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