Modifier and Type | Field and Description |
---|---|
static int |
DEFAULT_BACKUP_COUNT
Deprecated.
The default value of the
backup-count |
static int |
DEFAULT_FLOW_CONTROL_PERIOD_MS
Deprecated.
The default value of the
flow-control period . |
Constructor and Description |
---|
InstanceConfig()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
boolean |
equals(Object o)
Deprecated.
|
int |
getBackupCount()
Deprecated.
Returns the
number of backups used for job
metadata and snapshots. |
int |
getCooperativeThreadCount()
Deprecated.
Returns the number of cooperative execution threads.
|
int |
getFlowControlPeriodMs()
Deprecated.
Returns the
flow-control period in
milliseconds. |
long |
getMaxProcessorAccumulatedRecords()
Deprecated.
Returns the maximum number of records that can be accumulated by any single
Processor instance. |
long |
getScaleUpDelayMillis()
Deprecated.
Returns the scale-up delay, see
setScaleUpDelayMillis(long) . |
int |
hashCode()
Deprecated.
|
boolean |
isLosslessRestartEnabled()
Deprecated.
Returns if lossless restart is enabled, see
setLosslessRestartEnabled(boolean) . |
InstanceConfig |
setBackupCount(int newBackupCount)
Deprecated.
Sets the number of backups that Jet will maintain for the job metadata
and snapshots.
|
InstanceConfig |
setCooperativeThreadCount(int size)
Deprecated.
Sets the number of threads each cluster member will use to execute Jet
jobs.
|
InstanceConfig |
setFlowControlPeriodMs(int flowControlPeriodMs)
Deprecated.
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 |
setLosslessRestartEnabled(boolean enabled)
Deprecated.
Sets whether lossless job restart is enabled for the node.
|
InstanceConfig |
setMaxProcessorAccumulatedRecords(long maxProcessorAccumulatedRecords)
Deprecated.
Sets the maximum number of records that can be accumulated by any single
Processor instance. |
InstanceConfig |
setScaleUpDelayMillis(long millis)
Deprecated.
Sets the delay after which auto-scaled jobs will restart if a new member
is added to the cluster.
|
public static final int DEFAULT_FLOW_CONTROL_PERIOD_MS
flow-control period
.public static final int DEFAULT_BACKUP_COUNT
backup-count
@Nonnull public InstanceConfig setCooperativeThreadCount(int size)
public int getCooperativeThreadCount()
@Nonnull public InstanceConfig setFlowControlPeriodMs(int flowControlPeriodMs)
public int getFlowControlPeriodMs()
flow-control period
in
milliseconds.@Nonnull public InstanceConfig setBackupCount(int newBackupCount)
For example, if you set the backup count to 2, Jet will replicate all the job metadata and snapshot data to two other members. If one or two members of the cluster fail, Jet can recover the data from the snapshot and continue executing the job on the remaining members without loss.
public int getBackupCount()
number of backups
used for job
metadata and snapshots.public InstanceConfig setScaleUpDelayMillis(long millis)
millis
- the delay, in millisecondspublic long getScaleUpDelayMillis()
setScaleUpDelayMillis(long)
.public boolean isLosslessRestartEnabled()
setLosslessRestartEnabled(boolean)
.public InstanceConfig setLosslessRestartEnabled(boolean enabled)
If enabled, you have to also configure Hot Restart:
JetConfig jetConfig = new JetConfig();
jetConfig.getInstanceConfig().setLosslessRestartEnabled(true);
jetConfig.getHazelcastConfig().getHotRestartPersistenceConfig()
.setEnabled(true)
.setBaseDir(new File("/mnt/hot-restart"))
.setParallelism(2);
Note: the snapshots exported using Job.exportSnapshot(java.lang.String)
will also have Hot Restart storage enabled.
Feature is disabled by default. If you enable this option in open-source Hazelcast Jet, the member will fail to start, you need Jet Enterprise to run it and obtain a license from Hazelcast.
public InstanceConfig setMaxProcessorAccumulatedRecords(long maxProcessorAccumulatedRecords)
Processor
instance.
Operations like grouping, sorting or joining require certain amount of
records to be accumulated before they can proceed. You can set this option
to reduce the probability of OutOfMemoryError
.
This option applies to each Processor
instance separately, hence the
effective limit of records accumulated by each cluster member is influenced
by the vertex's localParallelism
and the number of jobs in the cluster.
Currently, maxProcessorAccumulatedRecords
limits:
Note: the limit does not apply to streaming aggregations.
The default value is Long.MAX_VALUE
.
public long getMaxProcessorAccumulatedRecords()
Processor
instance.Copyright © 2023 Hazelcast, Inc.. All rights reserved.