Skip to main content

record_batch_to_ipc

Function record_batch_to_ipc 

Source
pub fn record_batch_to_ipc(
    record_batch: DfRecordBatch,
) -> Result<(Bytes, Bytes, Bytes)>
Expand description

Encodes a batch into the schema, record-batch header and payload used by bulk inserts.

Uses the default Flight compression and rejects dictionary batches, whose additional Flight messages cannot be represented by this three-part format.