ray.data.DatasetPipeline.add_column#

DatasetPipeline.add_column(col: str, fn: Callable[[pandas.DataFrame], pandas.Series], *, compute: Optional[str] = None, **ray_remote_args) → DatasetPipeline[U][source]#

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