Properti tabel - Layanan Terkelola untuk Apache Flink
Tentukan nilai waktu Apache FlinkGunakan konektor Flink dan properti format

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.

Properti tabel

Selain bidang data, AWS Glue tabel Anda memberikan informasi lain ke buku catatan Studio menggunakan properti tabel. Managed Service untuk Apache Flink menggunakan properti AWS Glue tabel berikut:

Untuk menambahkan properti ke AWS Glue tabel, lakukan hal berikut:

  1. Masuk ke AWS Management Console dan buka AWS Glue konsol di https://console.aws.amazon.com/glue/.

  2. Dari daftar tabel, pilih tabel yang digunakan aplikasi Anda untuk menyimpan informasi koneksi datanya. Pilih Action (Tindakan), Edit table details (Edit detail tabel).

  3. Di bawah Table Properties (Properti Tabel), masukkan managed-flink.proctime untuk key (kunci) dan user_action_time untuk Value (Nilai).

Tentukan nilai waktu Apache Flink

Apache Flink memberikan nilai waktu yang menjelaskan kapan peristiwa pemrosesan aliran terjadi, seperti Processing Time (Waktu Pemrosesan) dan Event Time (Waktu Peristiwa). Untuk menyertakan nilai-nilai ini dalam keluaran aplikasi Anda, Anda menentukan properti pada AWS Glue tabel yang memberi tahu runtime Managed Service for Apache Flink untuk memancarkan nilai-nilai ini ke dalam bidang yang ditentukan.

Kunci dan nilai yang Anda gunakan dalam properti tabel Anda adalah sebagai berikut:

Tipe Stempel Waktu Kunci Nilai
Waktu Pemrosesan dikelola-flink.proctime Nama kolom yang AWS Glue akan digunakan untuk mengekspos nilai. Nama kolom ini tidak sesuai dengan kolom tabel yang ada.
Waktu Acara dikelola flink.rowtime Nama kolom yang AWS Glue akan digunakan untuk mengekspos nilai. Nama kolom ini sesuai dengan kolom tabel yang ada.

terkelola-flink.watermark.column_name.milidetik

 Interval tanda air dalam milidetik

Gunakan konektor Flink dan properti format

Anda memberikan informasi tentang sumber data Anda ke konektor Flink aplikasi Anda menggunakan properti tabel AWS Glue . Beberapa contoh properti yang Managed Service untuk Apache Flink gunakan untuk konektor adalah sebagai berikut:

Tipe Konektor Kunci Nilai
Kafka format Format yang digunakan untuk deserialisasi dan serialisasi pesan Kafka, misalnya atau. json csv
scan.startup.mode Mode startup untuk konsumen Kafka, misalnya earliest-offset atautimestamp.
Kinesis format Format yang digunakan untuk deserialisasi dan serialisasi catatan aliran data Kinesis, misalnya atau. json csv
aws.region AWS Wilayah di mana aliran didefinisikan.
S3 (Sistem Berkas) format Format yang digunakan untuk deserialisasi dan serialisasi file, misalnya atau. json csv
path Jalur Amazon S3, mis. s3://mybucket/

Untuk informasi selengkapnya tentang konektor lainnya selain Kinesis dan Apache Kafka, lihat dokumentasi konektor Anda.