risingwave_connector::parser

Trait SourceParserIntoStreamExt

source 
pub trait SourceParserIntoStreamExt
where
    Self: ByteStreamSourceParser,
{
    // Required method
    fn parse_stream(self, _: BoxSourceMessageStream) -> impl SourceChunkStream;
}

Required Methods§

source

fn parse_stream(self, _: BoxSourceMessageStream) -> impl SourceChunkStream

Parse a SourceMessage stream into a StreamChunk stream.

§Arguments
  • msg_stream: A stream of batches of SourceMessage.
§Returns

A SourceChunkStream of parsed chunks. Each of the parsed chunks are guaranteed to have less than or equal to source_ctrl_opts.chunk_size rows, unless there’s a large transaction and source_ctrl_opts.split_txn is false.

Object Safety§

This trait is not object safe.

Implementors§