0

自分のUDFを豚にロードしようとしています。eclipseのエクスポート機能を使ってjarにしました。jar を HDFS に配置する前に動作することを確認できるように、ローカルで実行しようとしています。ローカルで実行すると、次のエラーが発生します。

ERROR 1070: Could not resolve myudfs.MONTH using imports: [, org.apache.pig.builtin., org.apache.pig.impl.builtin.]

脚本

REGISTER myudfs.jar; 
--DEFINE MONTH myudfs.MONTH;

A = load 'access_log_Jul95' using PigStorage(' ') as (ip:chararray, dash1:chararray, dash2:chararray, date:chararray, getRequset:chararray, status:int, port:int);
B = FOREACH A GENERATE myudfs.MONTH(date);
DUMP B;

関数

package myudfs;
import java.io.IOException;
import org.apache.pig.EvalFunc;
import org.apache.pig.data.Tuple;
import org.apache.pig.impl.util.WrappedIOException;

@SuppressWarnings("deprecation")
public class HOUR extends EvalFunc<String>
{
    public String exec(Tuple input) throws IOException {
        if (input == null || input.size() == 0)
            return null;
        try{
            String str = (String)input.get(0);
            return str.substring(1, 3);
        }catch(Exception e){
            throw WrappedIOException.wrap("Caught exception processing input row ", e);
        }
    }
}

作業ディレクトリ

1.pig  2.pig  bin  myudfs.jar  
pig.jar  pig-withouthadoop.jar  src/

実行中のコマンド

pig -x local 2.pig

ジャーの構造

 0  Thu May 02 12:16:26 MDT 2013 META-INF/
68  Thu May 02 12:16:26 MDT 2013 META-INF/MANIFEST.MF
 0  Thu May 02 12:05:50 MDT 2013 myudfs/
573 Thu May 02 12:15:10 MDT 2013 myudfs/HOUR.java

私はモニターをチャッキングし始めるのに本当に近いので、助けと方向性を探しています. 何が問題なのか教えてください。

4

1 に答える 1

4

UDF クラス名が呼び出されますHOUR

だからあなたの豚のラテン語はこれであってはいけませんか？

B = FOREACH A GENERATE myudfs.HOUR(date);
于 2013-05-02T21:15:24.660 に答える