A = load '$input1' using pigStorage() AS (a,b,c,d,e)
B = load '$input2' using pigStorage() AS (a,b1,c1,d1,e1)
C = JOIN A by a, B by a;
D = do something;
'D' 应该是格式 (a,b,c,d,e,b1)
如何实现?
最佳答案
D = FOREACH C GENERATE A::a .. A::e, B::b AS b1;
关于hadoop - 从 PIG JOIN 的其他关系中选择一个关系所有字段和一个或两个,如何?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/22224648/