Execute union remotely on cluster workers.
(self, other)
| 151 | return RemoteDatasetProxy(new_ref) |
| 152 | |
| 153 | def union(self, other) -> "RemoteDatasetProxy": |
| 154 | """Execute union remotely on cluster workers.""" |
| 155 | |
| 156 | @ray.remote |
| 157 | def _remote_union(dataset1, dataset2): |
| 158 | return dataset1.union(dataset2) |
| 159 | |
| 160 | new_ref = _remote_union.remote(self._dataset_ref, other._dataset_ref) |
| 161 | return RemoteDatasetProxy(new_ref) |
| 162 | |
| 163 | def materialize(self) -> "RemoteDatasetProxy": |
| 164 | """Execute materialize remotely on cluster workers.""" |
no test coverage detected