-
-
Notifications
You must be signed in to change notification settings - Fork 18.5k
Allow multiple lambdas in Groupby.aggregate #26905
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Changes from 1 commit
d877ae9
41b6096
54c36a1
9c2bcf2
d549046
3ece0a5
dde7610
b2947bd
6581abc
868cc60
be712d8
5aa538d
File filter
Filter by extension
Conversations
Jump to
Diff view
Diff view
There are no files selected for viewing
Original file line number | Diff line number | Diff line change |
---|---|---|
|
@@ -25,6 +25,7 @@ | |
from pandas.core.dtypes.common import ( | ||
ensure_int64, ensure_platform_int, is_bool, is_datetimelike, | ||
is_integer_dtype, is_interval_dtype, is_numeric_dtype, is_scalar) | ||
from pandas.core.dtypes.inference import is_dict_like, is_list_like | ||
TomAugspurger marked this conversation as resolved.
Show resolved
Hide resolved
|
||
from pandas.core.dtypes.missing import isna, notna | ||
|
||
from pandas._typing import FrameOrSeries | ||
|
@@ -208,6 +209,8 @@ def aggregate(self, func, *args, **kwargs): | |
raise TypeError("Must provide 'func' or tuples of " | ||
"'(column, aggfunc).") | ||
|
||
func = _maybe_mangle_lambdas(func) | ||
There was a problem hiding this comment. Choose a reason for hiding this commentThe reason will be displayed to describe this comment to others. Learn more. hmm I don't think you actually need to do this here, rather put it around https://github.com/pandas-dev/pandas/pull/26905/files#diff-bfee1ba9e7cb79839776fac1a57ed940L810 and pull out the change you have in https://github.com/pandas-dev/pandas/pull/26905/files#diff-bfee1ba9e7cb79839776fac1a57ed940L832 There was a problem hiding this comment. Choose a reason for hiding this commentThe reason will be displayed to describe this comment to others. Learn more. IIUC, the one on L810 is SeriesGroupBy.aggregate. I think it's entirely separate from NDFramGroupBy.aggregate. |
||
|
||
result, how = self._aggregate(func, _level=_level, *args, **kwargs) | ||
if how is None: | ||
return result | ||
|
@@ -830,6 +833,7 @@ def aggregate(self, func_or_funcs=None, *args, **kwargs): | |
if isinstance(func_or_funcs, abc.Iterable): | ||
# Catch instances of lists / tuples | ||
# but not the class list / tuple itself. | ||
func_or_funcs = _maybe_mangle_lambdas(func_or_funcs) | ||
ret = self._aggregate_multiple_funcs(func_or_funcs, | ||
(_level or 0) + 1) | ||
if relabeling: | ||
|
@@ -1710,3 +1714,69 @@ def _normalize_keyword_aggregation(kwargs): | |
order.append((column, | ||
com.get_callable_name(aggfunc) or aggfunc)) | ||
return aggspec, columns, order | ||
|
||
|
||
def _make_lambda(func, i): | ||
def f(*args, **kwargs): | ||
jreback marked this conversation as resolved.
Show resolved
Hide resolved
|
||
return func(*args, **kwargs) | ||
f.__name__ = "<lambda_{}>".format(i) | ||
return f | ||
|
||
|
||
def _managle_lambda_list(aggfuncs): | ||
i = 0 | ||
TomAugspurger marked this conversation as resolved.
Show resolved
Hide resolved
|
||
aggfuncs2 = [] | ||
TomAugspurger marked this conversation as resolved.
Show resolved
Hide resolved
|
||
for aggfunc in aggfuncs: | ||
if com.get_callable_name(aggfunc) == "<lambda>": | ||
if i > 0: | ||
aggfunc = _make_lambda(aggfunc, i) | ||
i += 1 | ||
aggfuncs2.append(aggfunc) | ||
|
||
return aggfuncs2 | ||
|
||
|
||
def _maybe_mangle_lambdas(agg_spec): | ||
""" | ||
TomAugspurger marked this conversation as resolved.
Show resolved
Hide resolved
|
||
Make new lambdas with unique names. | ||
|
||
Parameters | ||
---------- | ||
agg_spec : Any | ||
An argument to NDFrameGroupBy.agg. | ||
Non-dict-like `agg_spec` are pass through as is. | ||
jreback marked this conversation as resolved.
Show resolved
Hide resolved
|
||
For dict-like `agg_spec` a new spec is returned | ||
with name-mangled lambdas. | ||
|
||
Returns | ||
------- | ||
mangled : Any | ||
Same type as the input. | ||
|
||
Examples | ||
-------- | ||
>>> _maybe_mangle_lambdas('sum') | ||
'sum' | ||
|
||
>>> _maybe_mangle_lambdas([lambda: 1, lambda: 2]) # doctest: +SKIP | ||
[<function __main__.<lambda>()>, | ||
<function pandas...._make_lambda.<locals>.f(*args, **kwargs)>] | ||
""" | ||
is_dict = is_dict_like(agg_spec) | ||
if not (is_dict or is_list_like(agg_spec)): | ||
return agg_spec | ||
agg_spec2 = type(agg_spec)() # dict or OrderdDict | ||
|
||
if is_dict: | ||
for key in agg_spec: | ||
aggfuncs = agg_spec[key] | ||
TomAugspurger marked this conversation as resolved.
Show resolved
Hide resolved
|
||
if is_list_like(aggfuncs) and not is_dict_like(aggfuncs): | ||
aggfuncs2 = _managle_lambda_list(aggfuncs) | ||
else: | ||
aggfuncs2 = aggfuncs | ||
|
||
agg_spec2[key] = aggfuncs2 or aggfuncs | ||
else: | ||
agg_spec2 = _managle_lambda_list(agg_spec) | ||
|
||
return agg_spec2 |
Uh oh!
There was an error while loading. Please reload this page.