Skip to main content

instrument_scan_task_stream

risingwave_connector::source::iceberg::planner

Function instrument_scan_task_stream 

Source 
fn instrument_scan_task_stream(
    scan_tasks: FileScanTaskStream,
    metrics: Option<IcebergScanMetricsLabels>,
) -> Pin<Box<dyn Stream<Item = Result<FileScanTask, ConnectorError>> + Send>>