Module decode

Decoder to create RecordBatch streams from FlightData streams. See FlightRecordBatchStream.

Structs

DecodedFlightData

FlightData and the decoded payload (Schema, RecordBatch), if any

FlightDataDecoder

Wrapper around a stream of FlightData that handles the details of decoding low level Flight messages into Schema and RecordBatches, including details such as dictionaries.

FlightRecordBatchStream

Decodes a Stream of FlightData back into RecordBatches. This can be used to decode the response from an Arrow Flight server

Enums

DecodedPayload

The result of decoding FlightData