Package | Description |
---|---|
com.hazelcast.jet.config |
Jet's configuration data objects.
|
Modifier and Type | Method and Description |
---|---|
InstanceConfig |
JetConfig.getInstanceConfig()
Returns the Jet instance config.
|
InstanceConfig |
InstanceConfig.setBackupCount(int newBackupCount)
Sets the number of backups that Jet will maintain for the job metadata
and snapshots.
|
InstanceConfig |
InstanceConfig.setCooperativeThreadCount(int size)
Sets the number of threads each cluster member will use to execute Jet
jobs.
|
InstanceConfig |
InstanceConfig.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.
|
InstanceConfig |
InstanceConfig.setLosslessRestartEnabled(boolean enabled)
Sets whether lossless job restart is enabled for the node.
|
InstanceConfig |
InstanceConfig.setScaleUpDelayMillis(long millis)
Sets the delay after which auto-scaled jobs will restart if a new member
is added to the cluster.
|
Modifier and Type | Method and Description |
---|---|
JetConfig |
JetConfig.setInstanceConfig(InstanceConfig instanceConfig)
Sets the Jet instance config.
|
Copyright © 2021 Hazelcast, Inc.. All rights reserved.