use*_*976 5 apache-flink flink-streaming
在查看 Flink 官方文档时，我遇到了CheckpointedFunction. 想知道您为什么以及何时使用此功能。我目前正在从事一项有状态的 Flink 作业，该作业严重依赖于ProcessFunction在 RocksDB 中保存状态。只是想知道是否CheckpointedFunction比ProcessFunction.
CheckpointedFunction适用于您需要使用应由 Flink 管理并包含在检查点中的状态的情况，但您不使用 KeyedStream，因此无法像在KeyedProcessFunction.
最常见的用例CheckpointedFunction是源和接收器。
| 归档时间： |
|
| 查看次数： |
1011 次 |
| 最近记录： |