c1 = LOAD 'hdfs://localhost:9000/PigData/patient.txt' USING PigStorage(',')
as (age:int,gender:chararray,zipcode:int);
c2 = LOAD 'hdfs://localhost:9000/PigData/att1' USING PigStorage(',') as (att:chararray,cnt:int);
res = FOREACH c2 generate $0;
%declare zip res.$0;
final = group c1 by $zip;
dump final;
我想将一个属性作为vaue存储在一个变量中,然后在该变量的帮助下对数据进行分组,而不直接提及值。。
1条答案
按热度按时间qmelpv7a1#
在属性前面加上
(chararray)
。假设要将zipcode转换为string。请参阅此处以获取转换文档按zipcode分组