Ejemplos en Java de Managed Service for Apache Flink - Managed Service para Apache Flink

Amazon Managed Service para Apache Flink Amazon se denominaba 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.

Ejemplos en Java de Managed Service for Apache Flink

Los siguientes ejemplos muestran cómo crear aplicaciones escritas en Java.

nota

La mayoría de los ejemplos están diseñados para ejecutarse tanto de forma local, en la máquina IDE de desarrollo que elijas, como en Amazon Managed Service para Apache Flink. En ellos se muestran los mecanismos que puede utilizar para transferir los parámetros de la aplicación y cómo configurar la dependencia correctamente para ejecutar la aplicación en ambos entornos sin cambios.

En este ejemplo, se muestra una aplicación sencilla que lee de una transmisión de datos de Kinesis y escribe en otra transmisión de datos de Kinesis mediante el. DataStream API En el ejemplo se muestra cómo configurar el archivo con las dependencias correctas, crear el uber- yJAR, a continuación, analizar los parámetros de configuración para que pueda ejecutar la aplicación tanto de forma local, en su IDE cuenta como en Amazon Managed Service para Apache Flink.

Ejemplo de código: GettingStarted

En este ejemplo se muestra una aplicación sencilla que utiliza las Table API teclas ySQL. Demuestra cómo integrarlo DataStream API con Table API o SQL en la misma aplicación Java. También muestra cómo utilizar el DataGen conector para generar datos de prueba aleatorios desde la propia aplicación Flink, sin necesidad de un generador de datos externo.

Ejemplo completo: GettingStartedTable

En este ejemplo, se muestra cómo usar los s DataStream API FileSink para escribir JSON archivos en un bucket de S3.

Ejemplo de código: S3Sink

Este ejemplo muestra cómo configurar una fuente que consume de una transmisión de datos de Kinesis, ya sea utilizando el consumidor estándar oEFO, y cómo configurar un sumidero para la transmisión de datos de Kinesis.

Ejemplo de código: KinesisConnectors

En este ejemplo se muestra cómo enviar datos a Amazon Data Firehose (anteriormente conocido como Kinesis Data Firehose).

Ejemplo de código: KinesisFirehoseSink

En este ejemplo se muestran cuatro tipos de agregación de ventanas en. DataStream API

  1. Ventana deslizante basada en el tiempo de procesamiento

  2. Ventana corredera basada en la hora del evento

  3. Ventana giratoria basada en el tiempo de procesamiento

  4. Ventana giratoria basada en la hora del evento

Ejemplo de código: Windowing

En este ejemplo, se muestra cómo añadir métricas personalizadas a la aplicación Flink y enviarlas a las métricas. CloudWatch

Ejemplos de código: CustomMetrics