Package | Description |
---|---|
com.hazelcast.jet |
Hazelcast Jet is a distributed computation engine running on top of
Hazelcast IMDG technology.
|
com.hazelcast.jet.config |
Jet's configuration data objects.
|
com.hazelcast.jet.core |
Jet's Core API.
|
com.hazelcast.jet.core.test |
Utilities for writing tests of Core API Processors.
|
Modifier and Type | Method and Description |
---|---|
JobConfig |
Job.getConfig()
Returns the configuration this job was submitted with.
|
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.setAutoScaling(boolean enabled)
Sets whether Jet will scale the job up or down when a member is added or
removed from the cluster.
|
JobConfig |
JobConfig.setClassLoaderFactory(JobClassLoaderFactory classLoaderFactory)
Sets a custom
JobClassLoaderFactory that will be used to load
job classes and resources on Jet members. |
JobConfig |
JobConfig.setMaxWatermarkRetainMillis(int retainMillis)
Sets the maximum time to retain the watermarks while coalescing them.
|
JobConfig |
JobConfig.setName(String name)
Sets the name for the job.
|
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 |
---|---|
JobConfig |
ProcessorMetaSupplier.Context.jobConfig()
Returns the
JobConfig . |
Modifier and Type | Method and Description |
---|---|
JobConfig |
TestProcessorMetaSupplierContext.jobConfig() |
Modifier and Type | Method and Description |
---|---|
TestProcessorMetaSupplierContext |
TestProcessorMetaSupplierContext.setJobConfig(JobConfig jobConfig)
Sets the job name.
|
Copyright © 2018 Hazelcast, Inc.. All rights reserved.