java - pig 中元组的转换

Question

我的输入如下

sachin,rooney,rajni

我想输出为

sachin
rooney
rajni

我尝试了 pig 脚本如下

A = load'input' using PigStorage(',');
B = foreach A generate FLATTEN(*);

但是它照原样输出

sachin,rooney,rajni

Answer 1

试试这个脚本

A = load 'input';

B = foreach a generate FLATTEN(STRSPLIT($0,','));

C = foreach B generate FLATTEN(TOBAG(*));