Realtime Compute for Apache Flink:Plantillas de código

Categoría

Nombre de la plantilla

Caso de uso

Plantillas básicas

Create Table

Use una instrucción DDL para crear una tabla y guardarla en un catálogo.

Create Temporary Table

Use una tabla temporal si solo necesita la tabla dentro de la sesión actual o del script SQL.

Create Temporary View

Use una vista temporal para simplificar el desarrollo en Flink SQL mediante la reutilización de código o la organización de consultas extensas y scripts SQL.

INSERT INTO

Para escribir los resultados de una consulta en una tabla de un sistema de almacenamiento externo destinado a aplicaciones posteriores, use la sintaxis INSERT INTO.

STATEMENT SET

Para enviar los resultados de una consulta a dos o más sistemas posteriores, use la sintaxis STATEMENT SET.

Watermark

Use watermarks para garantizar que Flink gestione correctamente los datos desordenados. Defina un watermark en el DDL de una tabla al aplicar una expresión de generación sobre un campo existente, lo cual lo marca como el atributo de tiempo de evento. Para obtener más información, consulte Event time and watermarks.

Agregación y análisis

GROUP BY

Para agregar y analizar datos en tiempo real, use la instrucción GROUP BY.

Tumbling window aggregation

Para agrupar datos de series temporales y ejecutar agregaciones dentro de cada grupo, use una ventana de salto (tumbling window).

Sliding window aggregation

Para actualizar datos dentro de una ventana a intervalos regulares, use una ventana deslizante (sliding window).

Cumulative window aggregation

Para visualizar resultados de ventanas de forma anticipada, como observar el resultado más reciente cada minuto, use una ventana acumulativa (cumulative window).

Session window aggregation

Para analizar en tiempo real los datos que generan los usuarios durante una sesión activa, use una ventana de sesión (session window).

Over window aggregation

Para ejecutar análisis estadísticos sobre cada elemento dentro de una ventana, use una ventana over (over window).

Cascading window aggregation

Para agregar datos del mismo flujo en distintas dimensiones temporales, como 1 minuto, 5 minutos, 30 minutos y 1 hora, use una ventana en cascada (cascading window).

Deduplication template

Deduplicación

Para eliminar registros duplicados de un flujo de datos, use la sintaxis de deduplicación.

Plantillas Top-N

Top-N

Para encontrar los N registros superiores o inferiores según los requisitos del negocio, use la sintaxis Top-N.

Window Top-N

Para encontrar los N registros superiores o inferiores dentro de un rango de tiempo específico, use la sintaxis Window Top-N.

Plantilla CEP

Procesamiento de eventos complejos (CEP)

Para buscar una secuencia de patrones de eventos en un flujo de datos, use la sintaxis MATCH_RECOGNIZE.

Plantillas de unión (Join)

Regular join

Para enriquecer un flujo al unirlo con datos de otros flujos, use una unión regular (regular join).

Interval join

Para unir registros de dos flujos que se encuentran dentro de un intervalo de tiempo especificado, use una unión de intervalo (interval join).

Temporal join

Para unir cada registro de un flujo de datos con los datos versionados correspondientes en una tabla temporal, use una unión temporal (temporal join).

Lookup join

Para unir un flujo de datos con una tabla de dimensiones estática, use una unión de búsqueda (lookup join).