如何使用状态作为缓存

通常，如果要从Flink中的外部数据库缓存/镜像状态，最高效的方法是将数据库突变流式传输到Flink中 - 换句话说，将Flink转换为数据库更改数据捕获的复制端点（CDC） ）stream，如果数据库支持那个。

我没有使用hbase的经验，但https://github.com/mravi/hbase-connect-kafka是一个可能有用的例子（通过将kafka放在hbase和flink之间）。

如果您希望从Flink查询hbase，并且希望避免一次为一个用户进行点查询，那么您可以构建如下内容：

          -> queryManyUsers -> keyBy(uId) -> 

streamToEnrich CoProcessFunction

          -> keyBy(uID) ------------------->

在这里，您将拆分流，通过窗口或流程函数或async i / o发送一个副本以批量查询hbase，并将结果发送到保存缓存并进行丰富的CoProcessFunction。

当记录直接沿着底部路径到达此CoProcessFunction时，如果必要数据在缓存中，则使用它。否则，记录被缓冲，等待来自上部路径的高速缓存数据的到达。