apache-flink - 有状态的函数 Flink 与 Hbase 和 Redis 的交互

Question

学习如何使用 Flink Stateful Functions。我想知道它如何与 Hbase 和 Redis 交互。我在有状态函数中看不到 hbase 和 redis 的任何连接器。通过异步 api 调用通过服务访问这些是否有意义。

Answer 1

如果您对点查找感兴趣（键 X 的值是什么），那么您可以在函数调用期间联系任何外部服务。

• 如果您使用远程函数，那么您可以简单地使用 Redis 或 HBase 客户端在函数调用期间发出请求。如果您是 Python 用户，请在此处查看示例。

• 如果您使用的是嵌入式函数，则必须为 Redis / HBase 使用异步客户端。（许多功能在单个物理线程上多路复用，因此不建议阻塞）请参阅this，以及此处的示例

我还应该提到，如果可以的话，请使用 StateFun 中的内置原语。使用它们将为您提供开箱即用、出色的可扩展性、低延迟的状态访问以及恰好一次的消息传递和状态保证。

祝你好运！