グループ化されている関係があります。マップのようにグループ化された値にアクセスするにはどうすればよいですか?
data = load 'log.txt' as (id:chararray,name:chararray);
grouped = group data by id;
foreach data {
filtered = filter group by group.id=data.id;
};
グループを繰り返し処理し、結果のバッグをフィルタリングしようとしていた 1 つの方法。しかし、私のシナリオでは、外側のタプルを反復処理し、それらの結果を使用して、グループ化された値から対応するバッグを取得する必要があります。ネストされた foreach を試しましたが、以下の例外が発生しています。
expression is not a project expression: (Name: ScalarExpression) Type: null Uid: null)
役に立たないいくつかの組み合わせを試しました。