risingwave_connector::parser

Trait OpAction

source
trait OpAction {
    type Output<'a>;

    // Required methods
    fn output_for<'a>(datum: impl Into<DatumCow<'a>>) -> Self::Output<'a>;
    fn apply(builder: &mut ArrayBuilderImpl, output: Self::Output<'_>);
    fn rollback(builder: &mut ArrayBuilderImpl);
    fn finish(writer: &mut SourceStreamChunkRowWriter<'_>);
}

Required Associated Types§

source

type Output<'a>

Required Methods§

source

fn output_for<'a>(datum: impl Into<DatumCow<'a>>) -> Self::Output<'a>

source

fn apply(builder: &mut ArrayBuilderImpl, output: Self::Output<'_>)

source

fn rollback(builder: &mut ArrayBuilderImpl)

source

fn finish(writer: &mut SourceStreamChunkRowWriter<'_>)

Object Safety§

This trait is not object safe.

Implementors§