Struct RecordBatchDecoder 

pub struct RecordBatchDecoder<'a> {
    batch: RecordBatch<'a>,
    schema: Arc<Schema>,
    dictionaries_by_id: &'a HashMap<i64, Arc<dyn Array>>,
    compression: Option<CompressionCodec>,
    version: MetadataVersion,
    data: &'a Buffer,
    nodes: VectorIter<'a, FieldNode>,
    buffers: VectorIter<'a, Buffer>,
    projection: Option<&'a [usize]>,
    require_alignment: bool,
    skip_validation: UnsafeFlag,
}

State for decoding Arrow arrays from an IPC RecordBatch structure to RecordBatch

Fields

batch: RecordBatch<'a>

schema: Arc<Schema>

dictionaries_by_id: &'a HashMap<i64, Arc<dyn Array>>

compression: Option<CompressionCodec>

version: MetadataVersion

data: &'a Buffer

nodes: VectorIter<'a, FieldNode>

buffers: VectorIter<'a, Buffer>

projection: Option<&'a [usize]>

require_alignment: bool

skip_validation: UnsafeFlag

Implementations

impl<'a> RecordBatchDecoder<'a>

pub fn with_projection( self, projection: Option<&'a [usize]>, ) -> RecordBatchDecoder<'a>

Set the projection (default: None)

If set, the projection is the list of column indices that will be read

pub fn with_require_alignment( self, require_alignment: bool, ) -> RecordBatchDecoder<'a>

Set require_alignment (default: false)

If true, buffers must be aligned appropriately or error will result. If false, buffers will be copied to aligned buffers if necessary.