Struct AvroAccess

pub struct AvroAccess<'a> {
    value: &'a Value,
    options: AvroParseOptions<'a>,
}

Fields

value: &'a Value

options: AvroParseOptions<'a>

Implementations

impl<'a> AvroAccess<'a>

pub fn new(value: &'a Value, options: AvroParseOptions<'a>) -> Self

Trait Implementations

impl Access for AvroAccess<'_>

fn access<'a>( &'a self, path: &[&str], type_expected: &DataType, ) -> AccessResult<DatumCow<'a>>

Accesses path in the data structure (parsed Avro/JSON/Protobuf data), and then converts it to RisingWave Datum.