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 the parallelism for this sink. The degree must be higher than zero.
docstr_tok: ["Sets","the","parallelism","for","this","sink",".","The","degree","must","be","higher","than","zero","."]
code: def set_parallelism(self, parallelism: int) -> "CassandraSink":
      """
      Sets the parallelism for this sink. The degree must be higher than zero.
      """
      self._j_cassandra_sink.setParallelism(parallelism)
      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 5 for calling the CassandraSink obj's underlying member method code with example usage: obj.set_parallelism(parallelism) and returns: self