hadoop - 根据“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;

另请参见 SPLIT documentation。