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中读取用户的行为日志ÿ
本文转载自: https://blog.csdn.net/cobracanary/article/details/129284771
版权归原作者 canaryW 所有， 如有侵权，请联系我们删除。
版权归原作者 canaryW 所有， 如有侵权，请联系我们删除。