risingwave_connector::source::base

Type Alias StreamChunkWithState

Source 
pub type StreamChunkWithState = (StreamChunk, HashMap<SplitId, SplitImpl>);
Expand description

StreamChunk with the latest split state. The state is constructed in StreamReaderBuilder::into_retry_stream