2011-12-26 73 views
0
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的豬根文件夾中。
Apache 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. 

但如果我上運行咕嚕同一個程序,然後它給了我正確的輸出。 我已經嘗試了所有可能的參數java -cp的倒數第二個參數。

而且我還需要一個示例,其中使用CSVLoader類。

回答

3

如果你想運行在本地的豬,應該運行pig.jarpiggybank.jar 的piggybank.jar將被包括在腳本中的腳本由REGISTER命令

+0

或者只是使用在'bin'的'pig'可執行。 – 2011-12-27 03:12:24