Uses of Class
org.apache.flink.streaming.connectors.cassandra.CassandraSink

Packages that use CassandraSink

Package	Description
org.apache.flink.streaming.connectors.cassandra

Uses of CassandraSink in org.apache.flink.streaming.connectors.cassandra

Methods in org.apache.flink.streaming.connectors.cassandra that return CassandraSink

Modifier and Type	Method and Description
CassandraSink<IN>	CassandraSink.CassandraSinkBuilder.build() Finalizes the configuration of this sink.
protected abstract CassandraSink<IN>	CassandraSink.CassandraSinkBuilder.createSink()
CassandraSink<IN>	CassandraSink.CassandraTupleSinkBuilder.createSink()
protected CassandraSink<Row>	CassandraSink.CassandraRowSinkBuilder.createSink()
CassandraSink<IN>	CassandraSink.CassandraPojoSinkBuilder.createSink()
CassandraSink<IN>	CassandraSink.CassandraScalaProductSinkBuilder.createSink()
protected abstract CassandraSink<IN>	CassandraSink.CassandraSinkBuilder.createWriteAheadSink()
protected CassandraSink<IN>	CassandraSink.CassandraTupleSinkBuilder.createWriteAheadSink()
protected CassandraSink<Row>	CassandraSink.CassandraRowSinkBuilder.createWriteAheadSink()
protected CassandraSink<IN>	CassandraSink.CassandraPojoSinkBuilder.createWriteAheadSink()
protected CassandraSink<IN>	CassandraSink.CassandraScalaProductSinkBuilder.createWriteAheadSink()
CassandraSink<IN>	CassandraSink.disableChaining() Turns off chaining for this operator so thread co-location will not be used as an optimization.
CassandraSink<IN>	CassandraSink.name(String name) Sets the name of this sink.
CassandraSink<IN>	CassandraSink.setParallelism(int parallelism) Sets the parallelism for this sink.
CassandraSink<IN>	CassandraSink.setUidHash(String uidHash) Sets an user provided hash for this operator.
CassandraSink<IN>	CassandraSink.slotSharingGroup(String slotSharingGroup) Sets the slot sharing group of this operation.
CassandraSink<IN>	CassandraSink.uid(String uid) Sets an ID for this operator.