MCPcopy
hub / github.com/dask/dask / _unique_aggregate

Function _unique_aggregate

dask/dataframe/groupby.py:1213–1218  ·  view source on GitHub ↗
(series_gb, name=None)

Source from the content-addressed store, hash-verified

1211
1212
1213def _unique_aggregate(series_gb, name=None):
1214 data = {k: v.explode().unique() for k, v in series_gb}
1215 ret = type(series_gb.obj)(data, name=name)
1216 ret.index.names = series_gb.obj.index.names
1217 ret.index = ret.index.astype(series_gb.obj.index.dtype, copy=False)
1218 return ret
1219
1220
1221def _value_counts(x, **kwargs):

Callers

nothing calls this directly

Calls 3

uniqueMethod · 0.45
explodeMethod · 0.45
astypeMethod · 0.45

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…