竹爸的大数据手账
搜索文章
首页
首页
# 每日知识点
(3)
# Flink
(4)
# Doris
(2)
# Paimon
(1)
# Halo
(0)
Flink中的双流关联
在FLink中,经常会遇到双流关联的的场景,比如订单流和支付流的关联,用户行为流和用户信息流等。那么,在Flink中都提供了哪些双流的关联呢?下面主要从DataStream和Flink SQL角度入手说明。 DataStream Window Join(窗口Join) 两条流在同一个时间窗口内进行J
作者:Administrator
发布时间:2026-03-09
分类:
每日知识点
标签:
#
Flink
,
#
每日知识点
Flink中是怎么处理乱序数据的
Flink中是怎么处理乱序数据的 在 Flink 里,“乱序”本质是 事件时间(event time) 先后顺序和 到达时间(processing time) 不一致。Flink 处理乱序数据的核心机制主要围绕:事件时间语义 + Watermark + 窗口触发/延迟 + 迟到数据处理 + 状态与一
作者:Administrator
发布时间:2026-02-27
分类:
每日知识点
标签:
#
Flink
,
#
每日知识点
Flink中的广播变量(Broadcast State)
Flink中的广播变量(Broadcast State) Flink 的广播状态(Broadcast State) 是用于在 流处理(DataStream API)中,将一条控制流或规则流广播到所有并行实例,并在每个算子实例中维护一致的共享状态的一种机制。 主要用于: 动态规则下发 实时风控规则更新
作者:Administrator
发布时间:2026-02-26
分类:
每日知识点
标签:
#
Flink
,
#
每日知识点
共 3 篇文章
1
页