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_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	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	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 files.

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

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 files.

getTempDir

public String getTempDir()

Returns Jet's temp directory.

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.