lance_encoding::decoder

Function create_decode_stream

Source 
pub fn create_decode_stream(
    schema: &Schema,
    num_rows: u64,
    batch_size: u32,
    is_structural: bool,
    should_validate: bool,
    rx: UnboundedReceiver<Result<DecoderMessage>>,
) -> BoxStream<'static, ReadBatchTask>