在 Apache Flink 的受管理服務中使用 DataStream API - Managed Service for Apache Flink

Amazon Managed Service for Apache Flink 之前稱為 Amazon Kinesis Data Analytics for Apache Flink。

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

在 Apache Flink 的受管理服務中使用 DataStream API

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 文件中的「產生浮水印」。