ray.data.DatasetPipeline.map#

DatasetPipeline.map(fn: Union[Callable[[ray.data.block.T], ray.data.block.U], _CallableClassProtocol[T, U]], *, compute: Union[str, ray.data._internal.compute.ComputeStrategy] = None, **ray_remote_args) → DatasetPipeline[U][source]#

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