Create dataset from pandas DataFrame - dispatched via @ray.remote.
(self, df: Any)
| 575 | return RemoteDatasetProxy(remote_fn.remote(dataset_name, split, kwargs)) |
| 576 | |
| 577 | def from_pandas(self, df: Any) -> Any: |
| 578 | """Create dataset from pandas DataFrame - dispatched via @ray.remote.""" |
| 579 | from feast.infra.ray_shared_utils import RemoteDatasetProxy |
| 580 | |
| 581 | @ray.remote |
| 582 | def _remote(dataframe): |
| 583 | import ray |
| 584 | |
| 585 | return ray.data.from_pandas(dataframe) |
| 586 | |
| 587 | opts = self._get_task_options() |
| 588 | remote_fn = _remote.options(**opts) if opts else _remote |
| 589 | return RemoteDatasetProxy(remote_fn.remote(df)) |
| 590 | |
| 591 | def from_arrow(self, table: Any) -> Any: |
| 592 | """Create dataset from Arrow table - dispatched via @ray.remote.""" |
nothing calls this directly
no test coverage detected