Amazon Managed Service for Apache Flink(Amazon MSF)之前称为 Amazon Kinesis Data Analytics 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 文档中的生成水印