在 PIG 的多条记录中拆分一条记录

Question

我想为最后三个创建多个输入 fields.From 一条记录 我想为每条记录创建一个 tax 实例？我应该在 Pig 中使用什么方法？

输入模式

id     key   adr          name      tax     tax1     tax2

123456|1234|123 main st| jane doe| 123xxx | 124xxx | 125xxx

在 Pig 中是否可以从上面的输入得到以下输出？

123456|1234|123 main st| jane doe| 123xxx 

123456|1234|123 main st| jane doe| 124xxx 

123456|1234|123 main st| jane doe| 125xxx 

Answer 1

使用 ToBag()

A = LOAD 'data.txt' USING PigStorage(',');
B = FOREACH A GENERATE [=10=],,,,FLATTEN(ToBag(,,));
DUMP B;