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

Function _get_divisions

dask/dataframe/dask_expr/_shuffle.py:1322–1337  ·  view source on GitHub ↗
(
    frame,
    other,
    npartitions: int,
    ascending: bool = True,
    partition_size: float = 128e6,
    upsample: float = 1.0,
)

Source from the content-addressed store, hash-verified

1320
1321
1322def _get_divisions(
1323 frame,
1324 other,
1325 npartitions: int,
1326 ascending: bool = True,
1327 partition_size: float = 128e6,
1328 upsample: float = 1.0,
1329):
1330 key = (other._name, npartitions, ascending, partition_size, upsample)
1331 if key in divisions_lru:
1332 return divisions_lru[key]
1333 result = _calculate_divisions(
1334 frame, other, npartitions, ascending, partition_size, upsample
1335 )
1336 divisions_lru[key] = result
1337 return result
1338
1339
1340def _calculate_divisions(

Callers 4

_divisionsMethod · 0.85
_lowerMethod · 0.85
_divisionsMethod · 0.85
_lowerMethod · 0.85

Calls 1

_calculate_divisionsFunction · 0.70

Tested by

no test coverage detected