Dask: перебирать группы после использования Grouper в групповом - PullRequest
Новая
       8

Dask: перебирать группы после использования Grouper в групповом

0 голосов
/ 15 апреля 2020

Можно ли перебирать каждую группу после использования Grouper в групповой работе? Я пытался 

import dask.dataframe as dd
import pandas as pd
pdf = pd.DataFrame({'A':[1, 2, 3, 4, 5], 'B':['1985','1985','1990','1990','1990']})
pdf['B']=pd.to_datetime(pdf['B'], format="%Y")
ddf = dd.from_pandas(pdf, npartitions = 3)
groups = ddf.groupby(pd.Grouper(key='B', freq="Y"))
for group in ddf['B'].unique().compute():
    print(groups.get_group(pd.Timestamp(group))['A'].mean().compute())

Но получаю ошибку:

TypeError: object of type 'TimeGrouper' has no len()

Это похоже на вопрос повторять Объект GroupBy в сумерках , но с Grouper.

...