我们可以在spark结构化流处理中查找hbase表吗

sdnqo3pr  于 2021-06-09  发布在  Hbase
关注(0)|答案(0)|浏览(213)

我有一个spark结构化流应用程序,它从kafka读取数据并写入hbase和kafka,在此过程中,在从kafka读取数据之后,我想查找hbase表,是否有人可以建议可用的选项,如果有示例代码,请提供示例代码。
我曾经尝试过使用shc(spark-hbase-connector),但是使用shc读取hbase表意味着在另一个Dataframe上进行Dataframe迭代,这是动态过滤器,spark似乎不喜欢。

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题