risingwave_meta::stream::stream_graph::fragment

Function fill_snapshot_backfill_epoch

source 
pub fn fill_snapshot_backfill_epoch(
    node: &mut StreamNode,
    snapshot_backfill_info: Option<&SnapshotBackfillInfo>,
    cross_db_snapshot_backfill_info: &SnapshotBackfillInfo,
) -> MetaResult<bool>
Expand description

Fill snapshot epoch for StreamScanNode of SnapshotBackfill. Return true when has change applied.