Module arrow_flight::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