Module stream 

Re-exports

use std::collections::HashMap; 🔒

use std::fmt::Debug; 🔒

use std::fmt::Debug; 🔒

use std::sync::Arc; 🔒

use arrow_array::ArrayRef; 🔒

use arrow_array::RecordBatch; 🔒

use arrow_buffer::Buffer; 🔒

use arrow_buffer::MutableBuffer; 🔒

use arrow_schema::ArrowError; 🔒

use arrow_schema::SchemaRef; 🔒

use crate::convert::MessageBuffer; 🔒

use crate::reader::MAX_PREALLOC_BYTES; 🔒

use crate::reader::RecordBatchDecoder; 🔒

use crate::reader::read_dictionary_impl; 🔒

use crate::CONTINUATION_MARKER; 🔒

use crate::MessageHeader; 🔒

Structs

StreamDecoder

A low-level interface for reading [RecordBatch] data from a stream of bytes

Enums

DecoderState 🔒

Functions

reserve_declared 🔒

Reserves a message’s declared length before copying its first bytes into an empty buf, bounded as in read_body_bounded. Growing with each input buffer instead doubles the capacity, and the decoded batch, which is zero-copy over buf, keeps up to twice its size.