Java教程

时间概念 与 Watermark

本文主要是介绍时间概念 与 Watermark，对大家解决编程问题具有一定的参考价值，需要的程序猿们随着小编来一起学习吧！

时间概念 与 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 自定义生成

这篇关于时间概念 与 Watermark的文章就介绍到这儿，希望我们推荐的文章对大家有所帮助，也希望大家多多支持为之网！
您可能喜欢
栏目导航