Input

Menjelaskan format data dalam sumber streaming, dan cara setiap elemen data memetakan ke kolom yang sesuai di pengaliran dalam aplikasi yang dibuat.

Juga digunakan untuk menjelaskan format sumber data referensi.

Tipe: Objek SourceSchema

Wajib: Ya

Prefiks nama untuk digunakan saat membuat pengaliran dalam aplikasi. Anggap saja Anda menentukan prefiks "MyInApplicationStream." Kinesis Data Analytics kemudian membuat satu atau beberapa (sesuai jumlah InputParallelism yang Anda tentukan) pengaliran dalam aplikasi dengan nama "MyInApplicationStream_001," "MyInApplicationStream_002," dan seterusnya.

Tipe: String

Batasan Panjang: Panjang minimum 1. Panjang maksimum 32.

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

Wajib: Ya

Menjelaskan jumlah pengaliran dalam aplikasi yang dibuat.

Tipe: Objek InputParallelism

Wajib: Tidak

InputProcessingConfigurationUntuk input. Prosesor input mengubah catatan seperti yang diterima dari pengaliran, sebelum dieksekusi oleh kode SQL aplikasi. Saat ini, satu-satunya konfigurasi pemrosesan input yang tersedia adalahInputLambdaProcessor.

Tipe: Objek InputProcessingConfiguration

Wajib: Tidak

Jika sumber streaming adalah aliran pengiriman Amazon Kinesis Data Firehose, ia mengidentifikasi ARN aliran pengiriman.

Tipe: Objek KinesisFirehoseInput

Wajib: Tidak

Jika sumber streaming adalah aliran data Amazon Kinesis, ia mengidentifikasi Amazon Resource Name (ARN) pengaliran tersebut.

Tipe: Objek KinesisStreamsInput

Wajib: Tidak