使用DataStreamAPI - Amazon Kinesis Data Analytics
Amazon Web Services 文档中描述的 Amazon Web Services 服务或功能可能因区域而异。要查看适用于中国区域的差异,请参阅中国的 Amazon Web Services 服务入门

本文属于机器翻译版本。若本译文内容与英语原文存在差异,则一律以英文原文为准。

使用DataStreamAPI

Kinesis Data Analytics 使用以下时间戳跟踪事件:

  • 处理时间:指的是执行相应操作的计算机的系统时间。

  • 事件时间:指的是在生成设备上发生每个事件的时间。

  • 摄取时间:指的是事件进入 Kinesis Data Analytics 服务的时间。

您可以使用 setStreamTimeCharacteristic 设置流环境使用的时间:

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

有关时间戳的更多信息,请参阅事件时间中的Apache Flink 文档.