我有一个 Spark 结构化流应用程序,它从 Kafka 读取数据并写入 HBase 和 Kafka,在此过程中,从 kafka 读取数据后,我想查找 HBase 表,有人可以建议可用的选项,如果你有示例代码.
我曾尝试使用 SHC(Spark HBase 连接器),但使用 SHC 读取 HBASE 表意味着在另一个数据帧上进行数据帧迭代,哪个动态过滤器,哪个 spark 似乎不喜欢。
我有一个 Spark 结构化流应用程序,它从 Kafka 读取数据并写入 HBase 和 Kafka,在此过程中,从 kafka 读取数据后,我想查找 HBase 表,有人可以建议可用的选项,如果你有示例代码.
我曾尝试使用 SHC(Spark HBase 连接器),但使用 SHC 读取 HBASE 表意味着在另一个数据帧上进行数据帧迭代,哪个动态过滤器,哪个 spark 似乎不喜欢。