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: Sets an ID for this operator. The specified ID is used to assign the same operator ID
  across job submissions (for example when starting a job from a savepoint).
  Note that this ID needs to be unique per transformation and job. Otherwise, job submission
  will fail.
docstr_tok: ["Sets","an","ID","for","this","operator",".","The","specified","ID","is","used","to","assign","the","same","operator","ID","across","job","submissions","(","for","example","when","starting","a","job","from","a","savepoint",")",".","Note","that","this","ID","needs","to","be","unique","per","transformation","and","job",".","Otherwise",",","job","submission","will","fail","."]
code: def uid(self, uid: str) -> "CassandraSink":
      """
      Sets an ID for this operator. The specified ID is used to assign the same operator ID
      across job submissions (for example when starting a job from a savepoint).
      Note that this ID needs to be unique per transformation and job. Otherwise, job submission
      will fail.
      """
      self._j_cassandra_sink.uid(uid)
      return self
  
imports: from enum import Enum
  from pyflink.common import Duration
  from pyflink.java_gateway import get_gateway
label_desc: Use image node_id 3 for calling the CassandraSink obj's underlying member method code with example usage: obj.uid(uid) and returns: self