使用spark中的hadoop配置连接到Hbase

import org.apache.spark.{SparkConf, SparkContext}
import org.apache.hadoop.hbase.HBaseConfiguration
import org.apache.hadoop.hbase.mapreduce.TableInputFormat
import org.apache.hadoop.hbase.util.Bytes

val sparkConf = new SparkConf().setAppName("SparkHBaseExample").setMaster("local[*]")
val sc = new SparkContext(sparkConf)

val conf = HBaseConfiguration.create()
conf.set("hbase.zookeeper.quorum", "localhost")
conf.set("hbase.zookeeper.property.clientPort", "2181")
conf.set(TableInputFormat.INPUT_TABLE, "your_table_name")

val hbaseRDD = sc.newAPIHadoopRDD(conf, classOf[TableInputFormat], classOf[org.apache.hadoop.hbase.io.ImmutableBytesWritable], classOf[org.apache.hadoop.hbase.client.Result])

val resultRDD = hbaseRDD.map(tuple => tuple._2)
val dataRDD = resultRDD.map(result => {
  val rowKey = Bytes.toString(result.getRow)
  val value = Bytes.toString(result.getValue(Bytes.toBytes("cf"), Bytes.toBytes("column")))
  (rowKey, value)
})

dataRDD.foreach(println)
sc.stop()