Überprüfen Sie die Zeitattribute der Tabelle API - Managed Service für Apache Flink

Amazon Managed Service für Apache Flink war zuvor als Amazon Kinesis Data Analytics für Apache Flink bekannt.

Die vorliegende Übersetzung wurde maschinell erstellt. Im Falle eines Konflikts oder eines Widerspruchs zwischen dieser übersetzten Fassung und der englischen Fassung (einschließlich infolge von Verzögerungen bei der Übersetzung) ist die englische Fassung maßgeblich.

Überprüfen Sie die Zeitattribute der Tabelle API

Jeder Datensatz in einem Datenstrom hat mehrere Zeitstempel, die definieren, wann Ereignisse im Zusammenhang mit dem Datensatz aufgetreten sind:

  • Ereigniszeit: Ein benutzerdefinierter Zeitstempel, der definiert, wann das Ereignis eingetreten ist, durch das der Datensatz erstellt wurde.

  • Erfassungszeit: Der Zeitpunkt, zu dem Ihre Anwendung den Datensatz aus dem Datenstrom abgerufen hat.

  • Verarbeitungszeit: Der Zeitpunkt, zu dem Ihre Anwendung den Datensatz verarbeitet hat.

Wenn die Apache Flink-Tabelle Fenster auf der Grundlage von Rekordzeiten API erstellt, definieren Sie mithilfe der Methode, welche dieser Zeitstempel sie verwendet. setStreamTimeCharacteristic

Weitere Informationen zur Verwendung von Zeitstempeln mit der Tabelle API finden Sie unter Time Attributes and Timely Stream Processing in der Apache Flink-Dokumentation.