pub fn scan_task_to_chunk(
table: Table,
data_file_scan_task: FileScanTask,
_: IcebergScanOpts,
metrics: Option<Arc<IcebergScanMetrics>>,
) -> impl Stream<Item = Result<DataChunk, ConnectorError>>
pub fn scan_task_to_chunk(
table: Table,
data_file_scan_task: FileScanTask,
_: IcebergScanOpts,
metrics: Option<Arc<IcebergScanMetrics>>,
) -> impl Stream<Item = Result<DataChunk, ConnectorError>>