Uses of Class
com.hazelcast.jet.config.JobConfig
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.
|
-
Uses of JobConfig in com.hazelcast.jet
Methods in com.hazelcast.jet that return JobConfig Modifier and Type Method Description JobConfig
Job. getConfig()
Returns the configuration this job was submitted with.Methods in com.hazelcast.jet with parameters of type JobConfig Modifier and Type Method Description Job
JetInstance. newJob(DAG dag, JobConfig config)
Creates and returns a Jet job based on the supplied DAG and job configuration.Job
JetInstance. newJob(Pipeline pipeline, JobConfig config)
Creates and returns a Jet job based on the supplied pipeline and job configuration.Job
JetInstance. newJobIfAbsent(DAG dag, JobConfig config)
Creates and returns a Jet job based on the supplied DAG and job configuration.Job
JetInstance. newJobIfAbsent(Pipeline pipeline, JobConfig config)
Creates and returns a Jet job based on the supplied pipeline and job configuration. -
Uses of JobConfig in com.hazelcast.jet.config
Methods in com.hazelcast.jet.config that return JobConfig Modifier and Type Method Description JobConfig
JobConfig. addClass(Class... classes)
Adds the given classes and recursively all their nested (inner & anonymous) classes to the Jet job's classpath.JobConfig
JobConfig. addClasspathResource(File file)
Adds a file that will be available as a resource on the Jet job's classpath.JobConfig
JobConfig. addClasspathResource(File file, String id)
Adds a file that will be available as a resource on the Jet job's classpath.JobConfig
JobConfig. addClasspathResource(String path)
Adds a file that will be available as a resource on the Jet job's classpath.JobConfig
JobConfig. addClasspathResource(String path, String id)
Adds a file that will be available as a resource on the Jet job's classpath.JobConfig
JobConfig. addClasspathResource(URL url)
Adds a resource that will be available on the Jet job's classpath.JobConfig
JobConfig. addClasspathResource(URL url, String id)
Adds a resource that will be available on the Jet job's classpath.JobConfig
JobConfig. addJar(File file)
Adds a JAR whose contents will be accessible to all the code attached to the underlying pipeline or DAG, but not to any other code.JobConfig
JobConfig. addJar(String path)
Adds a JAR whose contents will be accessible to all the code attached to the underlying pipeline or DAG, but not to any other code.JobConfig
JobConfig. addJar(URL url)
Adds a JAR whose contents will be accessible to all the code attached to the underlying pipeline or DAG, but not to any other code.JobConfig
JobConfig. addJarsInZip(File file)
Adds a ZIP file with JARs whose contents will be accessible to all the code attached to the underlying pipeline or DAG, but not to any other code.JobConfig
JobConfig. addJarsInZip(String path)
Adds a ZIP file with JARs whose contents will be accessible to all the code attached to the underlying pipeline or DAG, but not to any other code.JobConfig
JobConfig. addJarsInZip(URL url)
Adds a ZIP file with JARs whose contents will be accessible to all the code attached to the underlying pipeline or DAG, but not to any other code.JobConfig
JobConfig. addPackage(String... packages)
Adds recursively all the classes and resources in given packages to the Jet job's classpath.JobConfig
JobConfig. attachAll(Map<String,File> idToFile)
Attaches all the files/directories in the supplied map, as if by callingattachDirectory(dir, id)
for every entry that resolves to a directory andattachFile(file, id)
for every entry that resolves to a regular file.JobConfig
JobConfig. attachDirectory(File file)
Adds the supplied directory to the list of files that will be available to the job while it's executing in the Jet cluster.JobConfig
JobConfig. attachDirectory(File file, String id)
Adds the supplied directory to the list of files that will be available to the job while it's executing in the Jet cluster.JobConfig
JobConfig. attachDirectory(String path)
Adds the directory identified by the supplied pathname to the list of files that will be available to the job while it's executing in the Jet cluster.JobConfig
JobConfig. attachDirectory(String path, String id)
Adds the directory identified by the supplied pathname to the list of files that will be available to the job while it's executing in the Jet cluster.JobConfig
JobConfig. attachDirectory(URL url)
Adds the directory identified by the supplied URL to the list of directories that will be available to the job while it's executing in the Jet cluster.JobConfig
JobConfig. attachDirectory(URL url, String id)
Adds the directory identified by the supplied URL to the list of directories that will be available to the job while it's executing in the Jet cluster.JobConfig
JobConfig. attachFile(File file)
Adds the supplied file to the list of resources that will be available to the job while it's executing in the Jet cluster.JobConfig
JobConfig. attachFile(File file, String id)
Adds the supplied file to the list of files that will be available to the job while it's executing in the Jet cluster.JobConfig
JobConfig. attachFile(String path)
Adds the file identified by the supplied pathname to the list of files that will be available to the job while it's executing in the Jet cluster.JobConfig
JobConfig. attachFile(String path, String id)
Adds the file identified by the supplied pathname to the list of files that will be available to the job while it's executing in the Jet cluster.JobConfig
JobConfig. attachFile(URL url)
Adds the file identified by the supplied URL as a resource that will be available to the job while it's executing in the Jet cluster.JobConfig
JobConfig. attachFile(URL url, String id)
Adds the file identified by the supplied URL to the list of resources that will be available to the job while it's executing in the Jet cluster.<T, S extends StreamSerializer<T>>
JobConfigJobConfig. registerSerializer(Class<T> clazz, Class<S> serializerClass)
Registers the given serializer for the given class for the scope of the job.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 customJobClassLoaderFactory
that will be used to load job classes and resources on Jet members.JobConfig
JobConfig. setInitialSnapshotName(String initialSnapshotName)
Sets the exported state snapshot name to restore the initial job state from.JobConfig
JobConfig. setMetricsEnabled(boolean enabled)
Sets whether metrics collection should be enabled for the job.JobConfig
JobConfig. setName(String name)
Sets the name of the job.JobConfig
JobConfig. setProcessingGuarantee(ProcessingGuarantee processingGuarantee)
Set theprocessing 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.JobConfig
JobConfig. setStoreMetricsAfterJobCompletion(boolean storeMetricsAfterJobCompletion)
Sets whether metrics should be stored in the cluster after the job completes.JobConfig
JobConfig. setSuspendOnFailure(boolean suspendOnFailure)
Sets what happens if the job execution fails: If enabled, the job will be suspended. -
Uses of JobConfig in com.hazelcast.jet.core
Methods in com.hazelcast.jet.core that return JobConfig Modifier and Type Method Description JobConfig
ProcessorMetaSupplier.Context. jobConfig()
Returns theJobConfig
. -
Uses of JobConfig in com.hazelcast.jet.core.test
Methods in com.hazelcast.jet.core.test that return JobConfig Modifier and Type Method Description JobConfig
TestProcessorMetaSupplierContext. jobConfig()
Methods in com.hazelcast.jet.core.test with parameters of type JobConfig Modifier and Type Method Description TestProcessorMetaSupplierContext
TestProcessorMetaSupplierContext. setJobConfig(JobConfig jobConfig)
Sets the job name.