We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent a76a403 commit 7d23f9dCopy full SHA for 7d23f9d
bigframes/core/groupby/__init__.py
@@ -339,9 +339,18 @@ def _agg_list(self, func: typing.Sequence) -> df.DataFrame:
339
for col_id in self._aggregated_columns()
340
for f in func
341
]
342
+
343
+ aggregated_columns = pd.MultiIndex.from_tuples(
344
+ [
345
+ self._block.col_id_to_label[col_id]
346
+ for col_id in self._aggregated_columns()
347
+ ],
348
+ names=[*self._block.column_labels.names],
349
+ ).to_frame(index=False)
350
351
column_labels = [
- (self._block.col_id_to_label[col_id], f)
- for col_id in self._aggregated_columns()
352
+ tuple(col_id) + (f,)
353
+ for col_id in aggregated_columns.to_numpy()
354
355
356
agg_block, _ = self._block.aggregate(
0 commit comments