1

所以,我正在尝试使用远程函数来实现 flink 的 mapState。在 mapState 中,我将存储大约 1000 个用一个键映射的值。有人可以指出我为远程功能实现它的方向吗?我找到了带有嵌入式功能的文章https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/dev/datastream/fault-tolerance/state/

另外,当我从远程功能访问它时,我的整个状态会在每个请求中传输吗?如果是,有什么办法可以避免每次我请求时都进行大量数据传输?

4

0 回答 0