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

annotations, displayData, name, resourceHints

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>	withConnectTimeout(java.lang.Integer timeout) Cassandra client socket option for connect timeout in ms.
CassandraIO.Write<T>	withConnectTimeout(ValueProvider<java.lang.Integer> timeout) Cassandra client socket option for connect timeout in ms.
CassandraIO.Write<T>	withConsistencyLevel(java.lang.String consistencyLevel) Specify the consistency level for the request (e.g.
CassandraIO.Write<T>	withConsistencyLevel(ValueProvider<java.lang.String> consistencyLevel) Specify the consistency level for the request (e.g.
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>	withReadTimeout(java.lang.Integer timeout) Cassandra client socket option to set the read timeout in ms.
CassandraIO.Write<T>	withReadTimeout(ValueProvider<java.lang.Integer> timeout) Cassandra client socket option to set the read timeout in ms.
CassandraIO.Write<T>	withSsl(SSLOptions sslOptions) Optionally, specify SSLOptions configuration to utilize SSL.
CassandraIO.Write<T>	withSsl(ValueProvider<SSLOptions> sslOptions) Optionally, specify SSLOptions configuration to utilize SSL.
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

addAnnotation, compose, compose, getAdditionalInputs, getAnnotations, getDefaultOutputCoder, getDefaultOutputCoder, getDefaultOutputCoder, getKindString, getName, getResourceHints, populateDisplayData, setDisplayData, setResourceHints, toString, validate

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)

Specify the consistency level for the request (e.g. ONE, LOCAL_ONE, LOCAL_QUORUM, etc).

withConsistencyLevel

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

Specify the consistency level for the request (e.g. ONE, LOCAL_ONE, LOCAL_QUORUM, etc).

withConnectTimeout

public CassandraIO.Write<T> withConnectTimeout(java.lang.Integer timeout)

Cassandra client socket option for connect timeout in ms.

withConnectTimeout

public CassandraIO.Write<T> withConnectTimeout(ValueProvider<java.lang.Integer> timeout)

Cassandra client socket option for connect timeout in ms.

withReadTimeout

public CassandraIO.Write<T> withReadTimeout(java.lang.Integer timeout)

Cassandra client socket option to set the read timeout in ms.

withReadTimeout

public CassandraIO.Write<T> withReadTimeout(ValueProvider<java.lang.Integer> timeout)

Cassandra client socket option to set the read timeout in ms.

withMapperFactoryFn

public CassandraIO.Write<T> withMapperFactoryFn(SerializableFunction<Session,Mapper> mapperFactoryFn)

withSsl

public CassandraIO.Write<T> withSsl(SSLOptions sslOptions)

Optionally, specify SSLOptions configuration to utilize SSL. See https://docs.datastax.com/en/developer/java-driver/3.11/manual/ssl/#jsse-programmatic

withSsl

public CassandraIO.Write<T> withSsl(ValueProvider<SSLOptions> sslOptions)

Optionally, specify SSLOptions configuration to utilize SSL. See https://docs.datastax.com/en/developer/java-driver/3.11/manual/ssl/#jsse-programmatic

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>