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

Method _divisions

dask/dataframe/dask_expr/_shuffle.py:1003–1017  ·  view source on GitHub ↗
(self)

Source from the content-addressed store, hash-verified

1001 _filter_passthrough = True
1002
1003 def _divisions(self):
1004 if self.frame.npartitions == 1:
1005 # Protect against triggering calculations when we only have one division
1006 return (None, None)
1007
1008 divisions, mins, maxes, presorted = _get_divisions(
1009 self.frame,
1010 self.frame[self.by[0]],
1011 self._npartitions_input,
1012 self._divisions_ascending,
1013 upsample=self.upsample,
1014 )
1015 if presorted:
1016 return self.frame.divisions
1017 return (None,) * len(divisions)
1018
1019 @property
1020 def _divisions_ascending(self) -> bool:

Callers 2

_lowerMethod · 0.45
_lowerMethod · 0.45

Calls 1

_get_divisionsFunction · 0.85

Tested by

no test coverage detected