Tracking events in Managed Service for Apache Flink using the DataStream API - Managed Service for Apache Flink
Services or capabilities described in Amazon Web Services documentation might vary by Region. To see the differences applicable to the China Regions, see Getting Started with Amazon Web Services in China (PDF).

Amazon Managed Service for Apache Flink was previously known as Amazon Kinesis Data Analytics for Apache Flink.

Tracking events in Managed Service for Apache Flink using the DataStream API

Managed Service for Apache Flink tracks events using the following timestamps:

  • Processing Time: Refers to the system time of the machine that is executing the respective operation.

  • Event Time: Refers to the time that each individual event occurred on its producing device.

  • Ingestion Time: Refers to the time that events enter the Managed Service for Apache Flink service.

You set the time used by the streaming environment using setStreamTimeCharacteristic. 

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

For more information about timestamps, see Generating Watermarks in the Apache Flink documentation.