Uses of Class
com.hazelcast.jet.JetException
Package | Description |
---|---|
com.hazelcast.jet |
Hazelcast Jet is a distributed computation engine running on top of
Hazelcast IMDG technology.
|
com.hazelcast.jet.core |
Jet's Core API.
|
com.hazelcast.jet.pipeline |
The Pipeline API is Jet's high-level API to build and execute
distributed computation jobs.
|
-
Uses of JetException in com.hazelcast.jet
Subclasses of JetException in com.hazelcast.jet Modifier and Type Class Description class
JobAlreadyExistsException
Thrown when a named job is submitted while there is an active job with the same name.class
RestartableException
Exception to throw from job-executing methods to indicate a failure that can be resolved by restarting the job. -
Uses of JetException in com.hazelcast.jet.core
Subclasses of JetException in com.hazelcast.jet.core Modifier and Type Class Description class
JobNotFoundException
Thrown when a job could not be found on the master nodeclass
TopologyChangedException
Thrown when a topology change causes a job to abort. -
Uses of JetException in com.hazelcast.jet.pipeline
Methods in com.hazelcast.jet.pipeline that throw JetException Modifier and Type Method Description void
SourceBuilder.SourceBuffer. close()
Closes the buffer, signaling that all items have been emitted.