我在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)
谢谢你的帮助。
1条答案
按热度按时间pkwftd7m1#
不要使用“org.apache.spark.sql.execution.datasources.hbase”,而是尝试使用Phoenix官方网站建议的“org.apache.phoenix.spark”,以便在phoenix表中保存Dataframe。