Input - Amazon Managed Service para Apache Flink (anteriormente Amazon Kinesis Data Analytics para Apache Flink)

Las traducciones son generadas a través de traducción automática. En caso de conflicto entre la traducción y la version original de inglés, prevalecerá la version en inglés.

Input

Al configurar la entrada de la aplicación de Kinesis Data Analytics basada en SQL, debe especificar el origen de streaming, el nombre de la secuencia en la aplicación que se crea y la asignación entre los dos.

Contenido

InputSchema

Describe el formato de los datos del origen de transmisión y cómo se asigna cada elemento de datos a las columnas correspondientes del flujo en la aplicación que se crea.

También se utiliza para describir el formato del origen de datos de referencia.

Tipo: objeto SourceSchema

Obligatorio: sí

NamePrefix

El prefijo del nombre que se utilizará al crear el flujo en la aplicación. Supongamos que especifica un prefijo “MyInApplicationStream”. Kinesis Data Analytics crea uno o varios flujos (según el recuento que haya especificado en InputParallelism) dentro de la aplicación con los nombres “MyInApplicationStream_001”, “MyInApplicationStream_002”, etc.

Tipo: string

Limitaciones de longitud: longitud mínima de 1. La longitud máxima es de 32 caracteres.

Patrón: [^-\s<>&]*

Obligatorio: sí

InputParallelism

Describe el número de flujos en la aplicación que se crearán.

Tipo: objeto InputParallelism

Obligatorio: no

InputProcessingConfiguration

La InputProcessingConfiguration para la entrada. Un procesador de entrada transforma los registros a medida que se reciben desde el flujo, antes de la ejecución del código SQL de la aplicación. Actualmente, la única configuración de procesamiento de entrada disponible es InputLambdaProcessor.

Tipo: objeto InputProcessingConfiguration

Obligatorio: no

KinesisFirehoseInput

Si el origen de transmisión es un flujo de entrega de Amazon Kinesis Data Firehose, identifica el ARN del flujo de entrega.

Tipo: objeto KinesisFirehoseInput

Obligatorio: no

KinesisStreamsInput

Si el origen de transmisión es un flujo de datos de Amazon Kinesis, identifica el nombre de recurso de Amazon (ARN) del flujo.

Tipo: objeto KinesisStreamsInput

Obligatorio: no

Véase también

Para obtener más información sobre el uso de esta API en uno de los AWS SDK específicos del idioma, consulta lo siguiente: