Artículos por etiqueta: flink

Inner join en Flink con CRUD de Debezium

Implementación de inner join en tiempo real de tablas en Apache Flink con soporte completo para crear/leer/actualizar/eliminar de Debezium. Código, gestión de estado, limitaciones. Para dev middle/senior.

Flink JOIN en tiempo real: tablas 4+2 TB

Implementación de JOIN con estado en Apache Flink para actualizaciones de resultados en tiempo real entre tablas de terabytes. Table API, KeyedCoProcessFunction, MapState. Código y arquitectura para middle/senior.