org.apache.beam.sdk.io.cassandra

Class CassandraServiceImpl.DeleterImpl

java.lang.Object

org.apache.beam.sdk.io.cassandra.CassandraServiceImpl.DeleterImpl

All Implemented Interfaces:

java.lang.AutoCloseable, org.apache.beam.sdk.io.cassandra.CassandraService.Deleter<T>

Enclosing class:

CassandraServiceImpl<T>

protected class CassandraServiceImpl.DeleterImpl
extends java.lang.Object
implements org.apache.beam.sdk.io.cassandra.CassandraService.Deleter<T>

Deleter storing an entity into Apache Cassandra database.

Method Summary

Modifier and Type	Method and Description
void	close()
void	delete(T entity) This method should be synchronous.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.lang.AutoCloseable

close

Method Detail

delete

public void delete(T entity)
            throws java.util.concurrent.ExecutionException,
                   java.lang.InterruptedException

Description copied from interface: org.apache.beam.sdk.io.cassandra.CassandraService.Deleter

This method should be synchronous. It means you have to be sure that the entity is fully stored (and committed) into the Cassandra instance when you exit from this method.

Specified by:

delete in interface org.apache.beam.sdk.io.cassandra.CassandraService.Deleter<T>

Throws:

java.util.concurrent.ExecutionException

java.lang.InterruptedException

close

public void close()
           throws java.util.concurrent.ExecutionException,
                  java.lang.InterruptedException

Throws:

java.util.concurrent.ExecutionException

java.lang.InterruptedException