flink 键控状态（keyed state）

github开源项目flink-note的笔记。本博客的实现代码都写在项目的flink-state/src/main/java/state/keyed/KeyedStateDemo.java文件中。
项目github地址： github

1. flink键控状态

flink键控状态是作用与flink KeyedStream上的，也就是说需要将DataStream先进行keyby之后才能使用。键控状态会为每个key维护一份状态。flink支持五种键控状态，分别是：

• ValueState: 维护一个值的状态，比方说我们要统计每个用户的购买次数，那么就先将流按照用户id进行keyby，然后维护一个类型为Integer的ValueState。 这个值可以被update(T)更新，使用T value()进行获取。
• ListState ：维护一个list的状态，可以使用 add(T) 、 addAll(List)、update(List)来更新列表状态中的值，使用Iterable get()来获取list中的值。
• ReducingState 与ListState类似，只是将所有值都reduce出一个结果。
• AggregatingState<IN, OUT> 与上面类似
• MapState<UK, UV> 与上面类似

2. 键控状态的使用

在KeyedStateDemo.java中，我们实现了如下的功能：
我们从socket中读取用户的行为日志ÿ