Java SE 8 Stream API is a modern and functional API for processing Java Collections. Streams can do parallel processing by utilizing multi-core architecture, without writing a single line of multithreaded code. Hazelcast JET is a distributed, high-performance stream processing DAG engine, which provides distributed Java 8 Stream API implementation. This session will highlight this implementation of Stream API for big-data processing across many machines from the comfort of your Java Application.

With an explanation of internals of the implementation, I will give an introduction to the general design behind stream processing using DAG (directed acyclic graph) engines and how an actor-based implementation can provide in-memory performance while still leveraging industry-wide known frameworks as Java Streams API.