【发布时间】：2020-09-25 06:59:43
【问题描述】：
学习如何使用 Flink Stateful Functions。我想知道它如何与 Hbase 和 Redis 交互。我在有状态函数中看不到 hbase 和 redis 的任何连接器。通过异步 api 调用通过服务访问这些是否有意义。
【问题讨论】：
标签： apache-flink flink-statefun
【发布时间】：2020-09-25 06:59:43
【问题描述】：
如果您对点查找感兴趣（键 X 的值是什么），那么您可以在函数调用期间联系任何外部服务。
-
如果您使用remote functions，那么您可以简单地使用 Redis 或 HBase 客户端在调用您的函数期间发出请求。如果您是 Python 用户，请查看示例 here。
-
如果您使用的是embedded functions，那么您将不得不为 Redis / HBase 使用异步客户端。 （许多功能在单个物理线程上多路复用，因此不建议阻塞） 请参阅 this 和 example here
我还应该提到，如果可以的话，请使用 StateFun 中的内置原语。 使用它们将为您提供开箱即用、出色的可扩展性、低延迟的状态访问以及一次性消息传递和状态保证。
祝你好运！
【讨论】：