Skip to main content

render_fetch_work

Function render_fetch_work 

Source
pub fn render_fetch_work<'scope, T, S, F>(
    scope: Scope<'scope, T>,
    collection_id: GlobalId,
    source: S,
    format: F,
    work_requests: StreamVec<'scope, T, Result<F::WorkRequest<S>, StorageErrorX>>,
) -> (StreamVec<'scope, T, Result<F::RecordChunk, StorageErrorX>>, PressOnDropButton)
where T: Timestamp, S: OneshotSource + Sync + 'static, F: OneshotFormat + Sync + 'static,
Expand description

Render an operator that given a stream OneshotFormat::WorkRequests will fetch chunks of the remote OneshotSource::Object and return a stream of OneshotFormat::RecordChunks that can be decoded into Rows.