QueryableStateFLINK 3779.pdf

Flink QueryableState设计文档（FLINK-3779） Flink offers state abstractions for user functions1 in order to guarantee fault-tolerant processing of streams. Users can work with both non-partitioned (Checkpointed interface) and partitioned state (getRuntimeContext().getState(ValueStateDescriptor) and other v