Создание всех полей из псевдонима после JOIN в Pig

Я хотел бы выполнить эквивалент «сохранить все 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?

8
задан duckworthd 30 May 2012 в 23:23
поделиться