根据条件在 apache pig 中加入两个别名

Question

我想加入两个别名/关系，

say A has keys : a,b,c
and B has keys : x,y,z

应该是这样的：

C = JOIN A by a, (IF B.x matches "foo.*" then pick y else z)

如上逻辑。我该怎么做？

Answer 1

我的回答：

只需根据条件生成一个密钥，然后通过该密钥加入

例如。

BB = foreach B generate x,y,z,(x matches "foo.*") ? y : z as matchkey;
C = join A by a, BB by matchkey;
dump c;