pom引入hbase2.0.2依赖问题

hbase集群升级到hbase2.0.2, 应用程序依赖改为2.0.2, 无法读取数据, 将依赖改为1.1.2读取正常。
测试代码如下
    def testScan(tableName: String) = {
val startTime = System.currentTimeMillis()
val hbaseConf = HBaseConfiguration.create()
val hbaseConn = ConnectionFactory.createConnection(hbaseConf)
val table = hbaseConn.getTable(TableName.valueOf(tableName))

val scan = new Scan()
scan.setStartRow(Bytes.toBytes("190401"))
.setStopRow(Bytes.toBytes("190401~"))

val res = table.getScanner(scan)
val rs = res.iterator()
val rks = new ArrayBuffer[String]()
while(rs.hasNext) {
val r = rs.next()
val rk = Bytes.toString(r.getRow)
rks.append(rk)
}

val endTime = System.currentTimeMillis()

println("get " + rks.size + " 条数据, 花费" + (endTime - startTime) + " ms")
}
已邀请:

要回复问题请先登录注册


中国HBase技术社区微信公众号:
hbasegroup

欢迎加入HBase生态+Spark社区钉钉大群