Decoder

Enum Decoder 

Source
enum Decoder {
Show 40 variants Null(usize), Boolean(BooleanBufferBuilder), Int32(Vec<i32>), Int64(Vec<i64>), DurationSecond(Vec<i64>), DurationMillisecond(Vec<i64>), DurationMicrosecond(Vec<i64>), DurationNanosecond(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>), Int32ToInt64(Vec<i64>), Int32ToFloat32(Vec<f32>), Int32ToFloat64(Vec<f64>), Int64ToFloat32(Vec<f32>), Int64ToFloat64(Vec<f64>), Float32ToFloat64(Vec<f64>), BytesToString(OffsetBufferBuilder<i32>, Vec<u8>), StringToBytes(OffsetBufferBuilder<i32>, Vec<u8>), Binary(OffsetBufferBuilder<i32>, Vec<u8>), String(OffsetBufferBuilder<i32>, Vec<u8>), StringView(OffsetBufferBuilder<i32>, Vec<u8>), Array(FieldRef, OffsetBufferBuilder<i32>, Box<Decoder>), Record(Fields, Vec<Decoder>, Option<Projector>), Map(FieldRef, OffsetBufferBuilder<i32>, OffsetBufferBuilder<i32>, Vec<u8>, Box<Decoder>), Fixed(i32, Vec<u8>), Enum(Vec<i32>, Arc<[String]>, Option<EnumResolution>), Duration(IntervalMonthDayNanoBuilder), Uuid(Vec<u8>), Decimal32(usize, Option<usize>, Option<usize>, Decimal32Builder), Decimal64(usize, Option<usize>, Option<usize>, Decimal64Builder), Decimal128(usize, Option<usize>, Option<usize>, Decimal128Builder), Decimal256(usize, Option<usize>, Option<usize>, Decimal256Builder), RunEndEncoded(u8, usize, Box<Decoder>), Union(UnionDecoder), Nullable(Nullability, NullBufferBuilder, Box<Decoder>, NullablePlan),
}

Variants§

§

Null(usize)

§

Boolean(BooleanBufferBuilder)

§

Int32(Vec<i32>)

§

Int64(Vec<i64>)

§

DurationSecond(Vec<i64>)

§

DurationMillisecond(Vec<i64>)

§

DurationMicrosecond(Vec<i64>)

§

DurationNanosecond(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>)

§

Int32ToInt64(Vec<i64>)

§

Int32ToFloat32(Vec<f32>)

§

Int32ToFloat64(Vec<f64>)

§

Int64ToFloat32(Vec<f32>)

§

Int64ToFloat64(Vec<f64>)

§

Float32ToFloat64(Vec<f64>)

§

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

§

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

§

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

§

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

String data encoded as UTF-8 bytes, mapped to Arrow’s StringArray

§

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

String data encoded as UTF-8 bytes, but mapped to Arrow’s StringViewArray

§

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

§

Record(Fields, Vec<Decoder>, Option<Projector>)

§

Map(FieldRef, OffsetBufferBuilder<i32>, OffsetBufferBuilder<i32>, Vec<u8>, Box<Decoder>)

§

Fixed(i32, Vec<u8>)

§

Enum(Vec<i32>, Arc<[String]>, Option<EnumResolution>)

§

Duration(IntervalMonthDayNanoBuilder)

§

Uuid(Vec<u8>)

§

Decimal32(usize, Option<usize>, Option<usize>, Decimal32Builder)

§

Decimal64(usize, Option<usize>, Option<usize>, Decimal64Builder)

§

Decimal128(usize, Option<usize>, Option<usize>, Decimal128Builder)

§

Decimal256(usize, Option<usize>, Option<usize>, Decimal256Builder)

§

RunEndEncoded(u8, usize, Box<Decoder>)

§

Union(UnionDecoder)

§

Nullable(Nullability, NullBufferBuilder, Box<Decoder>, NullablePlan)

Implementations§

Source§

impl Decoder

Source

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

Source

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

Source

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

Append a null record

Source

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

Append a single default literal into the decoder’s buffers

Source

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

Decode a single record from buf

Source

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

Source

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

Flush decoded records to an [ArrayRef]

Trait Implementations§

Source§

impl AsRef<str> for Decoder

Source§

fn as_ref(&self) -> &str

Converts this type into a shared reference of the (usually inferred) input type.
Source§

impl Debug for Decoder

Source§

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

Formats the value using the given formatter. Read more

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> Same for T

Source§

type Output = T

Should always be Self
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
§

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

§

fn vzip(self) -> V

§

impl<T> Allocation for T
where T: RefUnwindSafe + Send + Sync,