时间概念 与 Watermark

• 一.时间概念指定
• 二.EventTime 和 Watermark
• • 2.1 指定Timestamps 生成 Watermark
  • • 2.1.1 在 SourceFunction 中
    • 2.1.2 用 Flink自带的 Timestamp Assigner
    • • 2.1.2.1 用 Ascending Timestamp Assigner
      • 2.1.2.2 用 固定时延间隔的 Timestamp Assigner
    • 2.1.3 自定义Timestamp Assigner
    • • 2.1.3.1 用 Periodic Watermarks 自定义生成
      • 2.1.3.2 用 Punctuated Watermarks 自定义生成

一.时间概念指定

事件时间（EventTime）
接入时间（Ingestion Time）
处理时间（Processing Time）

val env =StreamExecutionEnvironment.getExecutionEnvironent()
env.setStreamTimeCharateristic(TimeCharacteristic.EventTime)

二.EventTime 和 Watermark

2.1 指定Timestamps 生成 Watermark

2.1.1 在 SourceFunction 中

2.1.2 用 Flink自带的 Timestamp Assigner

2.1.2.1 用 Ascending Timestamp Assigner

2.1.2.2 用 固定时延间隔的 Timestamp Assigner

2.1.3 自定义Timestamp Assigner

2.1.3.1 用 Periodic Watermarks 自定义生成

2.1.3.2 用 Punctuated Watermarks 自定义生成

标签：EventTime,Assigner,自定义,Watermark,Timestamp,概念,时间,2.1
来源： https://blog.csdn.net/m0_47231659/article/details/119395703