risingwave_storage::table

Function collect_data_chunk_with_builder

source
pub async fn collect_data_chunk_with_builder<E, S, R>(
    stream: &mut S,
    builder: &mut DataChunkBuilder,
) -> Result<Option<DataChunk>, E>
where R: Row, S: Stream<Item = Result<R, E>> + Unpin,
Expand description

Collects data chunks from stream of rows.