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>	withConsistencyLevel(ValueProvider<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>	withHosts(ValueProvider<java.util.List<java.lang.String>> hosts) Specify the hosts of the Apache Cassandra instances.
CassandraIO.Write<T>	withKeyspace(java.lang.String keyspace) Specify the Cassandra keyspace where to write data.
CassandraIO.Write<T>	withKeyspace(ValueProvider<java.lang.String> keyspace) Specify the Cassandra keyspace where to read data.
CassandraIO.Write<T>	withLocalDc(java.lang.String localDc) Specify the local DC used by the load balancing policy.
CassandraIO.Write<T>	withLocalDc(ValueProvider<java.lang.String> localDc) Specify the local DC used for the load balancing.
CassandraIO.Write<T>	withMapperFactoryFn(SerializableFunction<Session,Mapper> mapperFactoryFn)
CassandraIO.Write<T>	withPassword(java.lang.String password) Specify the password used for authentication.
CassandraIO.Write<T>	withPassword(ValueProvider<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>	withPort(ValueProvider<java.lang.Integer> port) Specify the port number of the Apache Cassandra instances.
CassandraIO.Write<T>	withUsername(java.lang.String username) Specify the username used for authentication.
CassandraIO.Write<T>	withUsername(ValueProvider<java.lang.String> username) Specify the username 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.

withHosts

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

Specify the hosts of the Apache Cassandra instances.

withPort

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

Specify the Cassandra instance port number where to write data.

withPort

public CassandraIO.Write<T> withPort(ValueProvider<java.lang.Integer> port)

Specify the port number of the Apache Cassandra instances.

withKeyspace

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

Specify the Cassandra keyspace where to write data.

withKeyspace

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

Specify the Cassandra keyspace where to read 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.

withUsername

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

Specify the username for authentication.

withPassword

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

Specify the password used for authentication.

withPassword

public CassandraIO.Write<T> withPassword(ValueProvider<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.

withLocalDc

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

Specify the local DC used for the load balancing.

withConsistencyLevel

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

withConsistencyLevel

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

withMapperFactoryFn

public CassandraIO.Write<T> withMapperFactoryFn(SerializableFunction<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>