我在两张桌子上做了一个内连接。然而,我无法在其中一个云上进行求和:
执行的查询:
sample1 = load '/user/tweets/samples.csv' using PigStorage AS (line:chararray);
words = FOREACH sample1 GENERATE FLATTEN(TOKENIZE(REPLACE(LOWER(TRIM(line)),'[\\p{Punct},\\p{Cntrl}]',''))) AS word
newinnerjoin = join words by word, wordlexion by lexword;下面是表的输出: newinnerjoin
(important,important,2)
(irritated,irritated,-3)
(promoting,promoting,1)
(promoting,promoting,1)
(appreciate,appreciate,2)
(confidence,confidence,2)我想在内部联接结果的第3列上执行聚合。所以,我想将和计算为2+ -3 +1+1+2+2=5,我可以不把内部连接结果存储在csv文件中吗?请给我建议。
谢谢
发布于 2014-11-28 15:47:39
你能加3行代码让我知道结果吗?
A = GROUP newinnerjoin ALL;
B = FOREACH A GENERATE SUM(newinnerjoin.$2);
DUMP B;https://stackoverflow.com/questions/27183996
复制相似问题