如何穿越ApachePig?

pieyvz9o  于 2021-06-21  发布在  Pig
关注(0)|答案(1)|浏览(318)

我有这样的数据模式 {col1:chararray,col2:int,col3:bag{}} 例如

{a,1,{d,e}}

{b,2,{c}}

我想要一个像这样的输出

{a,1,d}

{a,1,e}

{b,2,c}

我觉得这有点像在一些柱子上画十字,但我不知道如何达到同样的效果?也许还有其他方法可以得到输出。

j2cgzkjk

j2cgzkjk1#

你将不得不使用tobag函数和展平

A = LOAD 'data.txt' USING PigStorage('\t') as (col1:chararray,col2:int,col3:bag{});
B = FOREACH A GENERATE col1,col2, FLATTEN(TOBAG(col3));

相关问题