org.apache.beam.sdk.io.cassandra

Class CassandraIO.Write<T>

java.lang.Object

org.apache.beam.sdk.transforms.PTransform<PCollection<T>,PDone>

org.apache.beam.sdk.io.cassandra.CassandraIO.Write<T>

All Implemented Interfaces:

java.io.Serializable, HasDisplayData

Enclosing class:

CassandraIO

public abstract static class CassandraIO.Write<T>
extends PTransform<PCollection<T>,PDone>

A PTransform to mutate into Apache Cassandra. See CassandraIO for details on usage and configuration.

See Also:

Serialized Form

Field Summary

Fields inherited from class org.apache.beam.sdk.transforms.PTransform

name

Constructor Summary

Constructors

Constructor and Description
Write()

Method Summary

Modifier and Type	Method and Description
PDone	expand(PCollection<T> input) Override this method to specify how this PTransform should be expanded on the given InputT.
void	validate(PipelineOptions pipelineOptions) Called before running the Pipeline to verify this transform is fully and correctly specified.
CassandraIO.Write<T>	withConsistencyLevel(java.lang.String consistencyLevel)
CassandraIO.Write<T>	withEntity(java.lang.Class<T> entity) Specify the entity class in the input PCollection.
CassandraIO.Write<T>	withHosts(java.util.List<java.lang.String> hosts) Specify the Cassandra instance hosts where to write data.
CassandraIO.Write<T>	withKeyspace(java.lang.String keyspace) Specify the Cassandra keyspace where to write data.
CassandraIO.Write<T>	withLocalDc(java.lang.String localDc) Specify the local DC used by the load balancing policy.
CassandraIO.Write<T>	withMapperFactoryFn(SerializableFunction<com.datastax.driver.core.Session,Mapper> mapperFactoryFn)
CassandraIO.Write<T>	withPassword(java.lang.String password) Specify the password used for authentication.
CassandraIO.Write<T>	withPort(int port) Specify the Cassandra instance port number where to write data.
CassandraIO.Write<T>	withUsername(java.lang.String username) Specify the username used for authentication.

Methods inherited from class org.apache.beam.sdk.transforms.PTransform

compose, compose, getAdditionalInputs, getDefaultOutputCoder, getDefaultOutputCoder, getDefaultOutputCoder, getKindString, getName, populateDisplayData, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

Write

public Write()

Method Detail

withHosts

public CassandraIO.Write<T> withHosts(java.util.List<java.lang.String> hosts)

Specify the Cassandra instance hosts where to write data.

withPort

public CassandraIO.Write<T> withPort(int port)

Specify the Cassandra instance port number where to write data.

withKeyspace

public CassandraIO.Write<T> withKeyspace(java.lang.String keyspace)

Specify the Cassandra keyspace where to write data.

withEntity

public CassandraIO.Write<T> withEntity(java.lang.Class<T> entity)

Specify the entity class in the input PCollection. The CassandraIO will map this entity to the Cassandra table thanks to the annotations.

withUsername

public CassandraIO.Write<T> withUsername(java.lang.String username)

Specify the username used for authentication.

withPassword

public CassandraIO.Write<T> withPassword(java.lang.String password)

Specify the password used for authentication.

withLocalDc

public CassandraIO.Write<T> withLocalDc(java.lang.String localDc)

Specify the local DC used by the load balancing policy.

withConsistencyLevel

public CassandraIO.Write<T> withConsistencyLevel(java.lang.String consistencyLevel)

withMapperFactoryFn

public CassandraIO.Write<T> withMapperFactoryFn(SerializableFunction<com.datastax.driver.core.Session,Mapper> mapperFactoryFn)

validate

public void validate(PipelineOptions pipelineOptions)

Description copied from class: PTransform

Called before running the Pipeline to verify this transform is fully and correctly specified.

By default, does nothing.

Overrides:

validate in class PTransform<PCollection<T>,PDone>

expand

public PDone expand(PCollection<T> input)

Description copied from class: PTransform

Override this method to specify how this PTransform should be expanded on the given InputT.

NOTE: This method should not be called directly. Instead apply the PTransform should be applied to the InputT using the apply method.

Composite transforms, which are defined in terms of other transforms, should return the output of one of the composed transforms. Non-composite transforms, which do not apply any transforms internally, should return a new unbound output and register evaluators (via backend-specific registration methods).

Specified by:

expand in class PTransform<PCollection<T>,PDone>