Le service géré Amazon pour Apache Flink était auparavant connu sous le nom d’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.
Exemples Java
Les exemples suivants montrent comment créer des applications écrites en Java.
Note
La plupart des exemples sont conçus pour s'exécuter à la fois localement, sur votre machine de développement et sur l'IDE de votre choix, et sur Amazon Managed Service pour Apache Flink. Ils montrent les mécanismes que vous pouvez utiliser pour transmettre les paramètres de l'application et comment définir correctement la dépendance pour exécuter l'application dans les deux environnements sans modification.
Cet exemple montre une application simple qui lit à partir d'un flux de données Kinesis et écrit dans un autre flux de données Kinesis à l'aide de l'API. DataStream
L'exemple montre comment configurer le fichier avec les dépendances correctes, créer l'Uber-JAR, puis analyser les paramètres de configuration afin de pouvoir exécuter l'application à la fois localement, dans votre IDE et sur Amazon Managed Service pour Apache Flink.
Exemple de code : GettingStarted
Cet exemple montre une application simple utilisant l'Table
API et le SQL. Il montre comment intégrer l'DataStream
API à l'Table
API ou au SQL dans la même application Java. Il montre également comment utiliser le DataGen
connecteur pour générer des données de test aléatoires à partir de l'application Flink elle-même, sans nécessiter de générateur de données externe.
Exemple complet : GettingStartedTable
Cet exemple montre comment utiliser les DataStream
API FileSink
pour écrire des fichiers JSON dans un compartiment S3.
Exemple de code : S3Sink
Cet exemple montre comment configurer une source consommant un flux de données Kinesis, en utilisant le consommateur standard ou EFO, et comment configurer un récepteur pour le flux de données Kinesis.
Exemple de code : KinesisConnectors
Cet exemple montre comment envoyer des données à Amazon Data Firehose (anciennement connu sous le nom de Kinesis Data Firehose).
Exemple de code : KinesisFirehoseSink
Ces deux exemples montrent comment implémenter l'agrégation sur des fenêtres de traitement, en glissant ou en décroissant, à l'aide de l'API. DataStream
Exemples de code :
Ces deux exemples distincts WordCount
montrent comment implémenter des métriques personnalisées dans l'DataStream
API et les envoyer vers CloudWatch des métriques. RecordCount
Exemples de code : CustomMetrics