risingwave_batch::executor::utils

Function batch_read

source
pub fn batch_read(
    stream: BoxedDataChunkStream,
    rows: usize,
) -> Pin<Box<dyn Stream<Item = Result<Vec<DataChunk>, BatchError>> + Send>>
Expand description

Read at least rows rows.