Flink状态(一)

算子状态也称为非key状态。每一个算子状态绑定一个并发算子实例。
kafka connector是flink算子状态比较好的应用范例。每一个
kafka consumer并发实例都维护一个topic分区和分区对应的offset的map，并将此map作为算子状态。