Skip to main content

Encoder

Enum Encoder 

Source
enum Encoder<'a> {
Show 58 variants Boolean(BooleanEncoder<'a>), Int(IntEncoder<'a, Int32Type>), Long(LongEncoder<'a, Int64Type>), TimestampMicros(LongEncoder<'a, TimestampMicrosecondType>), TimestampMillis(LongEncoder<'a, TimestampMillisecondType>), TimestampNanos(LongEncoder<'a, TimestampNanosecondType>), Date32(IntEncoder<'a, Date32Type>), Time32SecsToMillis(Time32SecondsToMillisEncoder<'a>), Time32Millis(IntEncoder<'a, Time32MillisecondType>), Time64Micros(LongEncoder<'a, Time64MicrosecondType>), DurationSeconds(LongEncoder<'a, DurationSecondType>), DurationMillis(LongEncoder<'a, DurationMillisecondType>), DurationMicros(LongEncoder<'a, DurationMicrosecondType>), DurationNanos(LongEncoder<'a, DurationNanosecondType>), Float32(F32Encoder<'a>), Float64(F64Encoder<'a>), Binary(BinaryEncoder<'a, i32>), LargeBinary(BinaryEncoder<'a, i64>), Utf8(Utf8GenericEncoder<'a, i32>), Utf8Large(Utf8GenericEncoder<'a, i64>), Utf8View(Utf8ViewEncoder<'a>), BinaryView(BinaryViewEncoder<'a>), List(Box<ListEncoder<'a, i32>>), LargeList(Box<ListEncoder<'a, i64>>), ListView(Box<ListViewEncoder<'a, i32>>), LargeListView(Box<ListViewEncoder<'a, i64>>), FixedSizeList(Box<FixedSizeListEncoder<'a>>), Struct(Box<StructEncoder<'a>>), Fixed(FixedEncoder<'a>), Uuid(UuidEncoder<'a>), IntervalMonthDayNanoDuration(DurationEncoder<'a, IntervalMonthDayNanoType>), IntervalMonthDayNanoFixed(IntervalMonthDayNanoFixedEncoder<'a>), IntervalYearMonthDuration(DurationEncoder<'a, IntervalYearMonthType>), IntervalDayTimeDuration(DurationEncoder<'a, IntervalDayTimeType>), Decimal32(DecimalEncoder<'a, 4, Decimal32Array>), Decimal64(DecimalEncoder<'a, 8, Decimal64Array>), Decimal128(DecimalEncoder<'a, 16, Decimal128Array>), Decimal256(DecimalEncoder<'a, 32, Decimal256Array>), Enum(EnumEncoder<'a>), Map(Box<MapEncoder<'a>>), Union(Box<UnionEncoder<'a>>), RunEncoded16(Box<RunEncodedEncoder<'a, Int16Type>>), RunEncoded32(Box<RunEncodedEncoder<'a, Int32Type>>), RunEncoded64(Box<RunEncodedEncoder<'a, Int64Type>>), Null, Int8(Int8Encoder<'a>), Int16(Int16Encoder<'a>), UInt8(UInt8Encoder<'a>), UInt16(UInt16Encoder<'a>), UInt32(UInt32Encoder<'a>), UInt64Fixed(UInt64FixedEncoder<'a>), Float16Fixed(Float16FixedEncoder<'a>), Date64(LongEncoder<'a, Date64Type>), Time64Nanos(LongEncoder<'a, Time64NanosecondType>), Time32Secs(IntEncoder<'a, Time32SecondType>), TimestampSecs(LongEncoder<'a, TimestampSecondType>), IntervalYearMonthFixed(IntervalYearMonthFixedEncoder<'a>), IntervalDayTimeFixed(IntervalDayTimeFixedEncoder<'a>),
}

Variants§

§

