InputUpdate - Amazon Managed Service for Apache Flink (anteriormente Amazon Kinesis Data Analytics for Apache Flink)

As traduções são geradas por tradução automática. Em caso de conflito entre o conteúdo da tradução e da versão original em inglês, a versão em inglês prevalecerá.

InputUpdate

Para um aplicativo Kinesis Data Analytics baseado em SQL, descreve as atualizações em uma configuração de entrada específica (identificada pelo InputId de um aplicativo).

Conteúdo

InputId

O ID de entrada da entrada da aplicação a ser atualizado.

Tipo: string

Restrições de tamanho: tamanho mínimo 1. Tamanho máximo de 50.

Padrão: [a-zA-Z0-9_.-]+

Exigido: Sim

InputParallelismUpdate

Descreve as atualizações de paralelismo (o número de streams no aplicativo que o Kinesis Data Analytics cria para a fonte de streaming específica).

Tipo: objeto InputParallelismUpdate

Obrigatório: Não

InputProcessingConfigurationUpdate

Descreve as atualizações de um InputProcessingConfiguration.

Tipo: objeto InputProcessingConfigurationUpdate

Obrigatório: Não

InputSchemaUpdate

Descreve o formato dos dados na origem do streaming e como cada elemento de dados é mapeado para as colunas correspondentes no fluxo da aplicação que está sendo criado.

Tipo: objeto InputSchemaUpdate

Obrigatório: Não

KinesisFirehoseInputUpdate

Se um fluxo de entrega do Kinesis Data Firehose for a origem do streaming a ser atualizado, fornecerá um ARN de fluxo atualizado.

Tipo: objeto KinesisFirehoseInputUpdate

Obrigatório: Não

KinesisStreamsInputUpdate

Se um fluxo de dados do Kinesis for a origem do streaming a ser atualizado, fornecerá um nome do recurso da Amazon (ARN) de fluxo atualizado.

Tipo: objeto KinesisStreamsInputUpdate

Obrigatório: Não

NamePrefixUpdate

O prefixo do nome para streams no aplicativo que o Kinesis Data Analytics cria para a fonte de streaming específica.

Tipo: string

Restrições de tamanho: tamanho mínimo 1. Comprimento máximo de 32.

Padrão: [^-\s<>&]*

Obrigatório: Não

Consulte também

Para obter mais informações sobre como usar essa API em um dos AWS SDKs específicos da linguagem, consulte o seguinte: