com.hazelcast.jet.config

Class JetConfig

java.lang.Object

com.hazelcast.config.Config

com.hazelcast.jet.config.JetConfig

public class JetConfig
extends com.hazelcast.config.Config

Extension of Hazelcast member configuration with Jet specific additions.

Field Summary

Fields

Modifier and Type	Field and Description
static int	DEFAULT_SECONDS_TO_AWAIT Represents default value for any futures in system

Constructor Summary

Constructors

Constructor and Description
JetConfig() Constructs an empty config

Method Summary

Modifier and Type	Method and Description
JetConfig	addApplicationConfig(ApplicationConfig config) Sets the configuration for a given application
ApplicationConfig	getApplicationConfig(String name) Gets the configuration for a given application name
int	getIoThreadCount() Gets the number of I/O threads to use
int	getPort() Gets the port which Jet listens on
int	getProcessingThreadCount() Gets the number of processing threads to use
int	getShutdownTimeoutSeconds() Gets the timeout to use when shutting down threads
JetConfig	setIoThreadCount(int count) Sets the number of I/O threads to use
JetConfig	setPort(int port) Sets the port which Jet listens on
JetConfig	setProcessingThreadCount(int count) Sets the number of processing threads to use
JetConfig	setShutdownTimeoutSeconds(int seconds) Sets the timeout to use when shutting down threads

Methods inherited from class com.hazelcast.config.Config

addCacheConfig, addExecutorConfig, addJobTrackerConfig, addListConfig, addListenerConfig, addMapConfig, addMultiMapConfig, addQueueConfig, addQuorumConfig, addReliableTopicConfig, addReplicatedMapConfig, addRingBufferConfig, addSemaphoreConfig, addSetConfig, addTopicConfig, addWanReplicationConfig, findCacheConfig, findExecutorConfig, findJobTrackerConfig, findListConfig, findMapConfig, findMultiMapConfig, findQueueConfig, findQuorumConfig, findReliableTopicConfig, findReplicatedMapConfig, findRingbufferConfig, findSemaphoreConfig, findSetConfig, findTopicConfig, getCacheConfig, getCacheConfigs, getClassLoader, getConfigPatternMatcher, getConfigurationFile, getConfigurationUrl, getExecutorConfig, getExecutorConfigs, getGroupConfig, getHotRestartPersistenceConfig, getInstanceName, getJobTrackerConfig, getJobTrackerConfigs, getLicenseKey, getListConfig, getListConfigs, getListenerConfigs, getManagedContext, getManagementCenterConfig, getMapConfig, getMapConfigs, getMemberAttributeConfig, getMultiMapConfig, getMultiMapConfigs, getNativeMemoryConfig, getNetworkConfig, getPartitionGroupConfig, getProperties, getProperty, getProperty, getQueueConfig, getQueueConfigs, getQuorumConfig, getQuorumConfigs, getReliableTopicConfig, getReliableTopicConfigs, getReplicatedMapConfig, getReplicatedMapConfigs, getRingbufferConfig, getRingbufferConfigs, getSecurityConfig, getSemaphoreConfig, getSemaphoreConfigs, getSerializationConfig, getServicesConfig, getSetConfig, getSetConfigs, getTopicConfig, getTopicConfigs, getUserContext, getWanReplicationConfig, getWanReplicationConfigs, isCompatible, isLiteMember, setCacheConfigs, setClassLoader, setConfigPatternMatcher, setConfigurationFile, setConfigurationUrl, setExecutorConfigs, setGroupConfig, setHotRestartPersistenceConfig, setInstanceName, setJobTrackerConfigs, setLicenseKey, setListConfigs, setListenerConfigs, setLiteMember, setManagedContext, setManagementCenterConfig, setMapConfigs, setMemberAttributeConfig, setMultiMapConfigs, setNativeMemoryConfig, setNetworkConfig, setPartitionGroupConfig, setProperties, setProperty, setProperty, setQueueConfigs, setQuorumConfigs, setReplicatedMapConfigs, setSecurityConfig, setSemaphoreConfigs, setSerializationConfig, setServicesConfig, setSetConfigs, setTopicConfigs, setUserContext, setWanReplicationConfigs, toString

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_SECONDS_TO_AWAIT

public static final int DEFAULT_SECONDS_TO_AWAIT

Represents default value for any futures in system

See Also:

Constant Field Values

Constructor Detail

JetConfig

public JetConfig()

Constructs an empty config

Method Detail

getApplicationConfig

public ApplicationConfig getApplicationConfig(String name)

Gets the configuration for a given application name

Parameters:

name - name of the application

Returns:

the configuration for the application

addApplicationConfig

public JetConfig addApplicationConfig(ApplicationConfig config)

Sets the configuration for a given application

Parameters:

config - name of the application

Returns:

the configuration for the application

getProcessingThreadCount

public int getProcessingThreadCount()

Gets the number of processing threads to use

Returns:

the number of processing threads to use

setProcessingThreadCount

public JetConfig setProcessingThreadCount(int count)

Sets the number of processing threads to use

Parameters:

count - the number of processing threads

Returns:

the current configuration

getIoThreadCount

public int getIoThreadCount()

Gets the number of I/O threads to use

Returns:

the number of I/O threads

setIoThreadCount

public JetConfig setIoThreadCount(int count)

Sets the number of I/O threads to use

Parameters:

count - the number of I/O threads

Returns:

the current configuration

getShutdownTimeoutSeconds

public int getShutdownTimeoutSeconds()

Gets the timeout to use when shutting down threads

Returns:

the timeout in seconds

setShutdownTimeoutSeconds

public JetConfig setShutdownTimeoutSeconds(int seconds)

Sets the timeout to use when shutting down threads

Returns:

the current configuration

getPort

public int getPort()

Gets the port which Jet listens on

Returns:

the port which Jet listens on

setPort

public JetConfig setPort(int port)

Sets the port which Jet listens on

Parameters:

port - the port which Jet listens on

Returns:

the current configuration