グループ化されたレコードをPigで複数のファイルに保存する方法は？

Question

レコードをロードしてグループ化した後、グループ化されたレコードを複数のファイル（グループごとに1つ（= userid））に保存するにはどうすればよいですか？それが指定された属性によってレコードを分割 -

records = LOAD 'input' AS (userid:int, ...); 
grouped_records = GROUP records BY userid; 

は私が望むまさにんPiggybankでMultiStorageクラスがあり、（rexported）Apacheの豚バージョン0.8.1-cdh3u3実際

Answer 1

A = LOAD 'mydata' USING PigStorage() as (a, b, c); 
STORE A INTO '/my/home/output' USING MultiStorage('/my/home/output','0', 'bz2', '\\t'); 

パラメータ：

1. parentPathStr - 親出力ディレクトリパス
2. splitFieldIndex - キーフィールドインデックス
3. 圧縮 - 'BZ2'、 'BZ'、 'GZ' または 'なし'
4. fieldDel - 出力レコード区切り文字。

参考：GrepCode

Answer 2

を使用しています（私の例では、インデックス '0' で）：

STORE records INTO 'output' USING org.apache.pig.piggybank.storage.MultiStorage('output', '0', 'none', ',');