Boolean(BooleanEncoder<'a>)

§

Int(IntEncoder<'a, Int32Type>)

§

Long(LongEncoder<'a, Int64Type>)

§

TimestampMicros(LongEncoder<'a, TimestampMicrosecondType>)

§

TimestampMillis(LongEncoder<'a, TimestampMillisecondType>)

§

TimestampNanos(LongEncoder<'a, TimestampNanosecondType>)

§

Date32(IntEncoder<'a, Date32Type>)

§

Time32SecsToMillis(Time32SecondsToMillisEncoder<'a>)

§

Time32Millis(IntEncoder<'a, Time32MillisecondType>)

§

Time64Micros(LongEncoder<'a, Time64MicrosecondType>)

§

DurationSeconds(LongEncoder<'a, DurationSecondType>)

§

DurationMillis(LongEncoder<'a, DurationMillisecondType>)

§

DurationMicros(LongEncoder<'a, DurationMicrosecondType>)

§

DurationNanos(LongEncoder<'a, DurationNanosecondType>)

§

Float32(F32Encoder<'a>)

§

Float64(F64Encoder<'a>)

§

Binary(BinaryEncoder<'a, i32>)

§

LargeBinary(BinaryEncoder<'a, i64>)

§

Utf8(Utf8GenericEncoder<'a, i32>)

§

Utf8Large(Utf8GenericEncoder<'a, i64>)

§

Utf8View(Utf8ViewEncoder<'a>)

§

BinaryView(BinaryViewEncoder<'a>)

§

List(Box<ListEncoder<'a, i32>>)

§

LargeList(Box<ListEncoder<'a, i64>>)

§

ListView(Box<ListViewEncoder<'a, i32>>)

§

LargeListView(Box<ListViewEncoder<'a, i64>>)

§

FixedSizeList(Box<FixedSizeListEncoder<'a>>)

§

Struct(Box<StructEncoder<'a>>)

§

Fixed(FixedEncoder<'a>)

Avro fixed encoder (raw bytes, no length)

§

Uuid(UuidEncoder<'a>)

Avro uuid logical type encoder (string with RFC‑4122 hyphenated text)

§

IntervalMonthDayNanoDuration(DurationEncoder<'a, IntervalMonthDayNanoType>)

Avro duration logical type encoder (fixed(12) months/days/millis) for MonthDayNano.

§

IntervalMonthDayNanoFixed(IntervalMonthDayNanoFixedEncoder<'a>)

Arrow Interval(MonthDayNano) custom logical type encoder (fixed(16) months/days/nanos)

§

IntervalYearMonthDuration(DurationEncoder<'a, IntervalYearMonthType>)

Avro duration logical type encoder (fixed(12) months/days/millis) for YearMonth.

§

IntervalDayTimeDuration(DurationEncoder<'a, IntervalDayTimeType>)

Avro duration logical type encoder (fixed(12) months/days/millis) for DayTime.

§

Decimal32(DecimalEncoder<'a, 4, Decimal32Array>)

§

Decimal64(DecimalEncoder<'a, 8, Decimal64Array>)

§

Decimal128(DecimalEncoder<'a, 16, Decimal128Array>)

§

Decimal256(DecimalEncoder<'a, 32, Decimal256Array>)

§

Enum(EnumEncoder<'a>)

Avro enum encoder: writes the key (int) as the enum index.

§

Map(Box<MapEncoder<'a>>)

§

Union(Box<UnionEncoder<'a>>)

§

RunEncoded16(Box<RunEncodedEncoder<'a, Int16Type>>)

Run-end encoded values with specific run-end index widths

§

RunEncoded32(Box<RunEncodedEncoder<'a, Int32Type>>)

§

RunEncoded64(Box<RunEncodedEncoder<'a, Int64Type>>)

§

Null

§

Int8(Int8Encoder<'a>)

§

Int16(Int16Encoder<'a>)

§

UInt8(UInt8Encoder<'a>)

§

UInt16(UInt16Encoder<'a>)

§

UInt32(UInt32Encoder<'a>)

§

UInt64Fixed(UInt64FixedEncoder<'a>)

§

Float16Fixed(Float16FixedEncoder<'a>)

§

Date64(LongEncoder<'a, Date64Type>)

§

Time64Nanos(LongEncoder<'a, Time64NanosecondType>)

§

Time32Secs(IntEncoder<'a, Time32SecondType>)

§

TimestampSecs(LongEncoder<'a, TimestampSecondType>)

§

IntervalYearMonthFixed(IntervalYearMonthFixedEncoder<'a>)

§

IntervalDayTimeFixed(IntervalDayTimeFixedEncoder<'a>)

Implementations§

Source§

impl<'a> Encoder<'a>

Source

fn encode<W: Write + ?Sized>( &mut self, out: &mut W, idx: usize, ) -> Result<(), AvroError>

Encode the value at idx.

Auto Trait Implementations§

§

impl<'a> Freeze for Encoder<'a>

§

impl<'a> !RefUnwindSafe for Encoder<'a>

§

impl<'a> Send for Encoder<'a>

§

impl<'a> Sync for Encoder<'a>

§

impl<'a> Unpin for Encoder<'a>

§

impl<'a> UnsafeUnpin for Encoder<'a>

§

impl<'a> !UnwindSafe for Encoder<'a>

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