phoenix不返回任何行

xytpbqjk  于 2021-06-08  发布在  Hbase
关注(0)|答案(1)|浏览(304)

我在hbase有一张table。我用Phoenix创造了它

CREATE TABLE IF NOT EXISTS my_table ...

然后我用spark填充它(我使用hortonworks shc核心连接器):

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

在hbase shell模式下,我可以看到我的表不为空:

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

但是为什么我在phoenix控制台中运行查询,却没有得到行:

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

谢谢你的帮助。

pkwftd7m

pkwftd7m1#

不要使用“org.apache.spark.sql.execution.datasources.hbase”,而是尝试使用Phoenix官方网站建议的“org.apache.phoenix.spark”,以便在phoenix表中保存Dataframe。

相关问题