Package com.hazelcast.jet
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
-
Interface Summary Interface Description JetCacheManager Deprecated. since 5.0 UseICacheManager
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 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 usingJob.exportSnapshot(String)
.JobStatusEvent Holds information about a job's state (status) transition, reason for the transition, and whether it is user-initiated.Traversers 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.