This manual is for an old version of Hazelcast Jet, use the latest stable version.

As a further layer of convenience, there are some ready-made Processor implementations. These are the broad categories:

  1. Sources and sinks for Hazelcast IMap and IList.
  2. Processors with flatMap-type logic, including map, filter, and the most general flatMap.
  3. Processors that perform a reduction operation after grouping items by key. These come in two flavors: a. Accumulate: reduce by transforming an immutable value. b. Collect: reduce by updating a mutable result container.

Please refer to the Processors Javadoc for further details.