ray.data.DatasetPipeline.flat_map#

DatasetPipeline.flat_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.flat_map to each dataset/window in this pipeline.