Struct FlightIpcEncoder

struct FlightIpcEncoder {
    options: IpcWriteOptions,
    data_gen: IpcDataGenerator,
    dictionary_tracker: DictionaryTracker,
}

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

TODO: at allow dictionaries to be flushed / avoid building them

TODO limit on the number of dictionaries???

Fields

options: IpcWriteOptions

data_gen: IpcDataGenerator

dictionary_tracker: DictionaryTracker

Implementations

impl FlightIpcEncoder

fn new(options: IpcWriteOptions, error_on_replacement: bool) -> Self

fn encode_schema(&self, schema: &Schema) -> FlightData

Encode a schema as a FlightData

fn encode_batch( &mut self, batch: &RecordBatch, ) -> Result<(Vec<FlightData>, FlightData)>

Convert a RecordBatch to a Vec of FlightData representing dictionaries and a FlightData representing the batch