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 |
JetInstance.newJob(DAG dag)
Creates and returns a Jet job based on the supplied DAG.
|
Job |
JetInstance.newJob(DAG dag,
JobConfig config)
Creates and returns a Jet job based on the supplied DAG and job
configuration.
|
Job |
JetInstance.newJobIfAbsent(DAG dag,
JobConfig config)
Creates and returns a Jet job based on the supplied DAG and job
configuration.
|
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()
Transforms the pipeline into a Jet DAG, which can be submitted for
execution to a Jet instance.
|
Copyright © 2019 Hazelcast, Inc.. All rights reserved.