@Experimental(value=SOURCE_SINK)

Package org.apache.beam.sdk.io.cassandra

Transforms for reading and writing from/to Apache Cassandra.

See: Description

Interface Summary

Interface	Description
Mapper<T>	This interface allows you to implement a custom mapper to read and persist elements from/to Cassandra.

Class Summary

Class	Description
CassandraIO	An IO to read and write from/to Apache Cassandra
CassandraIO.Read<T>	A PTransform to read data from Apache Cassandra.
CassandraIO.Write<T>	A PTransform to mutate into Apache Cassandra.

Enum Summary

Enum	Description
CassandraIO.MutationType	Specify the mutation type: either write or delete.

Package org.apache.beam.sdk.io.cassandra Description

Transforms for reading and writing from/to Apache Cassandra.

See Also:

CassandraIO