| 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. 
 | 
| Modifier and Type | Class and 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. 
 | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
JobNotFoundException
Thrown when a job could not be found on the master node 
 | 
class  | 
TopologyChangedException
Thrown when a topology change causes a job to abort. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
SourceBuilder.SourceBuffer.close()
Closes the buffer, signaling that all items have been emitted. 
 | 
Copyright © 2023 Hazelcast, Inc.. All rights reserved.