class_docstr: Sets the ClusterBuilder for this sink. A ClusterBuilder is used to configure the connection to
  cassandra.
class_docstr_tok: ["Sets","the","ClusterBuilder","for","this","sink",".","A","ClusterBuilder","is","used","to","configure","the","connection","to","cassandra","."]
docstr: Writes a DataStream into a Cassandra database.
docstr_tok: ["Writes","a","DataStream","into","a","Cassandra","database","."]
code: def add_sink(input) -> "CassandraSinkBuilder":
      """
      Writes a DataStream into a Cassandra database.
      """
      JCassandraSink = (
          get_gateway().jvm.org.apache.flink.streaming.connectors.cassandra.CassandraSink
      )
      j_cassandra_sink_builder = JCassandraSink.addSink(
          input._j_data_stream
      )
      return CassandraSink.CassandraSinkBuilder(
          j_cassandra_sink_builder
      )
  
imports: from enum import Enum
  from pyflink.common import Duration
  from pyflink.java_gateway import get_gateway
label_desc: Use image node_id 8 for calling the CassandraSink obj's underlying member method code with example usage: obj.add_sink(input) and returns: CassandraSink