hadoop - リレーションを使用して GROUP をフィルタリングする方法は?

Question

私が関係Aを持っているとしましょう

DUMP A;
(a)
(d)
(g)

そして今、A の値を使用してグループ G をフィルター処理したいと考えています。

DUMP G;
(a, {(a,b), (a,c)})
(c, {(c,d), (c,x)})
(d, {(d,b), (d,e)})

...結果が

(a, {(a,b), (a,c)})
(d, {(d,b), (d,e)})

次に、生成するグループを抽出します。

 (a,b)
 (a,c)
 (d,b)
 (d,e)

フィルタリング部分に次のことを試しましたが、うまくいきませんでした：

J = JOIN G BY group, A BY a1;
R = FOREACH (FILTER J BY J::group == A::a1)
    GENERATE FLATTEN(J.group);