Skip to main content

Module exactly_once_util

risingwave_meta::manager

Module exactly_once_util 

Source

Functions§

clean_aborted_records
commit_and_prune_epoch
list_sink_states_ordered_by_epoch
persist_pre_commit_metadata

Type Aliases§

PendingSinkStateRow 🔒