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 © 2021 Hazelcast, Inc.. All rights reserved.