org.apache.beam.sdk.io.cassandra

Class CassandraServiceImpl<T>

java.lang.Object

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

All Implemented Interfaces:

java.io.Serializable, CassandraService<T>

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

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
protected class	CassandraServiceImpl.WriterImpl Writer storing an entity into Apache Cassandra database.

Nested classes/interfaces inherited from interface org.apache.beam.sdk.io.cassandra.CassandraService

CassandraService.Writer<T>

Constructor Summary

Constructors

Constructor and Description
CassandraServiceImpl()

Method Summary

Modifier and Type	Method and Description
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.
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.

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)

Description copied from interface: CassandraService

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

Specified by:

createReader in interface CassandraService<T>

getEstimatedSizeBytes

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

Description copied from interface: CassandraService

Returns an estimation of the size that could be read.

Specified by:

getEstimatedSizeBytes in interface CassandraService<T>

split

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

Description copied from interface: CassandraService

Split a table read into several sources.

Specified by:

split in interface CassandraService<T>

createWriter

public CassandraService.Writer createWriter(CassandraIO.Write<T> spec)

Description copied from interface: CassandraService

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

Specified by:

createWriter in interface CassandraService<T>