@@ -997,7 +997,7 @@ def _cython_agg_general(
997
997
agg_items , agg_blocks = self ._cython_agg_blocks (
998
998
how , alt = alt , numeric_only = numeric_only , min_count = min_count
999
999
)
1000
- return self ._agg_blocks_to_frame ( agg_items , agg_blocks )
1000
+ return self ._wrap_agged_blocks ( agg_blocks , items = agg_items )
1001
1001
1002
1002
def _cython_agg_blocks (
1003
1003
self , how : str , alt = None , numeric_only : bool = True , min_count : int = - 1
@@ -1697,7 +1697,7 @@ def _wrap_transformed_output(
1697
1697
1698
1698
return result
1699
1699
1700
- def _agg_blocks_to_frame (self , items : Index , blocks : "List[Block]" ) -> DataFrame :
1700
+ def _wrap_agged_blocks (self , blocks : "List[Block]" , items : Index ) -> DataFrame :
1701
1701
if not self .as_index :
1702
1702
index = np .arange (blocks [0 ].values .shape [- 1 ])
1703
1703
mgr = BlockManager (blocks , axes = [items , index ])
@@ -1746,18 +1746,18 @@ def count(self):
1746
1746
ids , _ , ngroups = self .grouper .group_info
1747
1747
mask = ids != - 1
1748
1748
1749
- val = (
1749
+ vals = (
1750
1750
(mask & ~ _isna_ndarraylike (np .atleast_2d (blk .get_values ())))
1751
1751
for blk in data .blocks
1752
1752
)
1753
- loc = (blk .mgr_locs for blk in data .blocks )
1753
+ locs = (blk .mgr_locs for blk in data .blocks )
1754
1754
1755
1755
counted = [
1756
- lib .count_level_2d (x , labels = ids , max_bin = ngroups , axis = 1 ) for x in val
1756
+ lib .count_level_2d (x , labels = ids , max_bin = ngroups , axis = 1 ) for x in vals
1757
1757
]
1758
- blocks = map ( make_block , counted , loc )
1758
+ blocks = [ make_block ( val , placement = loc ) for val , loc in zip ( counted , locs )]
1759
1759
1760
- return self ._agg_blocks_to_frame ( data . items , blocks = list ( blocks ) )
1760
+ return self ._wrap_agged_blocks ( blocks , items = data . items )
1761
1761
1762
1762
def nunique (self , dropna : bool = True ):
1763
1763
"""
0 commit comments