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

package org.apache.beam.sdk.io.cassandra

Transforms for reading and writing from/to Apache Cassandra.

See Also:

• CassandraIO

Related Packages

Package	Description
org.apache.beam.sdk.io	Defines transforms for reading and writing common storage formats, including invalid reference org.apache.beam.sdk.io.AvroIO , and TextIO.

Class	Description
CassandraIO	An IO to read and write from/to Apache Cassandra
CassandraIO.MutationType	Specify the mutation type: either write or delete.
CassandraIO.Read<T>	A PTransform to read data from Apache Cassandra.
CassandraIO.ReadAll<T>	A PTransform to read data from Apache Cassandra.
CassandraIO.Write<T>	A PTransform to mutate into Apache Cassandra.
ConnectionManager
Mapper<T>	This interface allows you to implement a custom mapper to read and persist elements from/to Cassandra.
RingRange	Models a Cassandra token range.