pyflink.datastream.connectors.cassandra.CassandraCommitter

class CassandraCommitter(j_checkpoint_committer)

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.