Apache Pig, выпуск программы - PullRequest
Новая
       0

Apache Pig, выпуск программы

0 голосов
/ 26 декабря 2011 
REGISTER /home/hadoop/pigg/trunk/contrib/piggybank/java/piggybank.jar;

-- Use the PigStorage function to load the excite log file into the raw bag as an array of records.
-- Input: (user,time,query) 
A = LOAD 'hadoop-test-data.csv' USING PigStorage(',') AS (user: chararray, site: chararray, view: int, click: int);

B = FOREACH A GENERATE org.apache.pig.piggybank.evaluation.string.UPPER(user);
-- Use the PigStorage function to store the results. 
STORE B INTO 'test-pig-result' USING PigStorage();

Это мой код, я просто конвертирую свое имя пользователя в верхнем регистре. Я сохранил этот код в test.pig в корневой папке pig.

Я выполняю этот код с, 

java -cp $PIGGDIR/trunk/contrib/piggybank/java/piggybank.jar:$HADOOP_HOME/conf org.apache.pig.piggybank test.pig

Но он продолжает выдавать следующую ошибку, 

Exception in thread "main" java.lang.NoClassDefFoundError: org/apache/pig/piggybank/Main
    Caused by: java.lang.ClassNotFoundException: org.apache.pig.piggybank.Main
            at java.net.URLClassLoader$1.run(URLClassLoader.java:202)
            at java.security.AccessController.doPrivileged(Native Method)
            at java.net.URLClassLoader.findClass(URLClassLoader.java:190)
            at java.lang.ClassLoader.loadClass(ClassLoader.java:306)
            at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301)
            at java.lang.ClassLoader.loadClass(ClassLoader.java:247)
    Could not find the main class: org.apache.pig.piggybank.Main.  Program will exit.

Но если я запускаю ту же программу на grunt, то это дает мне правильный вывод.Я перепробовал каждый возможный параметр второго последнего параметра java -cp .

И мне также нужен пример, в котором используется класс CSVLoader .

1 Ответ

3 голосов
/ 26 декабря 2011

Если вы хотите запустить pig локально, вы должны запустить pig.jar, а не piggybank.jar piggybank.jar будет включен в скрипт командой REGISTER в скрипте

...