Struct arrow_ipc::writer::IpcDataGenerator

pub struct IpcDataGenerator {}

Implementations

impl IpcDataGenerator

pub fn schema_to_bytes(
    &self,
    schema: &Schema,
    write_options: &IpcWriteOptions
) -> EncodedData

pub fn encoded_batch(
    &self,
    batch: &RecordBatch,
    dictionary_tracker: &mut DictionaryTracker,
    write_options: &IpcWriteOptions
) -> Result<(Vec<EncodedData>, EncodedData), ArrowError>

Encodes a batch to a number of EncodedData items (dictionary batches + the record batch). The DictionaryTracker keeps track of dictionaries with new dict_ids (so they are only sent once) Make sure the DictionaryTracker is initialized at the start of the stream.

Trait Implementations

impl Debug for IpcDataGenerator

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for IpcDataGenerator

fn default() -> IpcDataGenerator

Returns the “default value” for a type.