Input - Amazon Managed Service pour Apache Flink (anciennement Amazon Kinesis Data Analytics pour Apache Flink)

Les traductions sont fournies par des outils de traduction automatique. En cas de conflit entre le contenu d'une traduction et celui de la version originale en anglais, la version anglaise prévaudra.

Input

Lorsque vous configurez l'entrée d'une application Kinesis Data Analytics basée sur SQL, vous spécifiez la source de diffusion, le nom du flux intégré à l'application qui est créé, ainsi que le mappage entre les deux.

Table des matières

InputSchema

Décrit le format des données de la source de diffusion, et la manière dont chaque élément de données est mappé aux colonnes correspondantes dans le flux intégré à l'application qui est en cours de création.

Egalement utilisé pour décrire le format de la source de données de référence.

Type : objet SourceSchema

Obligatoire : oui

NamePrefix

Préfixe de nom à utiliser lors de la création d'un flux intégré à l'application. Supposons que vous spécifiez un préfixe « MyInApplicationStream ». Kinesis Data Analytics crée alors un ou plusieurs flux intégrés à l'application (en fonction du nombre d'InputParallelism spécifié) avec des noms « MyInApplicationStream_001 », « MyInApplicationStream_002 », et ainsi de suite.

Type : chaîne

Contraintes de longueur : longueur minimum de 1. Longueur maximale de 32.

Modèle : [^-\s<>&]*

Obligatoire : oui

InputParallelism

Décrit le nombre de flux intégrés à l'application à créer.

Type : objet InputParallelism

Obligatoire : non

InputProcessingConfiguration

Le InputProcessingConfiguration pour la saisie. Un processeur d'entrée transforme les enregistrements au fur et à mesure qu'ils sont reçus depuis le flux, avant l'exécution de l'application du code SQL. Actuellement, la seule configuration de traitement d'entrée disponible est InputLambdaProcessor.

Type : objet InputProcessingConfiguration

Obligatoire : non

KinesisFirehoseInput

Si la source de diffusion est un flux de diffusion Amazon Kinesis Data Firehose, identifie l'ARN du flux de diffusion.

Type : objet KinesisFirehoseInput

Obligatoire : non

KinesisStreamsInput

Si la source de diffusion est un flux de données Amazon Kinesis, identifie l'Amazon Resource Name (ARN) du flux de diffusion.

Type : objet KinesisStreamsInput

Obligatoire : non

consultez aussi

Pour plus d'informations sur l'utilisation de cette API dans l'un des AWS SDK spécifiques au langage, consultez les pages suivantes :