Pig - 如何在 pig 中使用嵌套的 for 循环来获取元组内的元素列表

Question

我有一个中间猪结构，如（A， B， （n. no Cs））例：

(a1,b1, (c11,c12))  
(a2,b2, (c21))  
(a3,b3, (c31,c32, c33))

现在，我想要格式的数据

(a1, b1, c11)  
(a1, b2, c12)  
(a2, b2, c21) etc.

我该怎么做？

本质上，我想要元组的大小，然后使用此大小运行嵌套的 for 循环。

Answer 1

你能试试下面的方法吗？

输入

a1      b1      (c11,c12)
a2      b2      (c21)
a3      b3      (c31,c32,c33)

猪脚本：

A = LOAD 'input' AS(f1,f2,T:(f3:chararray));
B = FOREACH A GENERATE f1,f2,FLATTEN(T);
C = FOREACH B GENERATE f1,f2,FLATTEN(TOKENIZE(T::f3));
DUMP C;

输出：

(a1,b1,c11)
(a1,b1,c12)
(a2,b2,c21)
(a3,b3,c31)
(a3,b3,c32)
(a3,b3,c33)