Trait MaybeData

trait MaybeData: Debug {
    type Out;

    // Required methods
    fn on_base(
        self,
        f: impl FnOnce(ScalarRefImpl<'_>) -> Result<Value, FieldEncodeError>,
    ) -> Result<Self::Out, FieldEncodeError>;
    fn on_struct(
        self,
        st: &StructType,
        avro: &AvroSchema,
    ) -> Result<Self::Out, FieldEncodeError>;
    fn on_list(
        self,
        elem: &DataType,
        avro: &AvroSchema,
    ) -> Result<Self::Out, FieldEncodeError>;
    fn on_map(
        self,
        value_type: &DataType,
        avro_value_schema: &AvroSchema,
    ) -> Result<Self::Out, FieldEncodeError>;
    fn handle_nullable_union(
        out: Self::Out,
        opt_idx: OptIdx,
    ) -> Result<Self::Out, FieldEncodeError>;
}

A trait that assists code reuse between validate and encode.

• For validate, the inputs are (RisingWave type, ProtoBuf type).
• For encode, the inputs are (RisingWave type, RisingWave data, ProtoBuf type).

Thus we impl MaybeData for both [()] and DatumRef.

Required Associated Types

type Out

Required Methods

fn on_base( self, f: impl FnOnce(ScalarRefImpl<'_>) -> Result<Value, FieldEncodeError>, ) -> Result<Self::Out, FieldEncodeError>

fn on_struct( self, st: &StructType, avro: &AvroSchema, ) -> Result<Self::Out, FieldEncodeError>

Switch to RecordSchema after #12562

fn on_list( self, elem: &DataType, avro: &AvroSchema, ) -> Result<Self::Out, FieldEncodeError>

fn on_map( self, value_type: &DataType, avro_value_schema: &AvroSchema, ) -> Result<Self::Out, FieldEncodeError>

fn handle_nullable_union( out: Self::Out, opt_idx: OptIdx, ) -> Result<Self::Out, FieldEncodeError>

Object Safety

This trait is not object safe.

Implementations on Foreign Types

impl MaybeData for ()

type Out = ()

fn on_base( self, _: impl FnOnce(ScalarRefImpl<'_>) -> Result<Value, FieldEncodeError>, ) -> Result<Self::Out, FieldEncodeError>

fn on_struct( self, st: &StructType, avro: &AvroSchema, ) -> Result<Self::Out, FieldEncodeError>

fn on_list( self, elem: &DataType, avro: &AvroSchema, ) -> Result<Self::Out, FieldEncodeError>

fn on_map( self, elem: &DataType, avro: &AvroSchema, ) -> Result<Self::Out, FieldEncodeError>

fn handle_nullable_union( out: Self::Out, _: OptIdx, ) -> Result<Self::Out, FieldEncodeError>

impl MaybeData for DatumRef<'_>

type Out = Value

fn on_base( self, f: impl FnOnce(ScalarRefImpl<'_>) -> Result<Value, FieldEncodeError>, ) -> Result<Self::Out, FieldEncodeError>

fn on_struct( self, st: &StructType, avro: &AvroSchema, ) -> Result<Self::Out, FieldEncodeError>

fn on_list( self, elem: &DataType, avro: &AvroSchema, ) -> Result<Self::Out, FieldEncodeError>

fn on_map( self, elem: &DataType, avro: &AvroSchema, ) -> Result<Self::Out, FieldEncodeError>

fn handle_nullable_union( out: Self::Out, opt_idx: OptIdx, ) -> Result<Self::Out, FieldEncodeError>

Implementors