06_Flink Streaming State

state,状态管理能够用来物化流计算的数据,作聚合和容错。如今能够物化到jobmanager内存中和文件系统中,rocketDB如今正在开发中。有四种类型的state,经过StreamingRuntimeContext.get对应的state。java package com.alibaba.flink.train.streaming; import org.apache.flink.api.
相关文章
相关标签/搜索