AI
推荐
模板社区
专题
登录
免费注册
首页
流程图
详情
Flink 时间语义
2023-09-02 10:07:58
5
举报
分享方式
免费使用
Flink 时间语义
大数据
Flink
实时计算
模版推荐
作者其他创作
大纲/内容
KeyByedStream()调用font color=\"#000000\
处理时间 ProcessTime知道此事的时间 正在执行相应操作的系统时间实时程序基于处理时间时 所有基于时间的操作都将使用运行机器的系统时间处理时间是最简单的概念 不需要流和机器之间的协调 提供了最佳的性能和最低延迟！注意：分布式和异步环境下 机器的系统时间可能有误差 处理时间不准确
摄入时间 IngestionTime：摄入时间指的是数据进入 Flink 的时间
代码实现
1.12之后EventTime-->作为默认的时间语义
1.12之前ProcessTime-->作为默认的时间语义
事件时间 EventTime事件真实发生的时间 事件时间一般在进入Flink之前嵌入记录中 可以从每个记录中提取事件时间戳事件时间进度机制：事件时间中 时间的进展取决于数据 不是任何挂钟 必须指定如何生成事件事件时间水印对于乱序 延时 数据重放 都能给正确的结果
environment.setStreamCharacteristic(TimeCharacteristic.xx)
时间语义为窗口计算而服务
收藏
立即使用
真实模拟面试流程
收藏
立即使用
大数据面试题库
收藏
立即使用
编码格式
收藏
立即使用
bigo的flink架构
失去温柔的艺术家
职业：大数据测试开发工程师
去主页
Collect
Get Started
flink
Collect
Get Started
flink pipe
Collect
Get Started
Flink
Collect
Get Started
Flink
评论
0
条评论
下一页
Document
