risingwave_stream::executor::backfill::utils

Function get_progress_per_vnode

source 
pub(crate) async fn get_progress_per_vnode<S: StateStore, const IS_REPLICATED: bool>(
    state_table: &StateTableInner<S, BasicSerde, IS_REPLICATED>,
) -> StreamExecutorResult<Vec<(VirtualNode, BackfillStatePerVnode)>>
Expand description

Recovers progress per vnode, so we know which to backfill. See how it decodes the state with the inline comments.