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,
Collects data chunks from stream of rows.