Package com.hazelcast.jet

Hazelcast Jet is a distributed computation engine running on top of Hazelcast IMDG technology.

See: Description

Interface Summary

Interface	Description
JetCacheManager	Deprecated since 5.0 Use ICacheManager instead.
JetInstance	Deprecated After 5.0 Jet was merged into core Hazelcast product.
JetService	Jet is a component of Hazelcast to execute streaming or batch computations.
Job	A handle to Jet computation job created by submitting a DAG or Pipeline to the cluster.
JobStatusListener	Invoked upon job status change.
Observable<T>	Represents a flowing sequence of events produced by observable sinks.
Traverser<T>	Traverses a potentially infinite sequence of non-null items.

Class Summary

Class	Description
Jet	Deprecated After 5.0 Jet was merged into core Hazelcast product.
JobStateSnapshot	A handle to an exported state snapshot created using Job.exportSnapshot(String).
JobStatusEvent	Holds information about a job's state (status) transition, reason for the transition, and whether it is user-initiated.
Traversers	Utility class with several Traversers useful in Processor implementations.
Util	Miscellaneous utility methods useful in DAG building logic.

Exception Summary

Exception	Description
JetException	Base Jet exception.
JobAlreadyExistsException	Thrown when a named job is submitted while there is an active job with the same name.
RestartableException	Exception to throw from job-executing methods to indicate a failure that can be resolved by restarting the job.

Package com.hazelcast.jet Description

Hazelcast Jet is a distributed computation engine running on top of Hazelcast IMDG technology. To use it, refer to the Javadoc on the Pipeline API and to the Reference Manual.

Since:

Jet 3.0