The Pipeline API is Jet's high-level API to build and execute distributed computation jobs.
Classes intended to be used for accumulator objects in Jet aggregation operations.
Jet's configuration data objects.
Jet's Core API.
Apache Kafka reader/writer support for Hazelcast Jet.
Utilities for writing tests of Core API Processors.
Generic data containers used by the Pipeline API.
Serializable variants of functional interfaces from
Contains Java program entry points that will start a Jet server instance, submit jobs to a Jet cluster, etc.
java.util.stream implementation using Hazelcast Jet
Copyright © 2017 Hazelcast, Inc.. All Rights Reserved.