Monitoraggio degli eventi in Managed Service for Apache Flink utilizzando l'API DataStream - Servizio gestito per Apache Flink

Il servizio gestito da Amazon per Apache Flink era precedentemente noto come Analisi dei dati Amazon Kinesis per Apache Flink.

Le traduzioni sono generate tramite traduzione automatica. In caso di conflitto tra il contenuto di una traduzione e la versione originale in Inglese, quest'ultima prevarrà.

Monitoraggio degli eventi in Managed Service for Apache Flink utilizzando l'API DataStream

Servizio gestito per Apache Flink tiene traccia degli eventi utilizzando i seguenti timestamp:

  • Tempo di elaborazione: si riferisce all'ora di sistema della macchina che esegue la rispettiva operazione.

  • Ora evento: si riferisce all'ora in cui ogni singolo evento si è verificato sul dispositivo di produzione.

  • Tempo di acquisizione: si riferisce all'ora in cui gli eventi entrano nel servizio gestito per Apache Flink.

Si imposta l'ora utilizzata dall'ambiente di streaming utilizzando. setStreamTimeCharacteristic 

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

Per ulteriori informazioni sui timestamp, consulta Generazione di filigrane nella documentazione di Apache Flink.