class_docstr: CheckpointCommitter that saves information about completed checkpoints within a separate table
  in a cassandra database.
class_docstr_tok: ["CheckpointCommitter","that","saves","information","about","completed","checkpoints","within","a","separate","table","in","a","cassandra","database","."]
docstr: CheckpointCommitter that saves information about completed checkpoints within a separate
  table in a cassandra database.
  
  Entries are in the form: | operator_id | subtask_id | last_completed_checkpoint |
docstr_tok: ["CheckpointCommitter","that","saves","information","about","completed","checkpoints","within","a","separate","table","in","a","cassandra","database",".","Entries","are","in","the","form",":","|","operator_id","|","subtask_id","|","last_completed_checkpoint","|"]
code: def default_checkpoint_committer(
      builder: ClusterBuilder, key_space: str = None
  ) -> "CassandraCommitter":
      """
      CheckpointCommitter that saves information about completed checkpoints within a separate
      table in a cassandra database.
  
      Entries are in the form: | operator_id | subtask_id | last_completed_checkpoint |
      """
      JCassandraCommitter = (
          get_gateway().jvm.org.apache.flink.streaming.connectors.cassandra.CassandraCommitter
      )
      if key_space is None:
          j_checkpoint_committer = JCassandraCommitter(
              builder._j_cluster_builder
          )
      else:
          j_checkpoint_committer = JCassandraCommitter(
              builder._j_cluster_builder, key_space
          )
      return CassandraCommitter(j_checkpoint_committer)
  
imports: from enum import Enum
  from pyflink.common import Duration
  from pyflink.java_gateway import get_gateway
label_desc: Use image node_id 2 for calling the CassandraCommitter obj's underlying member method code with example usage: obj.default_checkpoint_committer(builder, key_space) and returns: CassandraCommitter