Skip to main content

fetch_work

risingwave_stream::executor::source::iceberg_update::fetch

Function fetch_work 

Source 
fn fetch_work(
    properties: IcebergProperties,
    tasks: Vec<IcebergUpdateFetchState>,
    chunk_size: usize,
    metrics: IcebergFileScanMetrics,
) -> Pin<Box<dyn Stream<Item = Result<FetchResult, StreamExecutorError>> + Send>>
Expand description

Reads a nonempty batch of tasks in order, then reports BatchFinished.