Grid computing

JBoss DataGrid is also a computing grid; nodes can be used to perform distributed computing. JBoss Datagrid provides various mechanisms to empower data stored in these nodes:

• Distributed streams that aim to transform a cache entry set into a Java 8 Stream
• Distributed executors that extend the Java Executor stack to schedule tasks on cache instances

Distributed Streams

Data grid can also be used as a grid computing engine to perform various computation tasks on large and distributed datasets. Users can turn all the cache entries of a local, replication, or invalidation cache into a regular Java Stream using the following operations:

cache.entrySet().stream()
cache.entrySet().parallelStream()

So, instead of iterating on data key values yourself, the underlying org.infinisap.CacheStream object handles it, and you just have to provide operations to perform on it.

The primary interest of using streams with an Infinispan cache is Distributed Streams. Distributed Streams allow any operation...