Seguimiento de eventos en Managed Service for Apache Flink mediante la API DataStream - Managed Service para Apache Flink

Amazon Managed Service para Apache Flink Amazon se denominaba anteriormente Amazon Kinesis Data Analytics para Apache Flink.

Las traducciones son generadas a través de traducción automática. En caso de conflicto entre la traducción y la version original de inglés, prevalecerá la version en inglés.

Seguimiento de eventos en Managed Service for Apache Flink mediante la API DataStream

Managed Service para Apache Flink realiza un seguimiento de los eventos mediante las siguientes marcas de tiempo:

  • Hora de procesamiento: se refiere a la hora del sistema de la máquina que está ejecutando la operación correspondiente.

  • Hora del evento: se refiere a la hora en que ocurrió cada evento individual en el dispositivo que lo produjo.

  • Hora de adquisición de datos: se refiere al momento en que los eventos ingresan al servicio Managed Service para Apache Flink.

El tiempo utilizado por el entorno de streaming se establece mediante. setStreamTimeCharacteristic

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

Para obtener más información sobre las marcas de tiempo, consulte Generación de marcas de agua en la documentación de Apache Flink.