InputUpdate - Amazon Managed Servics for Apache Flink(前身为 Amazon Kinesis Data Analytics for Apache Flink)

本文属于机器翻译版本。若本译文内容与英语原文存在差异,则一律以英文原文为准。

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 的更多信息,请参阅以下内容: