上传者: 41608066
|
上传时间: 2021-01-28 04:28:03
|
文件大小: 129KB
|
文件类型: 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 variants).