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, for removal: This API element is subject to removal in a future version. After 5.0 Jet was merged into core Hazelcast product.
JetCacheManager	Deprecated, for removal: This API element is subject to removal in a future version. Use ICacheManager instead.
JetException	Base Jet exception.
JetInstance	Deprecated, for removal: This API element is subject to removal in a future version. 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.