Flink实现值累积,每次输出结果

数值随机产生，用flink进行数值累积进行打印,每次输出结果，输出结果日志会很频繁

Flink实现值累积，1s打印一次

数值随机产生，用flink进行数值累积进行打印，间隔1s进行打印

Flink温度连续上涨1s

Flink中输入流中的每一条数据都会触发KeyedProcessFunction类的processElement方法调用 通过这个方法的Context参数可以设置定时器，在开启定时器后会程序会定时调用onTimer方法 由于KeyedProcessFunction实现了RichFunction接口， 因此是可以通过RuntimeContext上下文对象管理状态state的开启和释放 需要注意的是，只有在KeyedStream里才能够访问state和定时器， 通俗点来说就是这个函数要用在keyBy这个函数的后面

什么是Flink富函数(算子生命周期)？

富函数（Rich Functions） 是 DataStream API 提供的一个函数类的接口，所有 Flink 函数类都有其 Rich 版本。它与常规函数的不同在于， 可以获取运行环境的上下文，并拥有一些生命周期方法，所以可以实现更复杂的功能。

flink-connector-mongodb-cdc实战案例

MongoDB CDC 连接器允许从 MongoDB 读取快照数据和增量数据。 本文档描述了如何设置 MongoDB CDC 连接器以针对 MongoDB 运行 SQL 查询。

Flink数据重分布

将数据发送到下游算子的不同的并行子任务