Expand description
Decoder to create RecordBatch streams from FlightData streams.
See FlightRecordBatchStream.
Structs§
- Decoded
Flight Data - FlightData and the decoded payload (Schema, RecordBatch), if any
- Flight
Data Decoder - Wrapper around a stream of
FlightDatathat handles the details of decoding low level Flight messages into [Schema] and [RecordBatch]es, including details such as dictionaries. - Flight
Record Batch Stream - Decodes a [Stream] of
FlightDataback into [RecordBatch]es. This can be used to decode the response from an Arrow Flight server - Flight
Stream 🔒State - tracks the state needed to reconstruct [
RecordBatch]es from a streaming flight response.
Enums§
- Decoded
Payload - The result of decoding
FlightData