Hazelcast Jet es un framework open-source (licencia Apache 2) para el procesamiento distribuido de datos en memoria:
Hazelcast Jet usa DAGs (directed acyclic graphs) para modelar last areas de procesamiento de datos ofreciendo un motor de baja latencia y alto throughput.
Un job Jet se compone de processors (unidades de procesamiento paralelo como data source readers, joiners, sorters, aggregators, filters, mappers o output writers). Estos nodes se conectan vía edges representando el data Flow.
Entre sus principales características tenemos:
· Low Latency End-to-end
· Batches tratados como streams
· Conexión con Data Brokers (conector Kafka por ejemplo)
· Hazelcast IMDG embebido
· Procesamiento distribuido con Hazelcast IMDG
· Simple de usar: un único JAR sin dependencias
· Ligero y embebible
· Despliegue en cloud
· Discovery
· Ejecuta en YARN y en MESOS
· Soporte HDFS
· Java 8 Stream API + API Core
La forma de usarlo es esta:
Podéis encontrar ejemplos aquí: https://github.com/hazelcast/hazelcast-jet-code-samples
Un poco de Java 
Deja un comentario