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:
3.0
  • Interface Summary 
    Interface Description
    JetCacheManager
    JetCacheManager is the entry point to access JSR-107 (JCache) caches via JetInstance interface.
    JetInstance
    Represents either an instance of a Jet server node or a Jet client instance that connects to a remote cluster.
    Job
    A Jet computation job created by submitting a DAG or Pipeline.
    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
    Entry point to the Jet 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.