为什么不赞成使用Flink ListCheckPointed作为运算符状态



正如本文档所说:通过直接实现ListCheckpointed接口,可以以更简单的方式检查函数对象本身的某些状态。

实现全面的CheckpointedFunction接口IMHO是乏味的。使用ListCheckpointed,我只需要维护成员变量,这更直观。否则,我将不得不保留ListState成员

ListCheckpointed已被弃用,因为它允许使用一些序列化快捷方式,而这些快捷方式对状态迁移不太好。

相关内容

  • 没有找到相关文章