Tracking Events in Kinesis Data Analytics for Apache Flink Using the DataStream API - Amazon Kinesis Data Analytics
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).

Tracking Events in Kinesis Data Analytics for Apache Flink Using the DataStream API

Kinesis Data Analytics 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 Kinesis Data Analytics 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 Event Time in the Apache Flink Documentation.