Class | Description |
---|---|
CassandraCommitter |
CheckpointCommitter that saves information about completed checkpoints within a separate table in a cassandra
database.
|
CassandraPojoSink<IN> |
Flink Sink to save data into a Cassandra cluster using
Mapper , which
it uses annotations from com.datastax.driver.mapping . |
CassandraSink<IN> |
This class wraps different Cassandra sink implementations to provide a common interface for all of them.
|
CassandraSink.CassandraPojoSinkBuilder<IN> | |
CassandraSink.CassandraSinkBuilder<IN> | |
CassandraSink.CassandraTupleSinkBuilder<IN extends Tuple> | |
CassandraSinkBase<IN,V> |
CassandraSinkBase is the common abstract class of
CassandraPojoSink and CassandraTupleSink . |
CassandraTupleSink<IN extends Tuple> |
Flink Sink to save data into a Cassandra cluster.
|
CassandraTupleWriteAheadSink<IN extends Tuple> |
Sink that emits its input elements into a Cassandra database.
|
ClusterBuilder |
This class is used to configure a
Cluster after deployment. |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.