竹爸的大数据手账
搜索文章
首页
首页
竹爸
日拱一卒,持续交卷
全部
默认分类 (2)
大数据 (2)
每日知识点 (3)
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
,
#
每日知识点
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
页
# 每日知识点
(3)
# Flink
(4)
# Doris
(2)
# Paimon
(1)
# Halo
(0)
友情链接
暂无友情链接