SourceParserIntoStreamExt

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.

Dyn Compatibility§

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementors§