Struct mz_interchange::avro::encode::AvroEncoder

pub struct AvroEncoder {
    columns: Vec<(ColumnName, ColumnType)>,
    schema: Schema,
    schema_id: i32,
}

Manages encoding of Avro-encoded bytes.

Fields

columns: Vec<(ColumnName, ColumnType)>

schema: Schema

schema_id: i32

Implementations

impl AvroEncoder

pub fn new( desc: RelationDesc, debezium: bool, schema: &str, schema_id: i32, ) -> Self

Trait Implementations

impl Debug for AvroEncoder

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

Formats the value using the given formatter.

impl Encode for AvroEncoder

fn encode_unchecked(&self, row: Row) -> Vec<u8>

fn hash(&self, buf: &[u8]) -> u64

Given the output of a call to Encode::encode_unchecked, returns a hash that is suitable for stable partitioning.