Skip to main content

build_oneshot_ingestion_dataflow

mz_storage::render

Function build_oneshot_ingestion_dataflow 

Source 
pub(crate) fn build_oneshot_ingestion_dataflow(
    timely_worker: &mut Worker,
    storage_state: &mut StorageState,
    ingestion_id: Uuid,
    collection_id: GlobalId,
    collection_meta: CollectionMetadata,
    description: OneshotIngestionRequest,
)