ray.data.DatasetPipeline.repartition_each_window#

DatasetPipeline.repartition_each_window(num_blocks: int, *, shuffle: bool = False) → ray.data.dataset_pipeline.DatasetPipeline[ray.data.block.U][source]#

Apply Dataset.repartition to each dataset/window in this pipeline.