Rastrear eventos no Managed Service for Apache Flink usando a API DataStream - Managed Service for Apache Flink

Anteriormente, o Amazon Managed Service for Apache Flink (Amazon MSF) era conhecido como Amazon Kinesis Data Analytics for Apache Flink.

Rastrear eventos no Managed Service for Apache Flink usando a API DataStream

O Managed Service for Apache Flink rastreia eventos usando os seguintes timestamps:

  • Tempo de processamento: refere-se à hora do sistema da máquina que está executando a respectiva operação.

  • Hora do evento: refere-se à hora em que cada evento individual ocorreu em seu dispositivo produtor.

  • Tempo de ingestão: refere-se à hora em que os eventos entram no serviço Managed Service for Apache Flink.

Você define o tempo usado pelo ambiente de transmissão usando setStreamTimeCharacteristic.

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

Para obter mais informações sobre timestamps, consulte Geração de marcas d’água na Documentação do Apache Flink.