Module polars_arrow::io::flight

Available on crate feature io_flight only.

Serialization and deserialization to Arrow’s flight protocol

Re-exports

• pub use super::ipc::write::default_ipc_fields;

Structs

• WriteOptionsio_ipc
  Options declaring the behaviour of writing to IPC

Functions

• deserialize_batch
  Deserializes FlightData representing a record batch message to RecordBatchT.
• deserialize_dictionary
  Deserializes FlightData, assuming it to be a dictionary message, into dictionaries.
• deserialize_message
  Deserializes FlightData into either a RecordBatchT (when the message is a record batch) or by upserting into dictionaries (when the message is a dictionary)
• deserialize_schemas
  Deserialize an IPC message into ArrowSchema, IpcSchema. Use to deserialize FlightData::data_header and SchemaResult::schema.
• serialize_batch
  Serializes RecordBatchT to a vector of FlightData representing the serialized dictionaries and a FlightData representing the batch.
• serialize_schema
  Serializes a ArrowSchema to FlightData.
• serialize_schema_to_info
  Convert a ArrowSchema to bytes in the format expected in arrow_format::flight::data::FlightInfo.
• serialize_schema_to_result
  Serializes a ArrowSchema to SchemaResult.