Module encode

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

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.