Spark HBase

import org.apache.hadoop.hbase.HBaseConfiguration
import org.apache.hadoop.hbase.io.ImmutableBytesWritable
import org.apache.hadoop.hbase.client.Result
import org.apache.hadoop.hbase.mapreduce.TableInputFormat


val conf = HBaseConfiguration.create()
conf.set("zookeeper.znode.parent", "/hbase")
conf.set("hbase.zookeeper.property.clientPort", "2181")
conf.set("hbase.zookeeper.quorum", "zk0,zk1,zk2,zk3,zk4")
conf.set(TableInputFormat.INPUT_TABLE, "test")

val set = sc.newAPIHadoopRDD(conf, 
                    classOf[TableInputFormat],
                    classOf[ImmutableBytesWritable],
                    classOf[Result])

val count = set.count()
println("Count:" + count)