Package com.hazelcast.jet

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

Class	Description
Jet	Deprecated. After 5.0 Jet was merged into core Hazelcast product.
JetCacheManager	Deprecated. since 5.0 Use ICacheManager instead.
JetException	Base Jet exception.
JetInstance	Deprecated. After 5.0 Jet was merged into core Hazelcast product.
JetMemberSelector	Selects the members on which a specific job will run.
JetService	Jet is a component of Hazelcast to execute streaming or batch computations.
JetService.JobBuilder
Job	A handle to Jet computation job created by submitting a DAG or Pipeline to the cluster.
JobAlreadyExistsException	Thrown when a named job is submitted while there is an active job with the same name.
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.
JobStatusListener	Invoked upon job status change.
Observable<T>	Represents a flowing sequence of events produced by observable sinks.
RestartableException	Exception to throw from job-executing methods to indicate a failure that can be resolved by restarting the job.
Traverser<T>	Traverses a potentially infinite sequence of non-null items.
Traversers	Utility class with several Traversers useful in Processor implementations.
Util	Miscellaneous utility methods useful in DAG building logic.