Flink:Richasyncfunction中的状态访问



richasyncfunction的flink文档状态:

runtimecontext中与状态相关的API尚不支持,因为在访问工作线程中的状态时,键可能会更改。

这到底是什么意思?允许哪些呼叫,哪些是不可能的?如果打电话给不支持的方法会发生什么?

RuntimeContext的文档在这里。

RichAsyncFunction提供了自己的RuntimeContext子类,该子类在尝试访问任何状态时会抛出UnsupportedOperationException

相关内容

  • 没有找到相关文章

最新更新