org.apache.beam.sdk.io.cassandra

Class CassandraServiceImpl.WriterImpl

java.lang.Object

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

All Implemented Interfaces:

java.lang.AutoCloseable, CassandraService.Writer<T>

Enclosing class:

CassandraServiceImpl<T>

protected class CassandraServiceImpl.WriterImpl
extends java.lang.Object
implements CassandraService.Writer<T>

Writer storing an entity into Apache Cassandra database.

Method Summary

Modifier and Type	Method and Description
void	close()
void	write(T entity) Write the entity to the Cassandra instance, using Mapper obtained with the MappingManager.

Methods inherited from class java.lang.Object

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

Method Detail

write

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

Write the entity to the Cassandra instance, using Mapper obtained with the MappingManager. This method uses Mapper.saveAsync(Object) method, which is asynchronous. Beam will wait for all futures to complete, to guarantee all writes have succeeded.

Specified by:

write in interface CassandraService.Writer<T>

Throws:

java.util.concurrent.ExecutionException

java.lang.InterruptedException

close

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

Specified by:

close in interface java.lang.AutoCloseable

Throws:

java.util.concurrent.ExecutionException

java.lang.InterruptedException