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