我正在研究有关新的hadoop / pig设置的一些示例。
这个相当简单的示例代码让我感到困惑。
A1 = load 'passwd' using PigStorage(':') as (f1:chararray,f2:chararray,f3:chararray,f4:chararray,f5:chararray,f6:chararray,f7:chararray);
G = group A1 by f7;
foreach G generate group, a.$2;
G的最后一个foreach失败,并显示以下错误消息-
[main] ERROR org.apache.pig.tools.grunt.Grunt - ERROR 1000: Error during parsing.
Encountered " <IDENTIFIER> "foreach "" at line 1, column 1.
有人可以礼貌地指出我在这里我想念的是什么吗?还是我只是在这里生锈。
您可以这样更改最后一行吗?
H = foreach G generate group, A1.$2;
DUMP H;
在这里A1。$ 2表示您正在尝试访问f3列,其他选项是
H = foreach G generate group, A1.f3;
本文收集自互联网,转载请注明来源。
如有侵权,请联系[email protected] 删除。
我来说两句