risingwave_connector::sink::iceberg::exactly_once_util

Function persist_pre_commit_metadata

Source 
pub async fn persist_pre_commit_metadata(
    sink_id: u32,
    db: DatabaseConnection,
    start_epoch: u64,
    end_epoch: u64,
    pre_commit_metadata: Vec<u8>,
    snapshot_id: i64,
) -> Result<()>