risingwave_batch::executor::source

Function covert_stream_chunk_to_batch_chunk

source 
fn covert_stream_chunk_to_batch_chunk(chunk: StreamChunk) -> Result<DataChunk>