中国建设银行西平支行网站中国广告网
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中读取用户的行为日志ÿ