语法错误，'groupped' 处或附近的意外符号

Question

我有以下代码：

Input_File = load '/user/cloudera/teste' USING PigStorage (' ')
      as (ID:Int, 
          Descrip:Chararray,
          Date:Datetime);

groupped = group Input_File by (ID, Date);

ranked = foreach groupped {
        ranked = rank groupped by ID desc DENSE;
        generate flatten(ranked);
        }

STORE ranked into '/user/cloudera/teste1123';

我正在尝试在此数据集上创建排名列：

id  des date
1   A   01-01-2016
2   A   02-01-2016
2   C   03-01-2016
2   D   03-01-2016
3   A   01-01-2016

主要目标是得到这个：

rank    id  desc    date
1       1   A   01-01-2016
2       2   A   02-01-2016
3       2   C   03-01-2016
3       2   D   03-01-2016
4       3   A   01-01-2016

但是当我运行我的代码时，我收到以下错误：

ERROR 1200: <line 5, column 14>  Syntax error, unexpected symbol at or near 'groupped'

Failed to parse: <line 5, column 14>  Syntax error, unexpected symbol at or near 'groupped'
    at org.apache.pig.parser.QueryParserDriver.parse(QueryParserDriver.java:241)
    at org.apache.pig.parser.QueryParserDriver.parse(QueryParserDriver.java:179)
    at org.apache.pig.PigServer$Graph.validateQuery(PigServer.java:1660)
    at org.apache.pig.PigServer$Graph.registerQuery(PigServer.java:1633)
    at org.apache.pig.PigServer.registerQuery(PigServer.java:587)
    at org.apache.pig.tools.grunt.GruntParser.processPig(GruntParser.java:1090)
    at org.apache.pig.tools.pigscript.parser.PigScriptParser.parse(PigScriptParser.java:501)
    at org.apache.pig.tools.grunt.GruntParser.parseStopOnError(GruntParser.java:198)
    at org.apache.pig.tools.grunt.GruntParser.parseStopOnError(GruntParser.java:173)
    at org.apache.pig.tools.grunt.Grunt.run(Grunt.java:69)
    at org.apache.pig.Main.run(Main.java:547)
    at org.apache.pig.Main.main(Main.java:158)
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke(Method.java:606)
    at org.apache.hadoop.util.RunJar.run(RunJar.java:221)
    at org.apache.hadoop.util.RunJar.main(RunJar.java:136)

我做错了什么？

非常感谢！

Answer 1

不确定语法错误在哪里，但这是您正在寻找的解决方案。

注意：您必须将日期加载为字符数组

Input_File = load '/user/cloudera/teste' USING PigStorage(' ') as (ID:int, Descrip:chararray,Date:chararray);
ranked = rank Input_File by ID ASC,Date DENSE;
dump ranked;

输出

语法错误，'groupped' 处或附近的意外符号

Syntax error, unexpected symbol at or near 'groupped'

hadoop

ranking

apache-pig