Package | Description |
---|---|
com.hazelcast.jet |
The Pipeline API is Jet's high-level API to build and execute
distributed computation jobs.
|
com.hazelcast.jet.config |
Jet's configuration data objects.
|
com.hazelcast.jet.stream |
java.util.stream implementation using Hazelcast Jet
|
Modifier and Type | Method and Description |
---|---|
Job |
JetInstance.newJob(DAG dag,
JobConfig config)
Creates and returns a Jet job based on the supplied DAG and job
configuration.
|
default Job |
JetInstance.newJob(Pipeline pipeline,
JobConfig config)
Creates and returns a Jet job based on the supplied pipeline and job
configuration.
|
Modifier and Type | Method and Description |
---|---|
JobConfig |
JobConfig.addClass(Class... classes)
Adds the supplied classes to the list of resources that will be
available on the job's classpath while it's executing in the Jet
cluster.
|
JobConfig |
JobConfig.addJar(File file)
Adds the supplied JAR file to the list of JARs that will be a part of
the job's classpath while it's executing in the Jet cluster.
|
JobConfig |
JobConfig.addJar(String path)
Adds the JAR identified by the supplied pathname to the list of JARs
that will be a part of the job's classpath while it's executing in the
Jet cluster.
|
JobConfig |
JobConfig.addJar(URL url)
Adds the JAR identified by the supplied URL to the list of JARs that
will be a part of the job's classpath while it's executing in the Jet
cluster.
|
JobConfig |
JobConfig.addResource(File file)
Adds the supplied file to the list of resources that will be on the
job's classpath while it's executing in the Jet cluster.
|
JobConfig |
JobConfig.addResource(File file,
String id)
Adds the supplied file to the list of resources that will be on the
job's classpath while it's executing in the Jet cluster.
|
JobConfig |
JobConfig.addResource(String path)
Adds the resource identified by the supplied pathname to the list of
resources that will be on the job's classpath while it's executing in
the Jet cluster.
|
JobConfig |
JobConfig.addResource(String path,
String id)
Adds the resource identified by the supplied pathname to the list of
resources that will be on the job's classpath while it's executing in
the Jet cluster.
|
JobConfig |
JobConfig.addResource(URL url)
Adds the resource identified by the supplied URL to the list of
resources that will be on the job's classpath while it's executing in
the Jet cluster.
|
JobConfig |
JobConfig.addResource(URL url,
String id)
Adds the resource identified by the supplied URL to the list of
resources that will be on the job's classpath while it's executing in
the Jet cluster.
|
JobConfig |
JobConfig.setAutoRestartOnMemberFailure(boolean isEnabled)
Sets whether the job should automatically restart after a
participating member leaves the cluster.
|
JobConfig |
JobConfig.setProcessingGuarantee(ProcessingGuarantee processingGuarantee)
Set the
processing guarantee for the job. |
JobConfig |
JobConfig.setSnapshotIntervalMillis(long snapshotInterval)
Sets the snapshot interval in milliseconds — the interval between
the completion of the previous snapshot and the start of a new one.
|
JobConfig |
JobConfig.setSplitBrainProtection(boolean isEnabled)
Configures the split brain protection feature.
|
Modifier and Type | Method and Description |
---|---|
DistributedIntStream |
DistributedIntStream.configure(JobConfig jobConfig) |
DistributedLongStream |
DistributedLongStream.configure(JobConfig jobConfig) |
DistributedDoubleStream |
DistributedDoubleStream.configure(JobConfig jobConfig) |
DistributedStream<T> |
DistributedStream.configure(JobConfig jobConfig) |
Copyright © 2017 Hazelcast, Inc.. All Rights Reserved.