spark接hbase讀取資料：

    val sc = new SparkContext(sparkConf)
    val conf = HBaseConfiguration.create()

    conf.set("hbase.zookeeper.property.clientPort", "port..")
    conf.set("hbase.zookeeper.quorum", "ip..")
    conf.set(TableInputFormat.INPUT_TABLE,"table1..")

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

    val count = hBaseRDD.count()
    println("HBase RDD Count:" + count)
    hBaseRDD.cache()

    //遍歷輸出
    hBaseRDD.collect().foreach{ case (_,result) =>
      val key = Bytes.toInt(result.getRow)
      val name = Bytes.toString(result.getValue("pd".getBytes,"name".getBytes))
      val age = Bytes.toInt(result.getValue("pd".getBytes,"age".getBytes))
      println("Row key:" + key + " name:" + name +" age:" + age)
    }
    
    sc.stop()
 

在網上看到有關繼承spark自帶的序列化工具，就想到可能沒有設定序列化的類，還是用的java的

於是到conf/目錄下檢視spark-defaults.conf檔案，果然沒有用到，修改如下：

更改後重新啟動spark可以取到hbase的資料。