pandas dfplyのgroup_byが機能しない

Question

前提・実現したいこと

dfplyでgroup_byを使った集計をしたい。

発生している問題・エラーメッセージ

dfplyでgroup_byを挟んで、smmarizeでsumやｎで集計したとき、
group_byが機能せずにカラム全体の集計値が表示される。

該当のソースコード

df >> group_by(df.Annotation) >> summarize(cor_cnt=sum(df.cor_res), cnt=n(df.Annotation))

試したこと

df.groupby('Annotation').sum()
df.groupby('Annotation').size()
上記の集計値は正しくgroup_byされていた。

df >> select(df.Annotation, df.cor_res) >> group_by(df.Annotation) >> summarize(cor_cnt=sum(df.cor_res), cnt=n(df.Annotation))
上記の書き方でもgroup_byは機能していなかった。

補足情報（FW/ツールのバージョンなど）

GoogleColab　Python3

####sumについての例です

######シンプルな入力例

Annotation	cor_res
0	0
1	1
2	0
3	1
0	1
1	1
2	1
3	1

######期待される結果

Annotation	cor_res
0	1
1	2
2	1
3	2

######実際の結果

Annotation	cor_res
0	6
1	6
2	6
3	6

Comments

[can110]

シンプルな入力データ例、それに期待する結果と実際に得られる結果の例を提示すると回答得られやすくなります。

[matac]

ご指摘ありがとうございます。内容を追加しました。

Answer 1

The X DataFrame symbol

The DataFrame as it is passed through the piping operations is represented by the symbol X

とのことなので、手前の結果を利用するにはXにて参照する必要があるようです。

import pandas as pd
from dfply import *

df = pd.DataFrame({'Annotation':[0,1,2,3,0,1,2,3], 'cor_res':[0,1,0,1,1,1,1,2]})
print(df)
#   Annotation  cor_res
#0           0        0
#1           1        1
#2           2        0
#3           3        1
#4           0        1
#5           1        1
#6           2        1
#7           3        2

print(df >> group_by(X.Annotation) >> summarize(cor_sum=X.cor_res.sum()))
#   Annotation  cor_sum
#0           0        1
#1           1        2
#2           2        1
#3           3        3

Comments

[matac]

ご教示ありがとうございました。
解決しました。