Lacak peristiwa di Managed Service untuk Apache Flink menggunakan DataStream API - Layanan Terkelola untuk Apache Flink

Amazon Managed Service untuk Apache Flink sebelumnya dikenal sebagai Amazon Kinesis Data Analytics untuk Apache Flink.

Terjemahan disediakan oleh mesin penerjemah. Jika konten terjemahan yang diberikan bertentangan dengan versi bahasa Inggris aslinya, utamakan versi bahasa Inggris.

Lacak peristiwa di Managed Service untuk Apache Flink menggunakan DataStream API

Layanan Terkelola untuk Apache Flink melacak peristiwa menggunakan stempel waktu berikut:

  • Processing Time (Waktu Pemrosesan): Mengacu pada waktu sistem mesin yang menjalankan operasi masing-masing.

  • Event Time (Waktu Peristiwa): Mengacu pada waktu setiap peristiwa individu terjadi pada perangkat produksinya.

  • Waktu Tertelan: Mengacu pada waktu peristiwa memasuki Layanan Terkelola untuk layanan Apache Flink.

Anda mengatur waktu yang digunakan oleh lingkungan streaming menggunakansetStreamTimeCharacteristic. 

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

Untuk informasi selengkapnya tentang stempel waktu, lihat Membuat Tanda Air di dokumentasi Apache Flink.