Skip to main content

decode_and_mfp

mz_storage_operators::persist_source

Function decode_and_mfp 

Source 
pub fn decode_and_mfp<'scope>(
    cfg: PersistConfig,
    fetched: StreamVec<'scope, (Timestamp, Subtime), FetchedBlob<SourceData, (), Timestamp, StorageDiff>>,
    name: &str,
    until: Antichain<Timestamp>,
    map_filter_project: Option<&mut MfpPlan>,
) -> StreamVec<'scope, (Timestamp, Subtime), (Result<Row, DataflowError>, (Timestamp, Subtime), Diff)>