org.apache.beam.sdk.io.cassandra

Interface CassandraService.Writer<T>

All Superinterfaces:

java.lang.AutoCloseable

All Known Implementing Classes:

CassandraServiceImpl.WriterImpl

Enclosing interface:

CassandraService<T>

public static interface CassandraService.Writer<T>
extends java.lang.AutoCloseable

Writer for an entity.

Method Summary

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

Methods inherited from interface java.lang.AutoCloseable

close

Method Detail

write

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

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.

Throws:

java.util.concurrent.ExecutionException

java.lang.InterruptedException