Spark 1.3 读取和写入 HBase



我想使用 spark 1.3 和 cloudera CDH-5.4.7 从 hbase 读写。我正在使用火花-hbase-连接器。我启动我的火花壳:

spark-shell --jars hbase-client-1.0.3.jar scalatest_2.10-2.2.4.jar hbase-common-1.0.3.jar spark-hbase-connector_2.10-1.0.3.jar hbase-server-1.0.3.jar

当我运行此导入时:

import it.nerdammer.spark.hbase._

我收到一个错误。使用 spark 1.3 从 hbase 读写的最佳方法是什么?谢谢

你能试试下面吗?

run : spark-shell --jars/opt/cloudera/parcels/CDH/lib/hbase/hbase-spark.jar

有关代码,请参阅以下链接

https://github.com/apache/hbase/blob/master/hbase-spark/src/main/scala/org/apache/hadoop/hbase/spark/example/hbasecontext/HBaseBulkGetExample.scala

最新更新