Expand description
Utilities for working with streams of RecordBatch.
Functionsยง
- rechunk_
stream_ by_ size - Rechunks a stream of
RecordBatchso that each output batch has approximatelytarget_bytesof array data. - rechunk_
stream_ by_ size_ deep_ copy - Like
rechunk_stream_by_sizebut deep-copies slices so thatget_array_memory_sizereflects the true size of each output batch.