pyflink.datastream.connectors.cassandra.CassandraSink

class CassandraSink(j_cassandra_sink)

Sets the ClusterBuilder for this sink. A ClusterBuilder is used to configure the connection to cassandra.

Methods

add_sink(input)	Writes a DataStream into a Cassandra database.
disable_chaining()	Turns off chaining for this operator so thread co-location will not be used as an optimization.
name(name)	Set the name of this sink.
set_parallelism(parallelism)	Sets the parallelism for this sink.
set_uid_hash(uid_hash)	Sets an user provided hash for this operator.
slot_sharing_group(slot_sharing_group)	Sets the slot sharing group of this operation.
uid(uid)	Sets an ID for this operator.