InputUpdate - 阿帕奇 Flink 的 Amazon 託管服務(以前為阿帕奇 Flink 的 Amazon Kinesis Data Analytics)

本文為英文版的機器翻譯版本,如內容有任何歧義或不一致之處,概以英文版為準。

InputUpdate

對於以 SQL 為基礎的 Kinesis Data Analytics 應用程式,說明特定輸入組態 (由應用程式識別) InputId 的更新。

目錄

InputId

要更新的應用程式輸入的輸入 ID。

類型:字串

長度限制:長度下限為 1。長度上限為 50。

模式:[a-zA-Z0-9_.-]+

必要:是

InputParallelismUpdate

描述平行處理原則更新 (Kinesis Data Analytics 針對特定串流來源建立的應用程式內串流數量)。

類型:InputParallelismUpdate 物件

必要:否

InputProcessingConfigurationUpdate

描述InputProcessingConfiguration.

類型:InputProcessingConfigurationUpdate 物件

必要:否

InputSchemaUpdate

描述串流來源中的資料格式,以及串流來源的紀錄元素如何映射至建立的應用程式內串流資料欄。

類型:InputSchemaUpdate 物件

必要:否

KinesisFirehoseInputUpdate

如果 Kinesis Data Firehose 傳送串流是要更新的串流來源,則會提供更新的串流 ARN。

類型:KinesisFirehoseInputUpdate 物件

必要:否

KinesisStreamsInputUpdate

如果 Kinesis 資料串流是要更新的串流來源,則會提供更新的資料流 Amazon 資源名稱 (ARN)。

類型:KinesisStreamsInputUpdate 物件

必要:否

NamePrefixUpdate

Kinesis Data Analytics 為特定串流來源建立的應用程式內串流的名稱前置詞。

類型:字串

長度限制:長度下限為 1。長度上限為 32。

模式:[^-\s<>&]*

必要:否

另請參閱

如需在其中一個特定語言 AWS SDK 中使用此 API 的詳細資訊,請參閱下列內容: