pub type ShuffleFragmentStream = BoxStream<'static, Result<RecordBatch, String>>;
One upstream fragment’s batches, in write order.
pub struct ShuffleFragmentStream { /* private fields */ }