java - MapReduce 上 Cassandra 执行错误

Question

我正在运行一个示例 mapreduce 程序(wordcount)来查询 cassandra 数据。
我已将 cassandra jar 文件包含在 http://wiki.apache.org/cassandra/HadoopSupport 中指定的 hadoop 类路径“export HADOOP_CLASSPATH=/usr/share/cassandra/lib/*:$HADOOP_CLASSPATH”中。 :在每个任务跟踪器上。但是当我构建 jar 文件时，我得到如下所示的错误。
.
.
.
.
.
.

.

如何构建 jar 文件使其可以在 cassandra 数据上运行？

如何将 cassandra 数据的路径提供给 mapreduce 程序？一般来说，对于 HDFS 数据处理，我们会给出类似“hadoop jar filename.jar ConfigClassName inputfile outputfile”的命令。如果是 cassandra，如何给出相同的命令？

关于如何进行的任何想法？

提前致谢!!!

Answer 1

请尝试像这样构建-

javac -classpath $HADOOP_CLASSPATH:/usr/local/hadoop/hadoop-1.2.1/hadoop-core-1.2.1.jar WordCount.java

我想，在构建时，您还需要将 HADOOP_CLASSPATH 放在 javac 类路径中。