结构体 UnionDecoder 

struct UnionDecoder {
    fields: UnionFields,
    type_ids: Vec<i8>,
    offsets: Vec<i32>,
    branches: Vec<Decoder>,
    counts: Vec<i32>,
    reader_type_codes: Vec<i8>,
    default_emit_idx: usize,
    null_emit_idx: usize,
    plan: UnionReadPlan,
}

字段

fields: UnionFields

type_ids: Vec<i8>

offsets: Vec<i32>

branches: Vec<Decoder>

counts: Vec<i32>

reader_type_codes: Vec<i8>

default_emit_idx: usize

null_emit_idx: usize

plan: UnionReadPlan

实现

impl UnionDecoder

fn try_new( fields: UnionFields, branches: Vec<Decoder>, resolved: Option<ResolvedUnion>, ) -> Result<Self, ArrowError>

fn try_new_from_writer_union( info: ResolvedUnion, target: Box<Decoder>, ) -> Result<Self, ArrowError>

fn plan_from_resolved( resolved: Option<ResolvedUnion>, ) -> Result<UnionReadPlan, ArrowError>

fn read_tag(buf: &mut AvroCursor<'_>) -> Result<usize, ArrowError>

fn emit_to(&mut self, reader_idx: usize) -> Result<&mut Decoder, ArrowError>

fn on_decoder<F>( &mut self, fallback_idx: usize, action: F, ) -> Result<(), ArrowError>

where F: FnOnce(&mut Decoder) -> Result<(), ArrowError>,

fn append_null(&mut self) -> Result<(), ArrowError>

fn append_default(&mut self, lit: &AvroLiteral) -> Result<(), ArrowError>

fn decode(&mut self, buf: &mut AvroCursor<'_>) -> Result<(), ArrowError>

fn flush(&mut self, nulls: Option<NullBuffer>) -> Result<ArrayRef, ArrowError>

Trait 实现

impl Debug for UnionDecoder

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

使用给定的格式化程序格式化值。 阅读更多

impl Default for UnionDecoder

fn default() -> Self

返回某个类型的“默认值”。阅读更多