Suivi des événements dans le service géré pour Apache Flink à l'aide de l'API DataStream - Service géré pour Apache Flink

Le service géré Amazon pour Apache Flink était auparavant connu sous le nom d’Amazon Kinesis Data Analytics pour Apache Flink.

Les traductions sont fournies par des outils de traduction automatique. En cas de conflit entre le contenu d'une traduction et celui de la version originale en anglais, la version anglaise prévaudra.

Suivi des événements dans le service géré pour Apache Flink à l'aide de l'API DataStream

Le service géré pour Apache Flink suit les événements à l’aide des horodatages suivants :

  • Heure de traitement : fait référence à l’heure système de la machine qui exécute l’opération correspondante.

  • Heure de l’événement : fait référence à l’heure à laquelle chaque événement individuel s’est produit sur son appareil producteur.

  • Heure d’ingestion : fait référence à l’heure à laquelle les événements entrent dans le service géré pour Apache Flink.

Vous réglez le temps utilisé par l'environnement de streaming à l'aide desetStreamTimeCharacteristic.

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

Pour plus d'informations sur les horodatages, consultez la section Génération de filigranes dans la documentation d'Apache Flink.