Function schedule_and_decode

pub fn schedule_and_decode(
    column_infos: Vec<Arc<ColumnInfo>>,
    requested_rows: RequestedRows,
    filter: FilterExpression,
    column_indices: Vec<u32>,
    target_schema: Arc<Schema>,
    config: SchedulerDecoderConfig,
) -> BoxStream<'static, ReadBatchTask>

Launches a scheduler on a dedicated (spawned) task and creates a decoder to decode the scheduled data and returns the decoder as a stream of record batches.

This is a convenience function that creates both the scheduler and the decoder which can be a little tricky to get right.