学习如何使用Flink Stateful函数。我想知道它是如何与Hbase和Redis相互作用的。在有状态函数中，我没有看到任何用于hbase和redis的连接器。通过异步api调用通过服务访问这些是否有意义。
如果您对点查找感兴趣(键X的值是多少(，那么您可以在调用函数期间联系任何外部服务。
-
如果您使用的是远程函数，那么您可以简单地使用Redis或HBase客户端在调用函数时发出请求。如果您是Python用户，请查看此处的示例。
-
如果您使用的是嵌入式函数，那么您必须使用Redis/HBase的异步客户端。(许多函数在单个物理线程上多路复用，因此不建议阻塞(看到这个，这里的例子
我还应该提到，如果可以的话，在StateFun中使用内置的原语。使用它们将为您提供开箱即用的、良好的可扩展性、低延迟的状态访问，以及一次消息传递&国家担保。
祝你好运！