Создание записей на основе условия во время проецирования в Pig Latin

Question

Я хотел бы генерировать записи из существующей схемы на основе условия, например, я хочу сделать что-то вроде

A = load 'data' using PigStorage() as (f1:int, f2:int);
B = foreach A generate ( f1 == 0 ? null : A);

Каким будет подходящий метод для этого?

Answer 1

Вы можете сгенерировать B следующим образом:

SPLIT A INTO B IF f1 != 0;

См. Также РАЗДЕЛЕННАЯ документация .

Answer 2

A = load 'data' using PigStorage() as (f1:int, f2:int);

B = filter A by f1 != 0 ;