link 中最大的一个亮点其实就是他的 SQL 了，我们之前所接触的 Hive SQL、Spark SQL 都是基于离线数据的 SQL 计算，而 Flink 的 SQL 是可以支持实时数据计算的，这样就可以极大简化企业中实时数据分析的工作量。 一、离线计算与实时计算 1，离线计算......
默认情况下 State 数据会一直存在，如果存储了过多状态数据，可能会导致内存溢出（针对 HashMapStateBackend）。因此从 Flink 1.6 版本开始引入了 State TTL 特性。类似于 Redis 中的 TTL 机制，超时自动删除。下面我通过样例进行演示。 1，基本介绍 （1）TTL 特性可以支持对 KeyedState 中过期状态数据的自动清理......
七、OperatorState 样例 1：使用 BroadcastState 实现双流连接 1，需求说明 （1）针对 BroadcastState 的使用，一个典型的应用案例就是两个流连接的场景。 假设其中一个数据流是“事件数据流”，它属于普通的数据流，里面是一些用户行为数据。 另外一个数据流是“配置数据流”，它不是普通的数据流......
六、OperatorState 样例 1：ListState 实现有状态的批量输出功能 1，需求说明 我们想要实现一个批量输出的功能，此时可以考虑在 Sink 组件内部定义一个缓存，但是还要保证数据一定会输出到外部系统。 2，实现逻辑 这个时候就需要借助于状态实现了，通过 CheckpointedFunction 接口......
四、KeyedState 样例 4：使用带有状态的算子 1，使用 Keyed State 的 3 种形式 （1）通过重写 RichXXXFunction，在里面创建和操作状态。 例如针对 map 算子可以使用 RichMapFunction，针对 flatmap 算子可以使用 RichFlatMapFunction 等。 在这里使用对应的 RichFunction 主要是因为它里面提供了......
四月头条：昔日20强语言Kotlin、Ruby与Swift处境艰难 在 TIOBE 编程语言排行榜中，Kotlin、Ruby 和 Swift 一直稳居前二十名，直到最近才开始动摇。如今，它们似乎失去了吸引力，有可能逐渐被淘汰。Kotlin 与 Swift 的衰落原因如出一辙：二者分别专用于移动平台 Android 和 iOS......
三、KeyedState 样例 3：使用 ListState 实现订单数据补全（双流 Join） 1，需求说明 大致需求是这样的，某外卖平台需要开发一个实时订单消息推送功能，当用户下单，并且成功支付后向商家推送一条消息。 2，实现逻辑 （1）由于下单数据是一个数据流，支付数据是另外一个数据流。 订单数据流......
、KeyedState 样例 1：MapState 实现直播间数据统计 1，需求说明 大致需求是这样的，需要统计平台中每个主播在直播间内收到的礼物信息、点赞、关注等指标，以直播间为单位进行统计。 2，实现逻辑 （1）由于用户每次开播都会生成一个新的直播间 vid.......
一、KeyedState 样例 1：使用 ValueState 实现温度告警 1，需求说明 大致需求是这样的，某机房内的多个设备会实时上报温度信息，在 Flink 任务内部需要对设备最近两次的温度进行对比，如果温差超过了 20 度，则需要发送告警信息，说明设备出问题了......
一、基本介绍 1，什么是 State？ （1）在流式计算中，State（状态）用于保存任务的中间数据或上下文信息。状态可以帮助任务跟踪事件间的依赖关系，从而实现复杂的业务逻辑，例如聚合、窗口计算或故障恢复。 （2）下图里面显示了 Flink 在对金融数据实现实时累加求和时的业务场景......