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.