Rastreie eventos no Managed Service for Apache Flink usando o DataStream API - Managed Service for Apache Flink

Anteriormente, o Amazon Managed Service for Apache Flink era conhecido 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á.

Rastreie eventos no Managed Service for Apache Flink usando o DataStream API

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.