Struct FlightDecoder

pub struct FlightDecoder {
    schema: Option<SchemaRef>,
    schema_bytes: Option<Bytes>,
    dictionaries_by_id: HashMap<i64, ArrayRef>,
}

Fields

schema: Option<SchemaRef>

schema_bytes: Option<Bytes>

dictionaries_by_id: HashMap<i64, ArrayRef>

Implementations

impl FlightDecoder

pub fn try_from_schema_bytes(schema_bytes: &Bytes) -> Result<Self>

Build a FlightDecoder instance from provided schema bytes.

pub fn try_decode_record_batch( &mut self, data_header: &Bytes, data_body: &Bytes, ) -> Result<DfRecordBatch>

pub fn try_decode( &mut self, flight_data: &FlightData, ) -> Result<Option<FlightMessage>>

Try to decode the FlightData to a FlightMessage.

If the FlightData is of type DictionaryBatch (produced while encoding an Arrow [RecordBatch] with dictionary arrays), the decoder will not return any FlightMessages. Instead, it will update its internal dictionary cache. Other types of FlightData will be decoded to exactly one FlightMessage.

pub fn schema(&self) -> Option<&SchemaRef>

pub fn schema_bytes(&self) -> Option<Bytes>

Trait Implementations

impl Default for FlightDecoder

fn default() -> FlightDecoder

Returns the “default value” for a type.