Track events in Managed Service for Apache Flink using the DataStream API - Managed Service for Apache Flink

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

Track 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.