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.
pub fn batch_read(
stream: BoxedDataChunkStream,
rows: usize,
) -> Pin<Box<dyn Stream<Item = Result<Vec<DataChunk>, BatchError>> + Send>>
Read at least rows
rows.