Function create_decode_iterator

Source
pub fn create_decode_iterator(
    schema: &Schema,
    num_rows: u64,
    batch_size: u32,
    should_validate: bool,
    is_structural: bool,
    messages: VecDeque<Result<DecoderMessage>>,
) -> Box<dyn RecordBatchReader>
Expand description

Creates a iterator that decodes a set of messages in a blocking fashion

See schedule_and_decode_blocking for more information.