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 | Method and Description |
---|---|
default Job |
JetService.newJob(DAG dag)
Creates and returns a Jet job based on the supplied DAG.
|
Job |
JetService.newJob(DAG dag,
JobConfig config)
Creates and returns a Jet job based on the supplied DAG and job
configuration.
|
Job |
JetService.newJobIfAbsent(DAG dag,
JobConfig config)
Creates and returns a Jet job based on the supplied DAG and job
configuration.
|
default Job |
JetService.newLightJob(DAG dag)
Submits a job defined in the Core API with a default config.
|
Job |
JetService.newLightJob(DAG dag,
JobConfig config)
Submits a job defined in the Core API.
|
Modifier and Type | Method and Description |
---|---|
DAG |
DAG.edge(Edge edge)
Adds an edge to this DAG.
|
DAG |
DAG.vertex(Vertex vertex)
Adds a vertex to this DAG.
|
Modifier and Type | Method and Description |
---|---|
DAG |
Pipeline.toDag()
Deprecated.
since Jet 4.3, Jet performs this transformation on the server-side.
|
Copyright © 2021 Hazelcast, Inc.. All rights reserved.