on_field

risingwave_connector::sink::encoder::avro

Function on_field 

Source 
fn on_field<D: MaybeData>(
    data_type: &DataType,
    maybe: D,
    expected: &Schema,
    refs: &NamesRef,
) -> Result<D::Out, FieldEncodeError>
Expand description

Handles both validate (without actual data) and encode. See MaybeData for more info.