pub fn render_fetch_work<G, S, F>(
scope: G,
collection_id: GlobalId,
source: S,
format: F,
work_requests: &Stream<G, Result<F::WorkRequest<S>, StorageErrorX>>,
) -> (Stream<G, Result<F::RecordChunk, StorageErrorX>>, PressOnDropButton)
Expand description
Render an operator that given a stream OneshotFormat::WorkRequest
s will fetch chunks of the
remote OneshotSource::Object
and return a stream of OneshotFormat::RecordChunk
s that
can be decoded into Row
s.