com.hazelcast.jet.config

Class InstanceConfig

java.lang.Object

com.hazelcast.jet.config.InstanceConfig

public class InstanceConfig
extends Object

General configuration options pertaining to a Jet instance.

Field Summary

Fields

Modifier and Type	Field and Description
static int	DEFAULT_BACKUP_COUNT The default value of the backup-count
static int	DEFAULT_FLOW_CONTROL_PERIOD_MS The default value of the flow-control period.

Constructor Summary

Constructors

Constructor and Description
InstanceConfig()

Method Summary

Modifier and Type	Method and Description
int	getBackupCount() Returns the backup-count used for job metadata and snapshots
int	getCooperativeThreadCount() Returns the number of cooperative execution threads.
int	getFlowControlPeriodMs() Returns the flow-control period in milliseconds.
String	getTempDir() Returns Jet's temp directory.
InstanceConfig	setBackupCount(int newBackupCount) Sets the number of synchronous backups for storing job metadata and snapshots.
InstanceConfig	setCooperativeThreadCount(int size) Sets the number of threads each cluster member will use to execute Jet jobs.
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	setTempDir(String tempDir) Sets the directory where Jet can place its temporary working directories.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

DEFAULT_FLOW_CONTROL_PERIOD_MS

public static final int DEFAULT_FLOW_CONTROL_PERIOD_MS

The default value of the flow-control period.

See Also:

Constant Field Values

DEFAULT_BACKUP_COUNT

public static final int DEFAULT_BACKUP_COUNT

The default value of the backup-count

See Also:

Constant Field Values

Constructor Detail

InstanceConfig

public InstanceConfig()

Method Detail

setCooperativeThreadCount

public InstanceConfig setCooperativeThreadCount(int size)

Sets the number of threads each cluster member will use to execute Jet jobs. This refers only to threads executing cooperative processors; each blocking processor is assigned its own thread.

getCooperativeThreadCount

public int getCooperativeThreadCount()

Returns the number of cooperative execution threads.

setTempDir

public InstanceConfig setTempDir(String tempDir)

Sets the directory where Jet can place its temporary working directories.

getTempDir

@Nonnull
public String getTempDir()

Returns Jet's temp directory. Defaults to java.io.tmpdir system property.

setFlowControlPeriodMs

public 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. The receiver will regularly report to each sender how much more data it is allowed to send over a given DAG edge. This method sets the length (in milliseconds) of the interval between flow-control ("ack") packets.

getFlowControlPeriodMs

public int getFlowControlPeriodMs()

Returns the flow-control period in milliseconds.

setBackupCount

public InstanceConfig setBackupCount(int newBackupCount)

Sets the number of synchronous backups for storing job metadata and snapshots. Maximum allowed value is 6, default value is 1.

For example, if backup count is set to 2, all job metadata and snapshot data will be replicated to two other members. If snapshots are enabled in the case that at most two members fail simultaneously the job can be restarted and continued from latest snapshot.

getBackupCount

public int getBackupCount()

Returns the backup-count used for job metadata and snapshots