@@ -709,7 +709,7 @@ def _aggregate_series_fast(self, obj, func):
709
709
dummy = obj [:0 ].copy ()
710
710
indexer = lib .groupsort_indexer (group_index , ngroups )[0 ]
711
711
obj = obj .take (indexer )
712
- group_index = group_index . take ( indexer )
712
+ group_index = com . ndtake ( group_index , indexer )
713
713
grouper = lib .SeriesGrouper (obj , func , group_index , ngroups ,
714
714
dummy )
715
715
result , counts = grouper .get_result ()
@@ -986,7 +986,8 @@ def labels(self):
986
986
def counts (self ):
987
987
if self ._counts is None :
988
988
if self ._was_factor :
989
- self ._counts = lib .group_count (self .labels , self .ngroups )
989
+ self ._counts = lib .group_count (com ._ensure_int64 (self .labels ),
990
+ self .ngroups )
990
991
else :
991
992
self ._make_labels ()
992
993
return self ._counts
@@ -1397,7 +1398,7 @@ def aggregate(self, arg, *args, **kwargs):
1397
1398
zipped = zip (result .index .levels , result .index .labels ,
1398
1399
result .index .names )
1399
1400
for i , (lev , lab , name ) in enumerate (zipped ):
1400
- result .insert (i , name , lev .values . take ( lab ))
1401
+ result .insert (i , name , com . ndtake ( lev .values , lab ))
1401
1402
result = result .consolidate ()
1402
1403
else :
1403
1404
values = result .index .values
@@ -1812,7 +1813,7 @@ def generate_groups(data, group_index, ngroups, axis=0, factory=lambda x: x):
1812
1813
group_index = com ._ensure_int64 (group_index )
1813
1814
1814
1815
indexer = lib .groupsort_indexer (group_index , ngroups )[0 ]
1815
- group_index = group_index . take ( indexer )
1816
+ group_index = com . ndtake ( group_index , indexer )
1816
1817
1817
1818
if isinstance (data , BlockManager ):
1818
1819
# this is sort of wasteful but...
@@ -1984,11 +1985,11 @@ def _reorder_by_uniques(uniques, labels):
1984
1985
mask = labels < 0
1985
1986
1986
1987
# move labels to right locations (ie, unsort ascending labels)
1987
- labels = reverse_indexer . take ( labels )
1988
+ labels = com . ndtake ( reverse_indexer , labels )
1988
1989
np .putmask (labels , mask , - 1 )
1989
1990
1990
1991
# sort observed ids
1991
- uniques = uniques . take ( sorter )
1992
+ uniques = com . ndtake ( uniques , sorter )
1992
1993
1993
1994
return uniques , labels
1994
1995
0 commit comments