Uses of Class
com.hazelcast.jet.config.JobConfig
Packages that use JobConfig
Package
Description
Hazelcast Jet is a distributed computation engine running on top of
Hazelcast IMDG technology.
Jet's configuration data objects.
Jet's Core API.
Utilities for writing tests of Core API Processors.
-
Uses of JobConfig in com.hazelcast.jet
Methods in com.hazelcast.jet that return JobConfigModifier and TypeMethodDescriptionJob.getConfig()Returns the configuration this job was submitted with.Job.updateConfig(DeltaJobConfig deltaConfig) Applies the specified delta configuration to asuspendedjob and returns the updated configuration.Methods in com.hazelcast.jet with parameters of type JobConfigModifier and TypeMethodDescriptionCreates and returns a Jet job based on the supplied DAG and job configuration.Creates and returns a Jet job based on the supplied pipeline and job configuration.JetService.newJobIfAbsent(DAG dag, JobConfig config) Creates and returns a Jet job based on the supplied DAG and job configuration.JetService.newJobIfAbsent(Pipeline pipeline, JobConfig config) Creates and returns a Jet job based on the supplied pipeline and job configuration.JetService.newLightJob(DAG dag, JobConfig config) Submits a job defined in the Core API.JetService.newLightJob(Pipeline pipeline, JobConfig config) Submits a light job for execution.JetService.JobBuilder.withConfig(JobConfig jobConfig) SeeJobConfigfor details. -
Uses of JobConfig in com.hazelcast.jet.config
Methods in com.hazelcast.jet.config that return JobConfigModifier and TypeMethodDescriptionAdds the given classes and recursively all their nested (inner & anonymous) classes to the Jet job's classpath.JobConfig.addClasspathResource(File file) Adds a file that will be available as a resource on the Jet job's classpath.JobConfig.addClasspathResource(File file, String id) Adds a file that will be available as a resource on the Jet job's classpath.JobConfig.addClasspathResource(String path) Adds a file that will be available as a resource on the Jet job's classpath.JobConfig.addClasspathResource(String path, String id) Adds a file that will be available as a resource on the Jet job's classpath.JobConfig.addClasspathResource(URL url) Adds a resource that will be available on the Jet job's classpath.JobConfig.addClasspathResource(URL url, String id) Adds a resource that will be available on the Jet job's classpath.JobConfig.addCustomClasspath(String name, String path) Adds custom classpath element to a stage with the given name.JobConfig.addCustomClasspaths(String name, List<String> paths) Adds custom classpath elements to a stage with the given name.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.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.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.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.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.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.addPackage(String... packages) Adds recursively all the classes and resources in given packages to the Jet job's classpath.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.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.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.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.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.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.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.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.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.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.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.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.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.setArgument(String key, Object value) Associates the specified value with the specified key.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.setClassLoaderFactory(JobClassLoaderFactory classLoaderFactory) Sets a customJobClassLoaderFactorythat will be used to load job classes and resources on Jet members.JobConfig.setInitialSnapshotName(String initialSnapshotName) Sets the exported state snapshot name to restore the initial job state from.JobConfig.setMaxProcessorAccumulatedRecords(long maxProcessorAccumulatedRecords) Sets the maximum number of records that can be accumulated by any singleProcessorinstance in the context of the job.JobConfig.setMetricsEnabled(boolean enabled) Sets whether metrics collection should be enabled for the job.Sets the name of the job.JobConfig.setProcessingGuarantee(ProcessingGuarantee processingGuarantee) Set theprocessing guaranteefor the job.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.setSplitBrainProtection(boolean isEnabled) Configures the split brain protection feature.JobConfig.setStoreMetricsAfterJobCompletion(boolean storeMetricsAfterJobCompletion) Sets whether metrics should be stored in the cluster after the job completes.JobConfig.setSuspendOnFailure(boolean suspendOnFailure) Sets what happens if the job execution fails: If enabled, the job will be suspended.JobConfig.setTimeoutMillis(long timeoutMillis) Sets the maximum execution time for the job in milliseconds.Methods in com.hazelcast.jet.config with parameters of type JobConfig -
Uses of JobConfig in com.hazelcast.jet.core
Methods in com.hazelcast.jet.core that return JobConfig -
Uses of JobConfig in com.hazelcast.jet.core.test
Methods in com.hazelcast.jet.core.test that return JobConfigMethods in com.hazelcast.jet.core.test with parameters of type JobConfigModifier and TypeMethodDescriptionUse the given instance forProcessorMetaSupplier.Context.jobConfig()TestProcessorContext.setJobConfig(JobConfig jobConfig) TestProcessorMetaSupplierContext.setJobConfig(JobConfig jobConfig) Sets the config for the job.TestProcessorSupplierContext.setJobConfig(JobConfig jobConfig)