ray.data.DatasetPipeline.sort_each_window#

DatasetPipeline.sort_each_window(key: Union[None, str, Callable[[ray.data.block.T], Any]] = None, descending: bool = False) → ray.data.dataset_pipeline.DatasetPipeline[ray.data.block.U][source]#

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