cascading - カスケード（バッファ）実装

Question

カスケード Hadoop でバッファを作成する必要があります。

フィールドがあるとします:

member_id,amountpaid,diadnosis_id,diagnosis_description,superGrouper_id,superGrouper_descriptiion,grouperId,grouperDescription

する必要がある

1. からフィールドをグループ化しmember_id、superGrouper_id
2. すべてのパイプを使用してこれらの情報をバッファに送信します
3. バッファ出力は次のようmember_idにsuperGrouperなりgrouperIdますdiagnosis_id。

バッファの作成を手伝ってください。前もって感謝します

Answer 1

次のことができます。

pipe = new GroupBy(pipe, new Fields("member_id", "superGrouper_id"), new Fields("superGrouper", "grouperId", "")); 
pipe = new Every(pipe, FirstNBuffer(int n));

間違っていたらごめんなさい。あなたの質問は明確ではありません。