Module encode 

Encoder to create FlightData streams from RecordBatch streams. See FlightDataEncoderBuilder.

Re-exports

use std::collections::VecDeque; 🔒

use std::fmt::Debug; 🔒

use std::fmt::Debug; 🔒

use std::pin::Pin; 🔒

use std::sync::Arc; 🔒

use std::task::Poll; 🔒

use crate::FlightData; 🔒

use crate::FlightDescriptor; 🔒

use crate::SchemaAsIpc; 🔒

use crate::error::Result; 🔒

use arrow_array::Array; 🔒

use arrow_array::ArrayRef; 🔒

use arrow_array::RecordBatch; 🔒

use arrow_array::RecordBatchOptions; 🔒

use arrow_array::UnionArray; 🔒

use arrow_ipc::writer::DictionaryTracker; 🔒

use arrow_ipc::writer::IpcDataGenerator; 🔒

use arrow_ipc::writer::IpcWriteContext; 🔒

use arrow_ipc::writer::IpcWriteOptions; 🔒

use arrow_schema::ArrowError; 🔒

use arrow_schema::DataType; 🔒

use arrow_schema::Field; 🔒

use arrow_schema::FieldRef; 🔒

use arrow_schema::Fields; 🔒

use arrow_schema::Schema; 🔒

use arrow_schema::SchemaRef; 🔒

use arrow_schema::UnionMode; 🔒

use bytes::Bytes; 🔒

use futures::Stream; 🔒

use futures::StreamExt; 🔒

use futures::ready; 🔒

use futures::stream::BoxStream; 🔒

Structs

FlightDataEncoder

Stream that encodes a stream of record batches to flight data.

FlightDataEncoderBuilder

Creates a [Stream] of FlightDatas from a Stream of Result<RecordBatch, FlightError>.

FlightIpcEncoder 🔒

The data needed to encode a stream of flight data, holding on to shared Dictionaries.

Enums

DictionaryHandling

Defines how a FlightDataEncoder encodes DictionaryArrays

Constants

GRPC_TARGET_MAX_FLIGHT_SIZE_BYTES

Default target size for encoded FlightData.

Functions

hydrate_dictionaries 🔒

Hydrates any dictionaries arrays in batch to its underlying type. See hydrate_dictionary for more information.

hydrate_dictionary 🔒

Hydrates a dictionary to its underlying type.

prepare_field_for_flight 🔒

prepare_schema_for_flight 🔒

Prepare an arrow Schema for transport over the Arrow Flight protocol

split_batch_for_grpc_response 🔒

Split RecordBatch so it hopefully fits into a gRPC response.