Uses of Class
com.hazelcast.jet.config.JobConfig

Packages that use 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 and 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 and Description
Job	JetService.newJob(DAG dag, JobConfig config) Creates and returns a Jet job based on the supplied DAG and job configuration.
Job	JetService.newJob(Pipeline pipeline, JobConfig config) Creates and returns a Jet job based on the supplied pipeline and job configuration.
Job	JetService.newJobIfAbsent(DAG dag, JobConfig config) Creates and returns a Jet job based on the supplied DAG and job configuration.
Job	JetService.newJobIfAbsent(Pipeline pipeline, JobConfig config) Creates and returns a Jet job based on the supplied pipeline and job configuration.
Job	JetService.newLightJob(DAG dag, JobConfig config) Submits a job defined in the Core API.
Job	JetService.newLightJob(Pipeline p, JobConfig config) Submits a light job for execution.

Uses of JobConfig in com.hazelcast.jet.config

Methods in com.hazelcast.jet.config that return JobConfig

Modifier and Type	Method and 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.addCustomClasspath(String name, String path) Adds custom classpath element to a stage with the given name.
JobConfig	JobConfig.addCustomClasspaths(String name, List<String> paths) Adds custom classpath elements to a stage with the given name.
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 calling attachDirectory(dir, id) for every entry that resolves to a directory and attachFile(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>> JobConfig	JobConfig.registerSerializer(Class<T> clazz, Class<S> serializerClass) Registers the given serializer for the given class for the scope of the job.
JobConfig	JobConfig.setArgument(String key, Object value) Associates the specified value with the specified key.
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.setInitialSnapshotName(String initialSnapshotName) Sets the exported state snapshot name to restore the initial job state from.
JobConfig	JobConfig.setMaxProcessorAccumulatedRecords(long maxProcessorAccumulatedRecords) Sets the maximum number of records that can be accumulated by any single Processor instance in the context of the job.
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 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.
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.
JobConfig	JobConfig.setTimeoutMillis(long timeoutMillis) Sets the maximum execution time for the job in milliseconds.

Uses of JobConfig in com.hazelcast.jet.core

Methods in com.hazelcast.jet.core that return JobConfig

Modifier and Type	Method and Description
JobConfig	ProcessorMetaSupplier.Context.jobConfig() Returns the JobConfig.

Uses of JobConfig in com.hazelcast.jet.core.test

Methods in com.hazelcast.jet.core.test that return JobConfig

Modifier and Type	Method and Description
JobConfig	TestProcessorMetaSupplierContext.jobConfig()

Methods in com.hazelcast.jet.core.test with parameters of type JobConfig

Modifier and Type	Method and Description
TestSupport	TestSupport.jobConfig(JobConfig jobConfig) Use the given instance for ProcessorMetaSupplier.Context.jobConfig()
TestProcessorMetaSupplierContext	TestProcessorMetaSupplierContext.setJobConfig(JobConfig jobConfig) Sets the config for the job.
TestProcessorSupplierContext	TestProcessorSupplierContext.setJobConfig(JobConfig jobConfig)
TestProcessorContext	TestProcessorContext.setJobConfig(JobConfig jobConfig)