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

Packages that use CassandraSink.CassandraSinkBuilder

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

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

Subclasses of CassandraSink.CassandraSinkBuilder in org.apache.flink.streaming.connectors.cassandra

Modifier and Type	Class and Description
static class	CassandraSink.CassandraPojoSinkBuilder<IN> Builder for a CassandraPojoSink.
static class	CassandraSink.CassandraRowSinkBuilder Builder for a CassandraRowSink.
static class	CassandraSink.CassandraScalaProductSinkBuilder<IN extends scala.Product> Builder for a CassandraScalaProductSink.
static class	CassandraSink.CassandraTupleSinkBuilder<IN extends Tuple> Builder for a CassandraTupleSink.

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

Modifier and Type	Method and Description
static <IN> CassandraSink.CassandraSinkBuilder<IN>	CassandraSink.addSink(org.apache.flink.streaming.api.scala.DataStream<IN> input) Writes a DataStream into a Cassandra database.
static <IN> CassandraSink.CassandraSinkBuilder<IN>	CassandraSink.addSink(DataStream<IN> input) Writes a DataStream into a Cassandra database.
CassandraSink.CassandraSinkBuilder<IN>	CassandraSink.CassandraSinkBuilder.enableIgnoreNullFields() Enables ignoring null values, treats null values as unset and avoids writing null fields and creating tombstones.
CassandraSink.CassandraSinkBuilder<IN>	CassandraSink.CassandraSinkBuilder.enableWriteAheadLog() Enables the write-ahead log, which allows exactly-once processing for non-deterministic algorithms that use idempotent updates.
CassandraSink.CassandraSinkBuilder<IN>	CassandraSink.CassandraSinkBuilder.enableWriteAheadLog(CheckpointCommitter committer) Enables the write-ahead log, which allows exactly-once processing for non-deterministic algorithms that use idempotent updates.
CassandraSink.CassandraSinkBuilder<IN>	CassandraSink.CassandraSinkBuilder.setClusterBuilder(ClusterBuilder builder) Sets the ClusterBuilder for this sink.
CassandraSink.CassandraSinkBuilder<IN>	CassandraSink.CassandraSinkBuilder.setDefaultKeyspace(String keyspace) Sets the keyspace to be used.
CassandraSink.CassandraSinkBuilder<IN>	CassandraSink.CassandraSinkBuilder.setFailureHandler(CassandraFailureHandler failureHandler) Sets the failure handler for this sink.
CassandraSink.CassandraSinkBuilder<IN>	CassandraSink.CassandraSinkBuilder.setHost(String host) Sets the cassandra host to connect to.
CassandraSink.CassandraSinkBuilder<IN>	CassandraSink.CassandraSinkBuilder.setHost(String host, int port) Sets the cassandra host/port to connect to.
CassandraSink.CassandraSinkBuilder<IN>	CassandraSink.CassandraSinkBuilder.setMapperOptions(MapperOptions options) Sets the mapper options for this sink.
CassandraSink.CassandraSinkBuilder<IN>	CassandraSink.CassandraSinkBuilder.setMaxConcurrentRequests(int maxConcurrentRequests) Sets the maximum allowed number of concurrent requests for this sink.
CassandraSink.CassandraSinkBuilder<IN>	CassandraSink.CassandraSinkBuilder.setMaxConcurrentRequests(int maxConcurrentRequests, java.time.Duration timeout) Sets the maximum allowed number of concurrent requests for this sink.
CassandraSink.CassandraSinkBuilder<IN>	CassandraSink.CassandraSinkBuilder.setQuery(String query) Sets the query that is to be executed for every record.