MCPcopy Create free account
hub / github.com/dask/dask / SortValuesBlockwise

Class SortValuesBlockwise

dask/dataframe/dask_expr/_shuffle.py:1269–1283  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

1267
1268
1269class SortValuesBlockwise(Blockwise):
1270 _projection_passthrough = False
1271 _parameters = ["frame", "sort_function", "sort_kwargs"]
1272 _keyword_only = ["sort_function", "sort_kwargs"]
1273 _is_length_preserving = True
1274
1275 @staticmethod
1276 def operation(*args, **kwargs):
1277 sort_func = kwargs.pop("sort_function")
1278 sort_kwargs = kwargs.pop("sort_kwargs")
1279 return sort_func(*args, **kwargs, **sort_kwargs)
1280
1281 @functools.cached_property
1282 def _meta(self):
1283 return self.frame._meta
1284
1285
1286class SetIndexBlockwise(Blockwise):

Callers 1

_lowerMethod · 0.85

Calls

no outgoing calls

Tested by

no test coverage detected