org.apache.beam.sdk.io.cassandra

Interface CassandraService<T>

All Superinterfaces:

java.io.Serializable

All Known Implementing Classes:

CassandraServiceImpl

public interface CassandraService<T>
extends java.io.Serializable

An interface for real or fake implementations of Cassandra.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	CassandraService.Writer<T> Writer for an entity.

Method Summary

Modifier and Type	Method and Description
BoundedSource.BoundedReader<T>	createReader(org.apache.beam.sdk.io.cassandra.CassandraIO.CassandraSource<T> source) Returns a BoundedSource.BoundedReader that will read from Cassandra using the spec from CassandraIO.CassandraSource.
CassandraService.Writer	createWriter(CassandraIO.Write<T> spec) Create a CassandraService.Writer that writes entities into the Cassandra instance.
long	getEstimatedSizeBytes(CassandraIO.Read<T> spec) Returns an estimation of the size that could be read.
java.util.List<BoundedSource<T>>	split(CassandraIO.Read<T> spec, long desiredBundleSizeBytes) Split a table read into several sources.

Method Detail

createReader

BoundedSource.BoundedReader<T> createReader(org.apache.beam.sdk.io.cassandra.CassandraIO.CassandraSource<T> source)

Returns a BoundedSource.BoundedReader that will read from Cassandra using the spec from CassandraIO.CassandraSource.

getEstimatedSizeBytes

long getEstimatedSizeBytes(CassandraIO.Read<T> spec)

Returns an estimation of the size that could be read.

split

java.util.List<BoundedSource<T>> split(CassandraIO.Read<T> spec,
                                       long desiredBundleSizeBytes)

Split a table read into several sources.

createWriter

CassandraService.Writer createWriter(CassandraIO.Write<T> spec)
                              throws java.lang.Exception

Create a CassandraService.Writer that writes entities into the Cassandra instance.

Throws:

java.lang.Exception