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. 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
-
Ventana deslizante basada en el tiempo de procesamiento
-
Ventana corredera basada en la hora del evento
-
Ventana giratoria basada en el tiempo de procesamiento
-
Ventana giratoria basada en la hora del evento
En este ejemplo se muestra cómo añadir métricas personalizadas a la aplicación Flink y enviarlas a las métricas. CloudWatch
Ejemplo de código: CustomMetrics
Este ejemplo ilustra cómo puede utilizar los proveedores de configuración de Kafka para configurar un almacén de claves y un almacén de confianza personalizados con certificados para la autenticación m para el conector de Kafka. TLS Esta técnica le permite cargar los certificados personalizados necesarios desde Amazon S3 y los secretos desde el AWS Secrets Manager momento en que se inicia la aplicación.
Ejemplo de código: TLSKafka-M
Este ejemplo ilustra cómo puede utilizar los proveedores de configuración de Kafka para obtener credenciales AWS Secrets Manager y descargar el almacén de confianza de Amazon S3 para configurar o autenticar un conector SASL de SCRAM Kafka. Esta técnica le permite cargar los certificados personalizados necesarios desde Amazon S3 y los secretos desde el AWS Secrets Manager momento en que se inicia la aplicación.
Ejemplo de código: Kafka- SASL _ SSL - ConfigProviders
