InputSchemaUpdate - 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á.

InputSchemaUpdate

Descreve as atualizações para o esquema de entrada de um aplicativo Kinesis Data Analytics baseado em SQL.

Conteúdo

RecordColumnUpdates

Uma lista dos objetos RecordColumn. Cada objeto descreve o mapeamento do elemento na origem do streaming para a coluna correspondente criada no fluxo da aplicação.

Tipo: Matriz de objetos RecordColumn

Membros da Matriz: Número mínimo de 1 item. Número máximo de 1000 itens.

Obrigatório: não

RecordEncodingUpdate

Especifica a codificação dos registros na origem do streaming. Por exemplo, UTF-8.

Tipo: string

Restrições de comprimento: comprimento fixo de 5.

Padrão: UTF-8

Obrigatório: não

RecordFormatUpdate

Especifica o formato dos registros na origem do streaming.

Tipo: objeto RecordFormat

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: