As a further layer of convenience, there are some ready-made Processor implementations. These are the broad categories:
- Sources and sinks for Hazelcast
- Processors with
flatMap-type logic, including
filter, and the most general
- 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.