Module decode 

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

Re-exports

use crate::FlightData; 🔒

use crate::trailers::LazyTrailers; 🔒

use arrow_array::ArrayRef; 🔒

use arrow_array::RecordBatch; 🔒

use arrow_buffer::Buffer; 🔒

use arrow_schema::Schema; 🔒

use arrow_schema::SchemaRef; 🔒

use bytes::Bytes; 🔒

use futures::Stream; 🔒

use futures::StreamExt; 🔒

use futures::ready; 🔒

use futures::stream::BoxStream; 🔒

use std::collections::HashMap; 🔒

use std::fmt::Debug; 🔒

use std::fmt::Debug; 🔒

use std::pin::Pin; 🔒

use std::sync::Arc; 🔒

use std::task::Poll; 🔒

use tonic::metadata::MetadataMap; 🔒

use crate::error::FlightError; 🔒

use crate::error::Result; 🔒

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

FlightStreamState 🔒

tracks the state needed to reconstruct RecordBatches from a streaming flight response.

Enums

DecodedPayload

The result of decoding FlightData