你可能需要打两次电话。注意,在元组上展平只是将元组中的每个字段提升到顶级字段。flatte on bag生成包中每个记录与generate中所有其他表达式的叉积。
A = load 'test.txt' using PigStorage() as (a0:int, t1:(a1:int, b1 {(a3:int,a4:chararray,a5:chararray)}));
describe A;
B = FOREACH A GENERATE FLATTEN(t1);
describe B;
C = FOREACH B GENERATE a1, FLATTEN(b1);
describe C;
dump C;
1条答案
按热度按时间myzjeezk1#
你可能需要打两次电话。注意,在元组上展平只是将元组中的每个字段提升到顶级字段。flatte on bag生成包中每个记录与generate中所有其他表达式的叉积。
输出