使用 DataStream API 追蹤 Managed Service for Apache Flink 中的事件 - Managed Service for Apache Flink

本文為英文版的機器翻譯版本，如內容有任何歧義或不一致之處，概以英文版為準。

使用 DataStream API 追蹤 Managed Service for Apache Flink 中的事件

Managed Service for Apache Flink 使用下列時間戳記來追蹤事件：

  • 處理時間：指正在執行相應操作的機器的系統時間。

  • 事件時間：指每個個別事件在其生產設備上發生的時間。

  • 擷取時間：指事件進入 Managed Service for Apache Flink 服務的時間。

您可以使用 設定串流環境使用的時間setStreamTimeCharacteristic。

env.setStreamTimeCharacteristic(TimeCharacteristic.ProcessingTime);
env.setStreamTimeCharacteristic(TimeCharacteristic.IngestionTime);
env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime);

如需時間戳記的詳細資訊，請參閱 Apache Flink 文件中的產生浮水印。