hadoop - 字符串连接在 pig 中不起作用

我在hcatalog中有一个表，其中有3个字符串列。当我尝试连接字符串时，出现以下错误:

A = LOAD 'default.temp_table_tower' USING org.apache.hcatalog.pig.HCatLoader() ;
B = LOAD 'default.cdr_data' USING org.apache.hcatalog.pig.HCatLoader();
c = FOREACH A GENERATE CONCAT(mcc,'-',mnc) as newCid;

问题的根本原因可能是什么？

最佳答案

可能会有助于 pig 的串联

data1包含:

(Maths,abc)
(Maths,def)
(Maths,ef)
(Maths,abc)
(Science,ac)
(Science,bc)
(Chemistry,xc)
(Telugu,xyz)

考虑模式为sub:Maths，Maths，Science .... etc，并命名为:abc，def，ef..etc

X = FOREACH data1 GENERATE CONCAT(sub,CONCAT('@',name));

X的O / P为:

(Maths@abc)
(Maths@def)
(Maths@ef)
(Maths@abc)
(Science@ac)
(Science@bc)
(Chemistry@xc)
(Telugu@xyz)