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

Packages that use ClusterBuilder

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

Uses of ClusterBuilder in org.apache.flink.batch.connectors.cassandra

Constructors in org.apache.flink.batch.connectors.cassandra with parameters of type ClusterBuilder

Constructor and Description
CassandraInputFormat(String query, ClusterBuilder builder)
CassandraInputFormatBase(String query, ClusterBuilder builder)
CassandraOutputFormat(String insertQuery, ClusterBuilder builder) Deprecated.
CassandraOutputFormatBase(String insertQuery, ClusterBuilder builder)
CassandraPojoInputFormat(String query, ClusterBuilder builder, Class<OUT> inputClass)
CassandraPojoInputFormat(String query, ClusterBuilder builder, Class<OUT> inputClass, MapperOptions mapperOptions)
CassandraPojoOutputFormat(ClusterBuilder builder, Class<OUT> outputClass)
CassandraPojoOutputFormat(ClusterBuilder builder, Class<OUT> outputClass, MapperOptions mapperOptions)
CassandraRowOutputFormat(String insertQuery, ClusterBuilder builder)
CassandraTupleOutputFormat(String insertQuery, ClusterBuilder builder)

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

Fields in org.apache.flink.streaming.connectors.cassandra declared as ClusterBuilder

Modifier and Type	Field and Description
protected ClusterBuilder	CassandraSink.CassandraSinkBuilder.builder

Methods in org.apache.flink.streaming.connectors.cassandra with parameters of type ClusterBuilder

Modifier and Type	Method and Description
CassandraSink.CassandraSinkBuilder<IN>	CassandraSink.CassandraSinkBuilder.setClusterBuilder(ClusterBuilder builder) Sets the ClusterBuilder for this sink.

Constructors in org.apache.flink.streaming.connectors.cassandra with parameters of type ClusterBuilder

Constructor and Description
AbstractCassandraTupleSink(String insertQuery, ClusterBuilder builder, CassandraSinkBaseConfig config, CassandraFailureHandler failureHandler)
CassandraAppendTableSink(ClusterBuilder builder, String cql)
CassandraAppendTableSink(ClusterBuilder builder, String cql, Properties properties)
CassandraCommitter(ClusterBuilder builder)
CassandraCommitter(ClusterBuilder builder, String keySpace)
CassandraPojoSink(Class<IN> clazz, ClusterBuilder builder) The main constructor for creating CassandraPojoSink.
CassandraPojoSink(Class<IN> clazz, ClusterBuilder builder, MapperOptions options)
CassandraPojoSink(Class<IN> clazz, ClusterBuilder builder, MapperOptions options, String keyspace)
CassandraPojoSink(Class<IN> clazz, ClusterBuilder builder, String keyspace)
CassandraRowSink(int rowArity, String insertQuery, ClusterBuilder builder)
CassandraRowWriteAheadSink(String insertQuery, TypeSerializer<Row> serializer, ClusterBuilder builder, CheckpointCommitter committer)
CassandraScalaProductSink(String insertQuery, ClusterBuilder builder)
CassandraTupleSink(String insertQuery, ClusterBuilder builder)
CassandraTupleWriteAheadSink(String insertQuery, TypeSerializer<IN> serializer, ClusterBuilder builder, CheckpointCommitter committer)