Uses of Class
com.hazelcast.jet.config.JetConfig
Package
Description
Provides classes for configuring HazelcastInstance.
Hazelcast Jet is a distributed computation engine running on top of
Hazelcast IMDG technology.
Jet's configuration data objects.
-
Uses of JetConfig in com.hazelcast.config
-
Uses of JetConfig in com.hazelcast.jet
Modifier and TypeMethodDescriptionJetService.getConfig()
Returns the configuration for this Jet member.Modifier and TypeMethodDescriptionstatic JetInstance
Jet.newJetInstance
(JetConfig config) Deprecated. -
Uses of JetConfig in com.hazelcast.jet.config
Modifier and TypeMethodDescriptionJetConfig.setBackupCount
(int newBackupCount) Sets the number of backups that Jet will maintain for the job metadata and snapshots.JetConfig.setCooperativeThreadCount
(int size) Sets the number of threads each cluster member will use to execute Jet jobs.JetConfig.setDefaultEdgeConfig
(EdgeConfig defaultEdgeConfig) Sets the configuration object that specifies the defaults to use for a DAG edge configuration.JetConfig.setEnabled
(boolean enabled) Sets if Jet is enabledJetConfig.setFlowControlPeriodMs
(int flowControlPeriodMs) While executing a Jet job there is the issue of regulating the rate at which one member of the cluster sends data to another member.JetConfig.setInstanceConfig
(InstanceConfig instanceConfig) Deprecated.The fields fromInstanceConfig
class were moved toJetConfig
class.JetConfig.setLosslessRestartEnabled
(boolean enabled) Sets whether lossless job restart is enabled for the node.JetConfig.setMaxProcessorAccumulatedRecords
(long maxProcessorAccumulatedRecords) Sets the maximum number of records that can be accumulated by any singleProcessor
instance.JetConfig.setResourceUploadEnabled
(boolean resourceUploadEnabled) Sets if uploading resources when submitting the job enabledJetConfig.setScaleUpDelayMillis
(long millis) Sets the delay after which auto-scaled jobs will restart if a new member is added to the cluster.
Hazelcast.newHazelcastInstance(Config)
and then getJetService
from the createdHazelcastInstance
by usingHazelcastInstance.getJet()
}.