org.apache.beam.sdk.io.cassandra

Class CassandraServiceImpl<T>

java.lang.Object

org.apache.beam.sdk.io.cassandra.CassandraServiceImpl<T>

public class CassandraServiceImpl<T>
extends java.lang.Object

An implementation of the CassandraService that actually use a Cassandra instance.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	org.apache.beam.sdk.io.cassandra.CassandraService.Deleter<T> Deleter for an entity.
static interface	org.apache.beam.sdk.io.cassandra.CassandraService.Writer<T> Writer for an entity.
protected class	CassandraServiceImpl.DeleterImpl Deleter storing an entity into Apache Cassandra database.

Constructor Summary

Constructors

Constructor and Description
CassandraServiceImpl()

Method Summary

Modifier and Type	Method and Description
org.apache.beam.sdk.io.cassandra.CassandraService.Deleter<T>	createDeleter(CassandraIO.Mutate<T> spec) Create a CassandraService.Writer that writes entities into the Cassandra instance.
org.apache.beam.sdk.io.cassandra.CassandraServiceImpl.CassandraReaderImpl	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.
org.apache.beam.sdk.io.cassandra.CassandraService.Writer<T>	createWriter(CassandraIO.Mutate<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.

Methods inherited from class java.lang.Object

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

Constructor Detail

CassandraServiceImpl

public CassandraServiceImpl()

Method Detail

createReader

public org.apache.beam.sdk.io.cassandra.CassandraServiceImpl.CassandraReaderImpl 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

public long getEstimatedSizeBytes(CassandraIO.Read<T> spec)

Returns an estimation of the size that could be read.

split

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

Split a table read into several sources.

createWriter

public org.apache.beam.sdk.io.cassandra.CassandraService.Writer<T> createWriter(CassandraIO.Mutate<T> spec)

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

createDeleter

public org.apache.beam.sdk.io.cassandra.CassandraService.Deleter<T> createDeleter(CassandraIO.Mutate<T> spec)

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