Module record 

Avro Decoder for Arrow types.

Re-exports

use crate::codec::AvroDataType; 🔒

use crate::codec::AvroLiteral; 🔒

use crate::codec::Codec; 🔒

use crate::codec::EnumMapping; 🔒

use crate::codec::Promotion; 🔒

use crate::codec::ResolutionInfo; 🔒

use crate::codec::ResolvedField; 🔒

use crate::codec::ResolvedRecord; 🔒

use crate::codec::ResolvedUnion; 🔒

use crate::codec::Tz; 🔒

use crate::errors::AvroError; 🔒

use crate::reader::cursor::AvroCursor; 🔒

use crate::schema::Nullability; 🔒

use arrow_array::builder::Decimal32Builder; 🔒

use arrow_array::builder::Decimal64Builder; 🔒

use arrow_array::builder::Decimal128Builder; 🔒

use arrow_array::builder::Decimal256Builder; 🔒

use arrow_array::builder::IntervalMonthDayNanoBuilder; 🔒

use arrow_schema::DECIMAL32_MAX_PRECISION; 🔒

use arrow_schema::DECIMAL64_MAX_PRECISION; 🔒

use arrow_schema::DECIMAL128_MAX_PRECISION; 🔒

use arrow_schema::DECIMAL256_MAX_PRECISION; 🔒

use arrow_schema::DataType; 🔒

use arrow_schema::Field as ArrowField; 🔒

use arrow_schema::FieldRef; 🔒

use arrow_schema::Fields; 🔒

use arrow_schema::Schema as ArrowSchema; 🔒

use arrow_schema::SchemaRef; 🔒

use arrow_schema::UnionFields; 🔒

use arrow_schema::UnionMode; 🔒

use arrow_select::take::TakeOptions; 🔒

use arrow_select::take::take; 🔒

use strum_macros::AsRefStr; 🔒

use uuid::Uuid; 🔒

use std::cmp::Ordering; 🔒

use std::mem; 🔒

use std::sync::Arc; 🔒

use arrow_array::types::*; 🔒

use arrow_array::*; 🔒

use arrow_buffer::*; 🔒

Macros

append_decimal_default 🔒

Macro to append a default decimal value from two’s-complement big-endian bytes into the corresponding decimal builder, with compile-time constructed error text.

decode_decimal 🔒

Macro to decode a decimal payload for a given width and integer type.

flush_decimal 🔒

Macro to finish a decimal builder into an array with precision/scale and nulls.

Structs

DispatchLookupTable 🔒

EnumResolution 🔒

NullableDecoder 🔒

Projector 🔒

ProjectorBuilder 🔒

RecordDecoder 🔒

Decodes avro encoded data into [RecordBatch]

UnionDecoder 🔒

UnionDecoderBranches 🔒

UnionDecoderBuilder 🔒

Enums

Decoder 🔒

FieldProjection 🔒

NegativeBlockBehavior 🔒

NullablePlan 🔒

Runtime plan for decoding reader-side ["null", T] types.

ResolutionPlan 🔒

Runtime plan for resolving writer-reader type differences.

Skipper 🔒

Lightweight skipper for non‑projected writer fields (fields present in the writer schema but omitted by the reader/projection); per Avro 1.11.1 schema resolution these fields are ignored.

UnionReadPlan 🔒

Constants

DEFAULT_CAPACITY 🔒

NO_SOURCE 🔒

Functions

flush_dict 🔒

flush_offsets 🔒

flush_primitive 🔒

flush_values 🔒

process_block_items 🔒

Decode count items, capping the running total at i32::MAX (the largest index an Arrow list/map offset holds). Otherwise a crafted i64::MAX count of a zero-byte item like null spins the loop forever (#10235); byte-consuming items self-terminate on cursor exhaustion, so valid blocks (including array<null>) are unaffected.

process_blockwise 🔒

read_blocks 🔒

read_decimal_bytes_be 🔒

sign_cast_to 🔒

Sign-extend or (when larger) validate-and-truncate a big-endian two’s-complement integer into exactly N bytes. This matches Avro’s decimal binary encoding: the payload is a big-endian two’s-complement integer, and when narrowing it must be representable without changing sign or value.

skip_blocks 🔒

values_equal_at 🔒