2016-07-22 5 views
0

1行を複数行に変換して変換を適用しました。私はタプルを使用しようとしますが、PIGの複数行から単一カンマ区切り行へ

D = foreach grouped generate group, COUNT(R); 
requestFile = foreach D generate (bag{tuple(chararray)}) D.group as abc:{(group:chararray)}; 
G = GROUP requestFile ALL; 
F = FOREACH G generate requestFile; 

Dは、個々の単語、それが繰り返される回数のカウントが、wrkedいない

今私は、単一の行に個々の行を変換する必要があります。

答えて

0

あなたは上記のコードのように単一の行に複数の行を変換するBagToTupleのFLATTENを使用する必要があり、

D = FOREACH grouped generate group, COUNT(R); 
G = GROUP D ALL; 
F = FOREACH G generate FLATTEN(BagToTuple(D)) ; 
関連する問題