猪错误：解析查询失败

我正在尝试编写一个过滤器UDF，它将输入作为元组，并返回元组，但是当我在Gruntt shell中定义函数时，我得到错误消息解析失败，我在哪里做错了这里猪错误：解析查询失败

REGISTER /home/filterUDF.jar; 

DEFINE filDist 'FilterDistrictUdf/FilterDistrict' 


package FilterDistrictUdf; 

import java.io.IOException; 

import org.apache.pig.FilterFunc; 

import org.apache.pig.data.Tuple; 


public class FilterDistrict extends FilterFunc{ 

@Override 
public Boolean exec(Tuple input) throws IOException { 
    String line = input.toString(); 
    String[] columns = line.split(","); 
    Double bplObjective = Double.parseDouble(columns[2]); 
    Double bplPerformance = Double.parseDouble(columns[10]); 



    //Double bplObjective = (Double)input.get(2); 
    //Double bplPerformance = (Double)input.get(10); 
    //BigInteger mul = new BigInteger("80"); 
    //BigInteger div = new BigInteger("100"); 

    if(bplPerformance >= ((bplObjective* 80)/100)) 
     return true; 
    else 
     return false; 


}

}

错误：

ERROR 1200: <line 40, column 15> Syntax error, unexpected symbol at or 
    near ''FilterDistrictUdf/FilterDistrict'' 

    Failed to parse: <line 40, column 15> Syntax error, unexpected symbol at 
    or near ''FilterDistrictUdf/FilterDistrict'' 
    at 

    org.apache.pig.parser.QueryParserDriver.parse(QueryParserDriver.java:244) 
    at 
    org.apache.pig.parser.QueryParserDriver.parse(QueryParserDriver.java:182) 
    at org.apache.pig.PigServer$Graph.validateQuery(PigServer.java:1707) 
    at org.apache.pig.PigServer$Graph.registerQuery(PigServer.java:1680) 
    at org.apache.pig.PigServer.registerQuery(PigServer.java:623) 
    at 
    org.apache.pig.tools.grunt.GruntParser.processPig(GruntParser.java:1063) 
    at

org.apache.pig.tools.pigscript.parser.PigScriptParser.parse（PigScriptParser.java:501） at org.apache.pig.tools.grunt.GruntParser.parseStopOnError（GruntParser.java:230） at org.apache.pig.tools.grunt.GruntParser.parseStopOnError（GruntParser.java:205） at org.apache。（org.apache.pig.Main.run）（Main.java:558） at org.apache.pig.Main.main（Main.java： 170）在sun.reflect.NativeMethodAccessorImpl.invoke0（本机方法）在

sun.reflect.NativeMethodAccessorImpl.invoke（NativeMethodAccessorImpl.java:62）在

sun.reflect.DelegatingMethodAccessorImpl.invoke（DelegatingMeth odAccessorImpl.ja VA：43）在java.lang.reflect.Method.invoke（Method.java:497）在org.apache.hadoop.util.RunJar.main（RunJar.java:212）

来源

2017-10-11 G.v. Sridhar

当我试图取而代之的定义temporay功能filDist来

DEFINE filDist 'FilterDistrictUdf/FilterDistrict'

错误来了，直接在过滤器操作使用功能

chk1 = FILTER elements by FilterDistrictUdf.FilterDistrict(*)

试着和它的工作正常

来源

2017-10-12 08:08:37

猪错误：解析查询失败

回答

相关问题