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

Function _groupby_slice_transform

dask/dataframe/groupby.py:125–148  ·  view source on GitHub ↗
(
    df,
    grouper,
    key,
    func,
    *args,
    group_keys=GROUP_KEYS_DEFAULT,
    dropna=None,
    observed=None,
    **kwargs,
)

Source from the content-addressed store, hash-verified

123
124
125def _groupby_slice_transform(
126 df,
127 grouper,
128 key,
129 func,
130 *args,
131 group_keys=GROUP_KEYS_DEFAULT,
132 dropna=None,
133 observed=None,
134 **kwargs,
135):
136 # No need to use raise if unaligned here - this is only called after
137 # shuffling, which makes everything aligned already
138 dropna = {"dropna": dropna} if dropna is not None else {}
139 observed = {"observed": observed} if observed is not None else {}
140 g = df.groupby(grouper, group_keys=group_keys, **observed, **dropna)
141 if key:
142 g = g[key]
143
144 # Cannot call transform on an empty dataframe
145 if len(df) == 0:
146 return g.apply(func, *args, **kwargs)
147
148 return g.transform(func, *args, **kwargs)
149
150
151def _groupby_slice_shift(

Callers 1

groupby_slice_transformFunction · 0.90

Calls 3

transformMethod · 0.80
groupbyMethod · 0.45
applyMethod · 0.45

Tested by

no test coverage detected