上記のコードで何が起こっているのか、ダンプ出力):
データSamle( 'SAMPLE_DATA/test_limiting.pig'):
1|5
1|5
1|6
2|9
2|9
3|1
3|2
そして、豚のスクリプト自体:
A = LOAD 'sample_data/test_limiting.pig' USING PigStorage('|') AS (c1:int, c2:int);
----
-- A: {c1: int,c2: int}
----
-- (1,5)
-- (1,5)
-- (1,6)
-- (2,9)
-- (2,9)
-- (3,1)
-- (3,2)
B = GROUP A BY (c1, c2);
----
-- B: {group: (c1: int,c2: int),A: {(c1: int,c2: int)}}
----
-- ((1,5),{(1,5),(1,5)})
-- ((1,6),{(1,6)})
-- ((2,9),{(2,9),(2,9)})
-- ((3,1),{(3,1)})
-- ((3,2),{(3,2)})
C = FOREACH B GENERATE group, COUNT(A) as num;
----
-- C: {group: (c1: int,c2: int),num: long}
----
-- ((1,5),2)
-- ((1,6),1)
-- ((2,9),2)
-- ((3,1),1)
-- ((3,2),1)
D = GROUP C BY group.c1;
----
-- D: {group: int,C: {(group: (c1: int,c2: int),num: long)}}
----
-- (1,{((1,5),2),((1,6),1)})
-- (2,{((2,9),2)})
-- (3,{((3,1),1),((3,2),1)})
E = FOREACH D {
SA = ORDER C BY num DESC;
SB = LIMIT SA 1;
GENERATE FLATTEN(SB.group);
}
----
-- E: {null::group: (c1: int,c2: int)}
----
-- ((1,5))
-- ((2,9))
-- ((3,1))
B tw、大文字の変種で爆撃されたので、参照 'グループ'を小文字で書く必要がありました。たぶん異なるバージョンのため、おそろしい。
Pigスキーマ参照エラーのために少し変更がありました。 "D = GROUP C BY c1": "D = GROUP C BY group.c1"と "GENERATE SB.c1、SB.c2"を読みます。 "GENERATE FLATTEN(SB.group)"ありがとうございました。 。よく働く! – GregH
あなたはようこそ、私は構文を修正した – frail