Я хотел бы выполнить эквивалент «сохранить все a
в A
, где a.field == b.field
для некоторые b
в B
"в Apache Pig. Я реализую это так:
AB_joined = JOIN A by field, B by field;
A2 = FOREACH AB_joined GENERATE A::field as field, A::field2 as field2, A::field3 as field3;
Перечислять все записи A
довольно глупо, и я бы предпочел сделать что-то вроде
A2 = FOREACH AB_joined GENERATE flatten(A);
Однако, похоже, это не работает. Есть ли другой способ сделать что-то эквивалентное без перечисления полей A
?