竹爸的大数据手账
搜索文章
首页
首页
2026 年 03 月
Flink中的双流关联
在FLink中，经常会遇到双流关联的的场景，比如订单流和支付流的关联，用户行为流和用户信息流等。那么，在Flink中都提供了哪些双流的关联呢？下面主要从DataStream和Flink SQL角度入手说明。 DataStream Window Join（窗口Join） 两条流在同一个时间窗口内进行J
作者：Administrator
发布时间：2026-03-09
分类：
每日知识点
标签：
#
Flink
,
#
每日知识点
2026 年 02 月
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
,
#
每日知识点
Doris的Routine Load操作
CREATE ROUTINE LOAD [数据库名].[任务名] ON [目标表] COLUMNS (列1, 列2, ...) -- 指定映射字段（可选） PROPERTIES ( "format" = "json", "desired_concurrent_number" = "3",
作者：Administrator
发布时间：2026-02-24
分类：
大数据
标签：
#
Doris
从Paimon到Doris，使用Flinksql做数据同步
使用FlinkSQL使用将Paimon数据表同步到Doris，需要以下步骤： 1. 相关的环境 确保Flink集群已经安装以下的依赖： Paimon Flink connector Doris Flink connector 相关数据库驱动 2. 创建Paimon的Catalog CREATE CA
作者：Administrator
发布时间：2026-02-24
分类：
大数据
标签：
#
Paimon
,
#
Doris
,
#
Flink
共 5 篇文章
1
页