Execute sort remotely on cluster workers.
(self, key, descending=False)
| 131 | return ray.get(schema_ref) |
| 132 | |
| 133 | def sort(self, key, descending=False) -> "RemoteDatasetProxy": |
| 134 | """Execute sort remotely on cluster workers.""" |
| 135 | |
| 136 | @ray.remote |
| 137 | def _remote_sort(dataset, sort_key, desc): |
| 138 | return dataset.sort(sort_key, descending=desc) |
| 139 | |
| 140 | new_ref = _remote_sort.remote(self._dataset_ref, key, descending) |
| 141 | return RemoteDatasetProxy(new_ref) |
| 142 | |
| 143 | def limit(self, count) -> "RemoteDatasetProxy": |
| 144 | """Execute limit remotely on cluster workers.""" |