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

O Amazon Managed Service para Apache Flink (Amazon MSF) era conhecido anteriormente como Amazon Kinesis Data Analytics for Apache Flink.

As traduções são geradas por tradução automática. Em caso de conflito entre o conteúdo da tradução e da versão original em inglês, a versão em inglês prevalecerá.

Acompanhe eventos no Managed Service para 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 streaming usandosetStreamTimeCharacteristic. 

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

Para obter mais informações sobre timestamps, consulte Gerando marcas d'água na documentação do Apache Flink.