InputUpdate - Amazon Managed Service untuk Apache Flink (sebelumnya 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.

InputUpdate

Untuk aplikasi Kinesis Data Analytics berbasis SQL, menjelaskan pembaruan ke konfigurasi input tertentu (diidentifikasi oleh aplikasi)InputId.

Daftar Isi

InputId

ID masukan dari input aplikasi yang akan diperbarui.

Jenis: String

Batasan Panjang: Panjang minimum 1. Panjang maksimum 50.

Pola: [a-zA-Z0-9_.-]+

Wajib: Ya

InputParallelismUpdate

Menjelaskan pembaruan paralelisme (jumlah aliran dalam aplikasi yang dibuat Kinesis Data Analytics untuk sumber streaming tertentu).

Tipe: Objek InputParallelismUpdate

Wajib: Tidak

InputProcessingConfigurationUpdate

Menjelaskan pembaruan ke fileInputProcessingConfiguration.

Tipe: Objek InputProcessingConfigurationUpdate

Wajib: Tidak

InputSchemaUpdate

Menjelaskan format data pada sumber streaming, dan cara elemen catatan di sumber streaming dipetakan ke kolom aliran dalam aplikasi yang dibuat.

Tipe: Objek InputSchemaUpdate

Wajib: Tidak

KinesisFirehoseInputUpdate

Jika aliran pengiriman Kinesis Data Firehose adalah sumber streaming yang akan diperbarui, berikan ARN streaming yang diperbarui.

Tipe: Objek KinesisFirehoseInputUpdate

Wajib: Tidak

KinesisStreamsInputUpdate

Jika aliran data Kinesis adalah sumber streaming yang akan diperbarui, berikan aliran Amazon Resource Name (ARN) yang diperbarui.

Tipe: Objek KinesisStreamsInputUpdate

Wajib: Tidak

NamePrefixUpdate

Awalan nama untuk aliran dalam aplikasi yang dibuat oleh Kinesis Data Analytics untuk sumber streaming tertentu.

Jenis: String

Batasan Panjang: Panjang minimum 1. Panjang maksimum 32.

Pola: [^-\s<>&]*

Diperlukan: Tidak

Lihat Juga

Untuk informasi selengkapnya tentang penggunaan API ini di salah satu AWS SDK khusus bahasa, lihat berikut ini: