struct UnionDecoder {
fields: UnionFields,
type_ids: Vec<i8>,
offsets: Vec<i32>,
branches: Vec<Decoder>,
counts: Vec<i32>,
reader_type_codes: Vec<i8>,
null_branch: Option<usize>,
default_emit_idx: usize,
null_emit_idx: usize,
plan: UnionReadPlan,
}
Fields§
§fields: UnionFields
§type_ids: Vec<i8>
§offsets: Vec<i32>
§branches: Vec<Decoder>
§counts: Vec<i32>
§reader_type_codes: Vec<i8>
§null_branch: Option<usize>
§default_emit_idx: usize
§null_emit_idx: usize
§plan: UnionReadPlan
Implementations§
Source§impl UnionDecoder
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>
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 Implementations§
Source§impl Debug for UnionDecoder
impl Debug for UnionDecoder
Auto Trait Implementations§
impl Freeze for UnionDecoder
impl RefUnwindSafe for UnionDecoder
impl Send for UnionDecoder
impl Sync for UnionDecoder
impl Unpin for UnionDecoder
impl UnwindSafe for UnionDecoder
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more