A = LOAD 'a.csv' USING PigStorage(';') AS (value1:chararray,value2:chararray,value3:chararray);
B = FOREACH A GENERATE value1, FLATTEN(TOKENIZE(value2, ',')), value3;
DUMP B;
输入：
1;2,3,4;2
输出：
(1,2,2)
(1,3,2)
(1,4,2)
我们可以使用存储b；作为分隔符。
STORE B INTO 'requiredOutputLocation' USING PigStorage(';');
1条答案
按热度按时间31moq8wy1#
Pig脚本：
输入：
输出：
我们可以使用存储b；作为分隔符。