我想使用spark 1.3和cloudera cdh-5.4.7从hbase读写。我用的是spark hbase连接器。我启动我的Spark壳:
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读写的最佳方式是什么?谢谢您
1条答案
按热度按时间vxbzzdmp1#
你能试试下面的吗?
运行:sparkshell--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