我有一个奇怪的问题,当我使用sparkphoenix从hbase获取数据时
val rdd = sc.phoenixTableAsRDD(tableName, allColumns, zkUrl = Some(hostPort).map(tupleToObject)
我得到了一个rdd与所有的记录,但很少有没有一些非主键字段的价值(拉姆多姆似乎)。如果我用一个简单的phoenix客户机查询这些记录,我发现这些字段实际上是有值的。
Example:
rdd.foreach(x => {
println("Field A -> " + x._1) //not a primary key value
println("Field B -> " + x._2) //not a primary key value
})
Output:
Field A 2
Field B 3
Field A null
Field B 4
Field A null
Field B null
我错过了什么?ApachePhoenix是否可能不保证数据一致性
暂无答案!
目前还没有任何答案,快来回答吧!