Atributos de tempo da API Table - 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.

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á.

Atributos de tempo da API Table

Cada registro em um fluxo de dados tem vários timestamps que definem quando os eventos relacionados ao registro ocorreram:

  • Hora do evento: um timestamp definido pelo usuário que define quando o evento que criou o registro ocorreu.

  • Tempo de ingestão: o momento em que seu aplicativo recuperou o registro do fluxo de dados.

  • Tempo de processamento: o momento em que seu aplicativo processou o registro.

Quando a API Table do Apache Flink cria janelas com base nas horas registradas, você define quais desses timestamps ela usa usando o método setStreamTimeCharacteristic.

Para obter mais informações sobre o uso de timestamps com a API Table, consulte Atributos de tempo e Processamento oportuno de fluxos na Documentação do Apache Flink.