ERROR 1070: Kann nicht CqlStorage mit Importen lösen:

Question

Ich habe versucht, dieses Skript auf dem Schwein im lokalen Modus auszuführen:

test = LOAD 'cql://phoenix/simple_table/' USING CqlStorage; 

Aber ich erhalte diesen folgenden Fehler,

> 2016-05-10 18:28:48,249 [main] ERROR org.apache.pig.tools.grunt.Grunt 
> - ERROR 1070: Could not resolve CqlStorage using imports: [, java.lang., org.apache.pig.builtin., org.apache.pig.impl.builtin.] 
> Details at logfile: /home/hduser/pig_1462885029564.log 

I verwende Hadoop 2.2.0, Cassandra 1.2.4 und Schwein 0.12.0.

Und meine bash-Datei ist,

export JAVA_HOME=/usr/lib/jvm/java-7-oracle 
export PIG_HOME=/home/hduser/pig-0.12.0 
export PIG_CONF_DIR=/home/hduser/pig-0.12.0/conf 
export PIG_CLASSPATH=/home/hduser/apache-cassandra-1.2.4-src/lib/libthrift-0.7.0.jar 
export PIG_INITIAL_ADDRESS=localhost; 
export PIG_RPC_PORT=9160; 
export PIG_PARTITIONER=org.apache.cassandra.dht.Murmur3Partitioner; 

und diesen Befehl auf Schwein laufen,

register '/home/hduser/apache-cassandra-1.2.4-src/build/apache-cassandra-1.2.4-SNAPSHOT.jar' 
define CqlStorage org.apache.cassandra.hadoop.pig.CqlStorage(); 

Aber ich bin immer das gleiche Problem des error.What?

Answer 1

Es sieht nicht so aus, als hätten Sie die Cassandra-JAR-Datei in Ihrem Klassenpfad. Diese Klasse ist als Teil der Distribution enthalten.

Hier ist ein Tutorial: http://saugereau.github.io/blog/2015/03/cassandra-pig/