new_fake_barrier

risingwave_meta::barrier::checkpoint::independent_job

Function new_fake_barrier 

Source 
fn new_fake_barrier(
    prev_epoch_fake_physical_time: &mut u64,
    pending_non_checkpoint_barriers: &mut Vec<u64>,
    kind: PbBarrierKind,
) -> BarrierInfo
Expand description

Build a fake BarrierInfo for independent partial-graph barriers.