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 user provided hash for this operator. This will be used AS IS the create the
  JobVertexID.
  
  The user provided hash is an alternative to the generated hashes, that is considered when
  identifying an operator through the default hash mechanics fails (e.g. because of changes
  between Flink versions).
  
  Note that this should be used as a workaround or for trouble shooting. The provided hash
  needs to be unique per transformation and job. Otherwise, job submission will fail.
  Furthermore, you cannot assign user-specified hash to intermediate nodes in an operator
  chain and trying so will let your job fail.
  
  A use case for this is in migration between Flink versions or changing the jobs in a way
  that changes the automatically generated hashes. In this case, providing the previous hashes
  directly through this method (e.g. obtained from old logs) can help to reestablish a lost
  mapping from states to their target operator.
docstr_tok: ["Sets","an","user","provided","hash","for","this","operator",".","This","will","be","used","AS","IS","the","create","the","JobVertexID",".","The","user","provided","hash","is","an","alternative","to","the","generated","hashes",",","that","is","considered","when","identifying","an","operator","through","the","default","hash","mechanics","fails","(","e.g",".","because","of","changes","between","Flink","versions",")",".","Note","that","this","should","be","used","as","a","workaround","or","for","trouble","shooting",".","The","provided","hash","needs","to","be","unique","per","transformation","and","job",".","Otherwise",",","job","submission","will","fail",".","Furthermore",",","you","can","not","assign","user-specified","hash","to","intermediate","nodes","in","an","operator","chain","and","trying","so","will","let","your","job","fail",".","A","use","case","for","this","is","in","migration","between","Flink","versions","or","changing","the","jobs","in","a","way","that","changes","the","automatically","generated","hashes",".","In","this","case",",","providing","the","previous","hashes","directly","through","this","method","(","e.g",".","obtained","from","old","logs",")","can","help","to","reestablish","a","lost","mapping","from","states","to","their","target","operator","."]
code: def set_uid_hash(self, uid_hash: str) -> "CassandraSink":
      """
      Sets an user provided hash for this operator. This will be used AS IS the create the
      JobVertexID.
  
      The user provided hash is an alternative to the generated hashes, that is considered when
      identifying an operator through the default hash mechanics fails (e.g. because of changes
      between Flink versions).
  
      Note that this should be used as a workaround or for trouble shooting. The provided hash
      needs to be unique per transformation and job. Otherwise, job submission will fail.
      Furthermore, you cannot assign user-specified hash to intermediate nodes in an operator
      chain and trying so will let your job fail.
  
      A use case for this is in migration between Flink versions or changing the jobs in a way
      that changes the automatically generated hashes. In this case, providing the previous hashes
      directly through this method (e.g. obtained from old logs) can help to reestablish a lost
      mapping from states to their target operator.
      """
      self._j_cassandra_sink.setUidHash(uid_hash)
      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 4 for calling the CassandraSink obj's underlying member method code with example usage: obj.set_uid_hash(uid_hash) and returns: self