豬錯誤：解析查詢失敗

我正在嘗試編寫一個過濾器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

豬錯誤：解析查詢失敗

回答

相關問題