Skip to main content

persist_pre_commit_metadata

risingwave_meta::manager::exactly_once_util

Function persist_pre_commit_metadata 

Source 
pub async fn persist_pre_commit_metadata(
    db: &DatabaseConnection,
    sink_id: SinkId,
    epoch: u64,
    commit_metadata: Option<Vec<u8>>,
    schema_change: Option<&PbSinkSchemaChange>,
) -> Result<()>