Enum Decoder

enum Decoder {
    Null(usize),
    Boolean(BooleanBufferBuilder),
    Int32(Vec<i32>),
    Int64(Vec<i64>),
    Float32(Vec<f32>),
    Float64(Vec<f64>),
    Date32(Vec<i32>),
    TimeMillis(Vec<i32>),
    TimeMicros(Vec<i64>),
    TimestampMillis(bool, Vec<i64>),
    TimestampMicros(bool, Vec<i64>),
    Binary(OffsetBufferBuilder<i32>, Vec<u8>),
    String(OffsetBufferBuilder<i32>, Vec<u8>),
    List(FieldRef, OffsetBufferBuilder<i32>, Box<Decoder>),
    Record(Fields, Vec<Decoder>),
    Nullable(Nullability, NullBufferBuilder, Box<Decoder>),
}

Variants

Null(usize)

Boolean(BooleanBufferBuilder)

Int32(Vec<i32>)

Int64(Vec<i64>)

Float32(Vec<f32>)

Float64(Vec<f64>)

Date32(Vec<i32>)

TimeMillis(Vec<i32>)

TimeMicros(Vec<i64>)

TimestampMillis(bool, Vec<i64>)

TimestampMicros(bool, Vec<i64>)

Binary(OffsetBufferBuilder<i32>, Vec<u8>)

String(OffsetBufferBuilder<i32>, Vec<u8>)

List(FieldRef, OffsetBufferBuilder<i32>, Box<Decoder>)

Record(Fields, Vec<Decoder>)

Nullable(Nullability, NullBufferBuilder, Box<Decoder>)

Implementations

impl Decoder

fn try_new(data_type: &AvroDataType) -> Result<Self, ArrowError>

fn append_null(&mut self)

Append a null record

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

Decode a single record from buf

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

Flush decoded records to an [ArrayRef]

Trait Implementations

impl Debug for Decoder

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

Formats the value using the given formatter.