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.
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).
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