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

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

Seguimiento de eventos en Managed Service para Apache Flink mediante la API de 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.

Usted establece la hora utilizada por el entorno de streaming mediante setStreamTimeCharacteristic.

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

Para obtener más información sobre marcas de tiempo, consulte Generating Watermarks en la documentación de Apache Fink.