本文主要是介绍Flink Keyed State 实例，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！
1 sourceStream必须要先keyBy然后才能使用Keyed State
2 需要继承RichxxxxFunction才行，在open之前声明，在open中初始化，在算子方法中使用和处理。不能继承xxxxxFunction，因为没有open方法，无法初始化，会报错。
3 open方法中只能初始化Keyed State，无法使用Keyed State（比如：获取值等操作），不然报错。因为open方法不属于Keyed上下文，算子方法才属于Keyed上下文
并行度是1：2个不同key流被1个子任务处理
package StateTtlConfig;/*** @Author you guess* @Date 2020/6/22 22:42* @Version 1.0* @Desc*/import org.apache.flink.api.common.functions.RichFlatMapFunction;
import org.apache.flink.api.common.state.ValueState;
import org.apache.flink.api.common.state.ValueStateDescriptor;
import org.apache.flink.api.common.typeinfo.TypeHint;
import org.apache.flink.api.common.typeinfo.TypeInformation;
import org.apache.flink.api.java.tuple.Tuple2;
import org.apache.flink.configuration.Configuration;
import org.apache.fl这篇关于Flink Keyed State 实例的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！
