pyflink.datastream.connectors.cassandra.CassandraCommitter#

class CassandraCommitter(j_checkpoint_committer)[source]#

CheckpointCommitter that saves information about completed checkpoints within a separate table in a cassandra database.

Methods

default_checkpoint_committer(builder[, ...])

CheckpointCommitter that saves information about completed checkpoints within a separate table in a cassandra database.