Phoenix不返回任何行

Question

我在HBASE有一张桌子。我和菲尼克斯一起创造的

CREATE TABLE IF NOT EXISTS my_table ...

然后我用spark填充它（我使用hortonworks shc-core连接器）：

df.write().options(options).format("org.apache.spark.sql.execution.datasources.hbase").save();

scan "my_table", {LIMIT=>1}
 55f8477005f6f8.71923246\x00\x00\x00\x00Zd{y    column=cf1:id2, timestamp=1516703969207, value=... 

SELECT * FROM 'my_table' LIMIT 10 ;
No rows selected (4.033 seconds)

多谢帮忙。

Answer 1

不要使用“org.apache.spark.sql.execution.datasources.hbase”，请尝试使用“org.apache.Phoenix.spark”，这是菲尼克斯官方网站在这里建议的，用于在菲尼克斯表中保存DataFrame。