public class IgniteConfiguration extends Object
Ignition.start(IgniteConfiguration)
method. It defines all configuration
parameters required to start a grid instance. Usually, a special
class called "loader" will create an instance of this interface and apply
Ignition.start(IgniteConfiguration)
method to initialize Ignite instance.
Note that you should only set values that differ from defaults, as grid will automatically pick default values for all values that are not set.
For more information about grid configuration and startup refer to Ignition
documentation.
Modifier and Type | Field and Description |
---|---|
static int |
AVAILABLE_PROC_CNT
Default core size of public thread pool.
|
static String |
COURTESY_LOGGER_NAME
Courtesy notice log category.
|
static boolean |
DFLT_ACTIVE_ON_START
Deprecated.
|
static boolean |
DFLT_ALL_SEG_RESOLVERS_PASS_REQ
Default value for all segmentation resolvers pass required.
|
static boolean |
DFLT_AUTO_ACTIVATION
Deprecated.
|
static int |
DFLT_BUILD_IDX_THREAD_POOL_SIZE
Default size of index create/rebuild thread pool.
|
static boolean |
DFLT_CACHE_SANITY_CHECK_ENABLED
Default value for cache sanity check enabled flag.
|
static Long |
DFLT_CLIENT_FAILURE_DETECTION_TIMEOUT
Default failure detection timeout for client nodes in millis.
|
static int |
DFLT_DATA_STREAMER_POOL_SIZE
Default size of data streamer thread pool.
|
static DeploymentMode |
DFLT_DEPLOYMENT_MODE
Default deployment mode (value is
DeploymentMode.SHARED ). |
static long |
DFLT_DISCOVERY_STARTUP_DELAY
Default discovery startup delay in milliseconds (value is
60,000ms ). |
static Long |
DFLT_FAILURE_DETECTION_TIMEOUT
Default failure detection timeout in millis.
|
static boolean |
DFLT_LATE_AFF_ASSIGNMENT
Deprecated.
|
static long |
DFLT_LONG_QRY_WARN_TIMEOUT
Deprecated.
Please use
SqlConfiguration.DFLT_LONG_QRY_WARN_TIMEOUT . |
static boolean |
DFLT_MARSHAL_LOCAL_JOBS
Default marshal local jobs flag.
|
static long |
DFLT_METRICS_EXPIRE_TIME
Default metrics expire time.
|
static int |
DFLT_METRICS_HISTORY_SIZE
Default metrics history size (value is
10000 ). |
static long |
DFLT_METRICS_LOG_FREQ
Default frequency of metrics log print out.
|
static long |
DFLT_METRICS_UPDATE_FREQ
Default metrics update frequency.
|
static int |
DFLT_MGMT_THREAD_CNT
Default size of management thread pool.
|
static long |
DFLT_MVCC_VACUUM_FREQUENCY
Default time interval between MVCC vacuum runs in milliseconds.
|
static int |
DFLT_MVCC_VACUUM_THREAD_CNT
Default number of MVCC vacuum threads..
|
static int |
DFLT_NETWORK_COMPRESSION
Default compression level for network messages (value is Deflater.BEST_SPEED.
|
static long |
DFLT_NETWORK_TIMEOUT
Default maximum timeout to wait for network responses in milliseconds (value is
5,000ms ). |
static boolean |
DFLT_P2P_ENABLED
Default flag for peer class loading.
|
static int |
DFLT_P2P_MISSED_RESOURCES_CACHE_SIZE
Default cache size for missed resources.
|
static int |
DFLT_P2P_THREAD_CNT
Default size of peer class loading thread pool.
|
static int |
DFLT_PUBLIC_THREAD_CNT
Default core size of public thread pool.
|
static int |
DFLT_QUERY_THREAD_POOL_SIZE
Default size of query thread pool.
|
static int |
DFLT_REBALANCE_BATCH_SIZE
Default rebalance batch size in bytes (value is
512Kb ). |
static long |
DFLT_REBALANCE_BATCHES_PREFETCH_COUNT
Default rebalance batches prefetch count (value is
2 ). |
static int |
DFLT_REBALANCE_THREAD_POOL_SIZE
Default limit of threads used for rebalance.
|
static long |
DFLT_REBALANCE_THROTTLE
Time to wait between rebalance messages in milliseconds to avoid overloading CPU (value is
0 ). |
static long |
DFLT_REBALANCE_TIMEOUT
Default rebalance message timeout in milliseconds (value is
10000 ). |
static long |
DFLT_SEG_CHK_FREQ
Default segment check frequency in discovery manager.
|
static SegmentationPolicy |
DFLT_SEG_PLC
Default segmentation policy.
|
static int |
DFLT_SEG_RESOLVE_ATTEMPTS
Default value segmentation resolve attempts count.
|
static int |
DFLT_SEND_RETRY_CNT
Default message send retries count.
|
static long |
DFLT_SEND_RETRY_DELAY
Default interval between message send retries.
|
static ShutdownPolicy |
DFLT_SHUTDOWN_POLICY
Default policy for node shutdown.
|
static String |
DFLT_SQL_QUERY_GLOBAL_MEMORY_QUOTA
Deprecated.
|
static int |
DFLT_SQL_QUERY_HISTORY_SIZE
Deprecated.
Please use
SqlConfiguration.DFLT_SQL_QUERY_HISTORY_SIZE . |
static String |
DFLT_SQL_QUERY_MEMORY_QUOTA
Deprecated.
Please use
SqlConfiguration.DFLT_SQL_QUERY_MEMORY_QUOTA . |
static boolean |
DFLT_SQL_QUERY_OFFLOADING_ENABLED
Deprecated.
|
static ClusterState |
DFLT_STATE_ON_START
Default value for cluster state on start.
|
static Long |
DFLT_SYS_WORKER_BLOCKED_TIMEOUT
Default system worker blocked timeout in millis.
|
static int |
DFLT_SYSTEM_CORE_THREAD_CNT
Default size of system thread pool.
|
static int |
DFLT_TCP_PORT
Default TCP server port.
|
static long |
DFLT_THREAD_KEEP_ALIVE_TIME
Default Ignite thread keep alive time.
|
static int |
DFLT_TIME_SERVER_PORT_BASE
Default time server port base.
|
static int |
DFLT_TIME_SERVER_PORT_RANGE
Default time server port range.
|
static boolean |
DFLT_WAIT_FOR_SEG_ON_START
Default value for wait for segment on startup flag.
|
ShutdownPolicy |
shutdown
Shutdown policy for cluster.
|
Constructor and Description |
---|
IgniteConfiguration()
Creates valid grid configuration with all default values.
|
IgniteConfiguration(IgniteConfiguration cfg)
Creates grid configuration by coping all configuration properties from
given configuration.
|
Modifier and Type | Method and Description |
---|---|
AddressResolver |
getAddressResolver()
Gets address resolver for addresses mapping determination.
|
int |
getAsyncCallbackPoolSize()
Size of thread pool that is in charge of processing asynchronous callbacks.
|
Executor |
getAsyncContinuationExecutor()
Gets the continuation executor for cache async APIs.
|
AtomicConfiguration |
getAtomicConfiguration() |
BinaryConfiguration |
getBinaryConfiguration()
Gets configuration for Ignite Binary objects.
|
int |
getBuildIndexThreadPoolSize()
Size of thread pool for create/rebuild index.
|
CacheConfiguration[] |
getCacheConfiguration()
Gets configuration (descriptors) for all caches.
|
CacheKeyConfiguration[] |
getCacheKeyConfiguration()
Gets cache key configuration.
|
javax.cache.configuration.Factory<CacheStoreSessionListener>[] |
getCacheStoreSessionListenerFactories()
Gets cache store session listener factories.
|
CheckpointSpi[] |
getCheckpointSpi()
Should return fully configured checkpoint SPI implementation.
|
ClassLoader |
getClassLoader() |
ClientConnectorConfiguration |
getClientConnectorConfiguration()
Gets client connector configuration.
|
Long |
getClientFailureDetectionTimeout()
Returns failure detection timeout for client nodes used by
TcpDiscoverySpi and TcpCommunicationSpi . |
@Nullable ClusterState |
getClusterStateOnStart()
Gets state of cluster on start.
|
CollisionSpi |
getCollisionSpi()
Should return fully configured collision SPI implementation.
|
CommunicationFailureResolver |
getCommunicationFailureResolver() |
CommunicationSpi |
getCommunicationSpi()
Should return fully configured SPI communication implementation.
|
ConnectorConfiguration |
getConnectorConfiguration() |
Serializable |
getConsistentId()
Gets consistent globally unique node ID which survives node restarts.
|
DataStorageConfiguration |
getDataStorageConfiguration()
Gets page memory configuration.
|
int |
getDataStreamerThreadPoolSize()
Size of thread pool that is in charge of processing data stream messages.
|
DeploymentMode |
getDeploymentMode()
Gets deployment mode for deploying tasks and other classes on this node.
|
DeploymentSpi |
getDeploymentSpi()
Should return fully configured deployment SPI implementation.
|
DiscoverySpi |
getDiscoverySpi()
Should return fully configured discovery SPI implementation.
|
long |
getDiscoveryStartupDelay()
Deprecated.
Not used any more.
|
EncryptionSpi |
getEncryptionSpi()
Gets fully configured encryption SPI implementations.
|
EventStorageSpi |
getEventStorageSpi()
Should return fully configured event SPI implementation.
|
ExecutorConfiguration[] |
getExecutorConfiguration()
Gets custom executors for user compute tasks.
|
FailoverSpi[] |
getFailoverSpi()
Should return fully configured failover SPI implementation.
|
Long |
getFailureDetectionTimeout()
Returns failure detection timeout used by
TcpDiscoverySpi and TcpCommunicationSpi . |
FailureHandler |
getFailureHandler()
Gets failure handler.
|
IgniteLogger |
getGridLogger()
Should return an instance of logger to use in grid.
|
String |
getGridName()
Deprecated.
Use
getIgniteInstanceName() instead. |
String |
getIgniteHome()
Should return Ignite installation home folder.
|
String |
getIgniteInstanceName()
Gets optional node name.
|
int[] |
getIncludeEventTypes()
Gets array of event types, which will be recorded.
|
String[] |
getIncludeProperties()
Gets array of system or environment properties to include into node attributes.
|
IndexingSpi |
getIndexingSpi()
Should return fully configured indexing SPI implementations.
|
LifecycleBean[] |
getLifecycleBeans()
Returns a collection of life-cycle beans.
|
LoadBalancingSpi[] |
getLoadBalancingSpi()
Should return fully configured load balancing SPI implementation.
|
Map<IgnitePredicate<? extends Event>,int[]> |
getLocalEventListeners()
Gets map of pre-configured local event listeners.
|
String |
getLocalHost()
Gets system-wide local address or host for all Ignite components to bind to.
|
long |
getLongQueryWarningTimeout()
Deprecated.
Use
SqlConfiguration.getLongQueryWarningTimeout() instead. |
int |
getManagementThreadPoolSize()
Size of thread pool that is in charge of processing internal and Visor
GridJobs . |
Marshaller |
getMarshaller()
Deprecated.
Since 2.1. Some Ignite features will not work if non-null marshaller is set
(IgniteCache.withKeepBinary(), .NET, CPP, ODBC)
|
MBeanServer |
getMBeanServer()
Should return MBean server instance.
|
MemoryConfiguration |
getMemoryConfiguration()
Deprecated.
Use
DataStorageConfiguration instead. |
MetricExporterSpi[] |
getMetricExporterSpi()
Gets fully configured metric SPI implementations.
|
long |
getMetricsExpireTime()
Elapsed time in milliseconds after which node metrics are considered expired.
|
int |
getMetricsHistorySize()
Number of node metrics to keep in memory to calculate totals and averages.
|
long |
getMetricsLogFrequency()
Gets frequency of metrics log print out.
|
long |
getMetricsUpdateFrequency()
Gets Ignite metrics update frequency in milliseconds.
|
long |
getMvccVacuumFrequency()
This is an experimental feature.
|
int |
getMvccVacuumThreadCount()
This is an experimental feature.
|
int |
getNetworkCompressionLevel()
Compression level of internal network messages.
|
int |
getNetworkSendRetryCount()
Message send retries count.
|
long |
getNetworkSendRetryDelay()
Interval in milliseconds between message send retries.
|
long |
getNetworkTimeout()
Maximum timeout in milliseconds for network requests.
|
UUID |
getNodeId()
Deprecated.
|
OdbcConfiguration |
getOdbcConfiguration()
Deprecated.
Use
getClientConnectorConfiguration() ()} instead. |
String[] |
getPeerClassLoadingLocalClassPathExclude()
Should return list of packages from the system classpath that need to
be peer-to-peer loaded from task originating node.
'*' is supported at the end of the package name which means
that all sub-packages and their classes are included like in Java
package import clause.
|
int |
getPeerClassLoadingMissedResourcesCacheSize()
Returns missed resources cache size.
|
int |
getPeerClassLoadingThreadPoolSize()
Size of thread pool which is in charge of peer class loading requests/responses.
|
PersistentStoreConfiguration |
getPersistentStoreConfiguration()
Deprecated.
Part of old API. Use
DataStorageConfiguration for configuring persistence instead. |
PlatformConfiguration |
getPlatformConfiguration()
Gets platform configuration.
|
PluginConfiguration[] |
getPluginConfigurations()
Deprecated.
|
PluginProvider[] |
getPluginProviders()
Gets plugin providers.
|
int |
getPublicThreadPoolSize()
Should return a thread pool size to be used in grid.
|
int |
getQueryThreadPoolSize()
Size of thread pool that is in charge of processing query messages.
|
long |
getRebalanceBatchesPrefetchCount()
The number of batches generated by supply node at rebalancing procedure start.
|
int |
getRebalanceBatchSize()
The supply message size in bytes to be loaded within a single rebalance batch.
|
int |
getRebalanceThreadPoolSize()
Gets Max count of threads can be used at rebalancing.
|
long |
getRebalanceThrottle()
Time in milliseconds to wait between rebalance messages to avoid overloading of CPU or network.
|
long |
getRebalanceTimeout()
Rebalance timeout for supply and demand messages in milliseconds.
|
SegmentationPolicy |
getSegmentationPolicy()
Returns segmentation policy.
|
int |
getSegmentationResolveAttempts()
Gets segmentation resolve attempts.
|
SegmentationResolver[] |
getSegmentationResolvers()
Returns a collection of segmentation resolvers.
|
long |
getSegmentCheckFrequency()
Returns frequency of network segment check by discovery manager.
|
ServiceConfiguration[] |
getServiceConfiguration()
Gets configurations for services to be deployed on the grid.
|
int |
getServiceThreadPoolSize()
Should return a thread pool size to be used in grid.
|
ShutdownPolicy |
getShutdownPolicy()
Gets shutdown policy.
|
SqlConfiguration |
getSqlConfiguration()
Gets initial configuration of the SQL subsystem.
|
SqlConnectorConfiguration |
getSqlConnectorConfiguration()
Deprecated.
Use
getClientConnectorConfiguration() instead. |
String |
getSqlGlobalMemoryQuota()
Deprecated.
Use
SqlConfiguration.getSqlGlobalMemoryQuota() instead. |
int |
getSqlQueryHistorySize()
Deprecated.
Use
SqlConfiguration.getSqlQueryHistorySize() instead. |
String |
getSqlQueryMemoryQuota()
Deprecated.
Use
SqlConfiguration.getSqlQueryMemoryQuota() instead. |
String[] |
getSqlSchemas()
Deprecated.
Use
SqlConfiguration.getSqlSchemas() instead. |
javax.cache.configuration.Factory<SSLContext> |
getSslContextFactory()
Returns SSL context factory that will be used for creating a secure socket layer.
|
int |
getStripedPoolSize()
Returns striped pool size that should be used for cache requests
processing.
|
int |
getSystemThreadPoolSize()
Size of thread pool that is in charge of processing internal system messages.
|
SystemViewExporterSpi[] |
getSystemViewExporterSpi()
Gets fully configured system view SPI implementations.
|
Long |
getSystemWorkerBlockedTimeout()
Returns maximum inactivity period for system worker.
|
int |
getTimeServerPortBase()
Gets base UPD port number for grid time server.
|
int |
getTimeServerPortRange()
Defines port range to try for time server start.
|
TracingSpi |
getTracingSpi()
Gets fully configured tracing SPI implementation.
|
TransactionConfiguration |
getTransactionConfiguration()
Gets transactions configuration.
|
Map<String,?> |
getUserAttributes()
Should return any user-defined attributes to be added to this node.
|
long |
getUtilityCacheKeepAliveTime()
Keep alive time of thread pool that is in charge of processing utility cache messages.
|
int |
getUtilityCacheThreadPoolSize()
Default size of thread pool that is in charge of processing utility cache messages.
|
IgniteInClosure<IgniteConfiguration> |
getWarmupClosure()
Gets grid warmup closure.
|
String |
getWorkDirectory()
Gets Ignite work directory.
|
boolean |
isActiveOnStart()
Deprecated.
Use
getClusterStateOnStart() instead. |
boolean |
isAllSegmentationResolversPassRequired()
Gets all segmentation resolvers pass required flag.
|
boolean |
isAuthenticationEnabled()
Returns
true if user authentication is enabled for cluster. |
boolean |
isAutoActivationEnabled()
Deprecated.
Use
getClusterStateOnStart() instead. |
boolean |
isCacheSanityCheckEnabled()
Gets flag indicating whether cache sanity check is enabled.
|
Boolean |
isClientMode()
Gets client mode flag.
|
boolean |
isDaemon()
Whether or not this node should be a daemon node.
|
boolean |
isLateAffinityAssignment()
Deprecated.
Starting from Ignite 2.1 late affinity assignment is always enabled.
|
boolean |
isMarshalLocalJobs()
If this flag is set to
true , jobs mapped to local node will be
marshalled as if it was remote node. |
boolean |
isPeerClassLoadingEnabled()
Returns
true if peer class loading is enabled, false
otherwise. |
boolean |
isPersistentStoreEnabled()
Deprecated.
Part of legacy configuration API. Doesn't work if new configuration API is used.
|
boolean |
isSqlOffloadingEnabled()
Deprecated.
Use
SqlConfiguration.isSqlOffloadingEnabled() instead. |
boolean |
isWaitForSegmentOnStart()
Gets wait for segment on startup flag.
|
IgniteConfiguration |
setActiveOnStart(boolean activeOnStart)
Deprecated.
Use
setClusterStateOnStart(ClusterState) instead. |
IgniteConfiguration |
setAddressResolver(AddressResolver addrRslvr)
Sets address resolver for addresses mapping determination.
|
IgniteConfiguration |
setAllSegmentationResolversPassRequired(boolean allResolversPassReq)
Sets all segmentation resolvers pass required flag.
|
IgniteConfiguration |
setAsyncCallbackPoolSize(int poolSize)
Sets async callback thread pool size to use within grid.
|
IgniteConfiguration |
setAsyncContinuationExecutor(Executor asyncContinuationExecutor)
Sets the continuation executor for cache async APIs.
|
IgniteConfiguration |
setAtomicConfiguration(AtomicConfiguration atomicCfg) |
IgniteConfiguration |
setAuthenticationEnabled(boolean authEnabled)
Sets flag indicating whether the user authentication is enabled for cluster.
|
IgniteConfiguration |
setAutoActivationEnabled(boolean autoActivation)
Deprecated.
Use
setClusterStateOnStart(ClusterState) instead. |
IgniteConfiguration |
setBinaryConfiguration(BinaryConfiguration binaryCfg)
Sets configuration for Ignite Binary objects.
|
IgniteConfiguration |
setBuildIndexThreadPoolSize(int poolSize)
Sets index create/rebuild thread pool size to use within grid.
|
IgniteConfiguration |
setCacheConfiguration(CacheConfiguration... cacheCfg)
Sets cache configurations.
|
IgniteConfiguration |
setCacheKeyConfiguration(CacheKeyConfiguration... cacheKeyCfg)
Sets cache key configuration.
|
IgniteConfiguration |
setCacheSanityCheckEnabled(boolean cacheSanityCheckEnabled)
Sets cache sanity check flag.
|
IgniteConfiguration |
setCacheStoreSessionListenerFactories(javax.cache.configuration.Factory<CacheStoreSessionListener>... storeSesLsnrs)
Cache store session listener factories.
|
IgniteConfiguration |
setCheckpointSpi(CheckpointSpi... cpSpi)
Sets fully configured instance of
CheckpointSpi . |
IgniteConfiguration |
setClassLoader(ClassLoader classLdr)
Sets loader which will be used for instantiating execution context (
EntryProcessors ,
CacheEntryListeners , CacheLoaders and
ExpiryPolicys ). |
IgniteConfiguration |
setClientConnectorConfiguration(ClientConnectorConfiguration cliConnCfg)
Sets client connector configuration.
|
IgniteConfiguration |
setClientFailureDetectionTimeout(long clientFailureDetectionTimeout)
Sets failure detection timeout to use in
TcpDiscoverySpi and TcpCommunicationSpi . |
IgniteConfiguration |
setClientMode(boolean clientMode)
Sets client mode flag.
|
IgniteConfiguration |
setClusterStateOnStart(ClusterState state)
Sets state of cluster on start.
|
IgniteConfiguration |
setCollisionSpi(CollisionSpi colSpi)
Sets fully configured instance of
CollisionSpi . |
IgniteConfiguration |
setCommunicationFailureResolver(CommunicationFailureResolver commFailureRslvr) |
IgniteConfiguration |
setCommunicationSpi(CommunicationSpi commSpi)
Sets fully configured instance of
CommunicationSpi . |
IgniteConfiguration |
setConnectorConfiguration(ConnectorConfiguration connectorCfg) |
IgniteConfiguration |
setConsistentId(Serializable consistentId)
Sets consistent globally unique node ID which survives node restarts.
|
IgniteConfiguration |
setDaemon(boolean daemon)
Sets daemon flag.
|
IgniteConfiguration |
setDataStorageConfiguration(DataStorageConfiguration dsCfg)
Sets durable memory configuration.
|
IgniteConfiguration |
setDataStreamerThreadPoolSize(int poolSize)
Set thread pool size that will be used to process data stream messages.
|
IgniteConfiguration |
setDeploymentMode(DeploymentMode deployMode)
Sets task classes and resources sharing mode.
|
IgniteConfiguration |
setDeploymentSpi(DeploymentSpi deploySpi)
Sets fully configured instance of
DeploymentSpi . |
IgniteConfiguration |
setDiscoverySpi(DiscoverySpi discoSpi)
Sets fully configured instance of
DiscoverySpi . |
IgniteConfiguration |
setDiscoveryStartupDelay(long discoStartupDelay)
Deprecated.
Not used any more.
|
IgniteConfiguration |
setEncryptionSpi(EncryptionSpi encryptionSpi)
Sets fully configured instances of
EncryptionSpi . |
IgniteConfiguration |
setEventStorageSpi(EventStorageSpi evtSpi)
Sets fully configured instance of
EventStorageSpi . |
IgniteConfiguration |
setExecutorConfiguration(ExecutorConfiguration... execCfgs)
Sets custom executors for user compute tasks.
|
IgniteConfiguration |
setFailoverSpi(FailoverSpi... failSpi)
Sets fully configured instance of
FailoverSpi . |
IgniteConfiguration |
setFailureDetectionTimeout(long failureDetectionTimeout)
Sets failure detection timeout to use in
TcpDiscoverySpi and TcpCommunicationSpi . |
IgniteConfiguration |
setFailureHandler(FailureHandler failureHnd)
Sets failure handler.
|
IgniteConfiguration |
setGridLogger(IgniteLogger log)
Sets logger to use within grid.
|
IgniteConfiguration |
setGridName(String gridName)
Deprecated.
Use
setIgniteInstanceName(String) instead. |
IgniteConfiguration |
setIgniteHome(String igniteHome)
Sets Ignite installation folder.
|
IgniteConfiguration |
setIgniteInstanceName(String nodeName)
Sets node name.
|
IgniteConfiguration |
setIncludeEventTypes(int... inclEvtTypes)
Sets array of event types, which will be recorded by
GridEventStorageManager.record(Event) . |
IgniteConfiguration |
setIncludeProperties(String... includeProps)
Sets array of system or environment property names to include into node attributes.
|
IgniteConfiguration |
setIndexingSpi(IndexingSpi indexingSpi)
Sets fully configured instances of
IndexingSpi . |
IgniteConfiguration |
setLateAffinityAssignment(boolean lateAffAssignment)
Deprecated.
Starting from Ignite 2.1 late affinity assignment is always enabled.
|
IgniteConfiguration |
setLifecycleBeans(LifecycleBean... lifecycleBeans)
Sets a collection of lifecycle beans.
|
IgniteConfiguration |
setLoadBalancingSpi(LoadBalancingSpi... loadBalancingSpi)
Sets fully configured instance of
LoadBalancingSpi . |
IgniteConfiguration |
setLocalEventListeners(Map<IgnitePredicate<? extends Event>,int[]> lsnrs)
Sets map of pre-configured local event listeners.
|
IgniteConfiguration |
setLocalHost(String locHost)
Sets system-wide local address or host for all Ignite components to bind to.
|
IgniteConfiguration |
setLongQueryWarningTimeout(long longQryWarnTimeout)
Deprecated.
Use
SqlConfiguration.setLongQueryWarningTimeout(long) ()} instead. |
IgniteConfiguration |
setManagementThreadPoolSize(int poolSize)
Sets management thread pool size to use within grid.
|
IgniteConfiguration |
setMarshaller(Marshaller marsh)
Deprecated.
Since 2.1. Some Ignite features will not work if non-null marshaller is set
(IgniteCache.withKeepBinary(), .NET, CPP, ODBC)
|
IgniteConfiguration |
setMarshalLocalJobs(boolean marshLocJobs)
Sets marshal local jobs flag.
|
IgniteConfiguration |
setMBeanServer(MBeanServer mbeanSrv)
Sets initialized and started MBean server.
|
IgniteConfiguration |
setMemoryConfiguration(MemoryConfiguration memCfg)
Deprecated.
Use
DataStorageConfiguration instead. |
IgniteConfiguration |
setMetricExporterSpi(MetricExporterSpi... metricExporterSpi)
Sets fully configured instances of
MetricExporterSpi . |
IgniteConfiguration |
setMetricsExpireTime(long metricsExpTime)
Sets time in milliseconds after which a certain metric value is considered expired.
|
IgniteConfiguration |
setMetricsHistorySize(int metricsHistSize)
Sets number of metrics kept in history to compute totals and averages.
|
IgniteConfiguration |
setMetricsLogFrequency(long metricsLogFreq)
Sets frequency of metrics log print out.
|
IgniteConfiguration |
setMetricsUpdateFrequency(long metricsUpdateFreq)
Sets Ignite metrics update frequency in milliseconds.
|
IgniteConfiguration |
setMvccVacuumFrequency(long mvccVacuumFreq)
This is an experimental feature.
|
IgniteConfiguration |
setMvccVacuumThreadCount(int mvccVacuumThreadCnt)
This is an experimental feature.
|
void |
setNetworkCompressionLevel(int netCompressionLevel)
Compression level for internal network messages.
|
IgniteConfiguration |
setNetworkSendRetryCount(int sndRetryCnt)
Sets message send retries count.
|
IgniteConfiguration |
setNetworkSendRetryDelay(long sndRetryDelay)
Sets interval in milliseconds between message send retries.
|
IgniteConfiguration |
setNetworkTimeout(long netTimeout)
Maximum timeout in milliseconds for network requests.
|
IgniteConfiguration |
setNodeId(UUID nodeId)
Deprecated.
Use
setConsistentId(Serializable) instead. |
IgniteConfiguration |
setOdbcConfiguration(OdbcConfiguration odbcCfg)
Deprecated.
|
IgniteConfiguration |
setPeerClassLoadingEnabled(boolean p2pEnabled)
Enables/disables peer class loading.
|
IgniteConfiguration |
setPeerClassLoadingLocalClassPathExclude(String... p2pLocClsPathExcl)
Sets list of packages in a system class path that should be P2P
loaded even if they exist locally.
|
IgniteConfiguration |
setPeerClassLoadingMissedResourcesCacheSize(int p2pMissedCacheSize)
Sets size of missed resources cache.
|
IgniteConfiguration |
setPeerClassLoadingThreadPoolSize(int poolSize)
Sets thread pool size to use for peer class loading.
|
IgniteConfiguration |
setPersistentStoreConfiguration(PersistentStoreConfiguration pstCfg)
Deprecated.
Part of old API. Use
DataStorageConfiguration for configuring persistence instead. |
IgniteConfiguration |
setPlatformConfiguration(PlatformConfiguration platformCfg)
Sets platform configuration.
|
IgniteConfiguration |
setPluginConfigurations(PluginConfiguration... pluginCfgs)
Sets plugin configurations.
|
IgniteConfiguration |
setPluginProviders(PluginProvider... pluginProvs)
Sets plugin providers.
|
IgniteConfiguration |
setPublicThreadPoolSize(int poolSize)
Sets thread pool size to use within grid.
|
IgniteConfiguration |
setQueryThreadPoolSize(int poolSize)
Sets query thread pool size to use within grid.
|
IgniteConfiguration |
setRebalanceBatchesPrefetchCount(long rebalanceBatchesCnt)
The number of batches generated by supply node at rebalancing procedure start.
|
IgniteConfiguration |
setRebalanceBatchSize(int rebalanceBatchSize)
The supply message size in bytes to be loaded within a single rebalance batch.
|
IgniteConfiguration |
setRebalanceThreadPoolSize(int rebalanceThreadPoolSize)
Sets Max count of threads can be used at rebalancing.
|
IgniteConfiguration |
setRebalanceThrottle(long rebalanceThrottle)
Time in milliseconds to wait between rebalance messages to avoid overloading of CPU or network.
|
IgniteConfiguration |
setRebalanceTimeout(long rebalanceTimeout)
Rebalance timeout for supply and demand messages in milliseconds.
|
IgniteConfiguration |
setSegmentationPolicy(SegmentationPolicy segPlc)
Sets segmentation policy.
|
IgniteConfiguration |
setSegmentationResolveAttempts(int segResolveAttempts)
Sets segmentation resolve attempts count.
|
IgniteConfiguration |
setSegmentationResolvers(SegmentationResolver... segResolvers)
Sets segmentation resolvers.
|
IgniteConfiguration |
setSegmentCheckFrequency(long segChkFreq)
Sets network segment check frequency.
|
IgniteConfiguration |
setServiceConfiguration(ServiceConfiguration... svcCfgs)
Sets configurations for services to be deployed on the grid.
|
IgniteConfiguration |
setServiceThreadPoolSize(int poolSize)
Sets thread pool size to use within grid.
|
IgniteConfiguration |
setShutdownPolicy(ShutdownPolicy shutdownPolicy)
Sets shutdown policy.
|
IgniteConfiguration |
setSqlConfiguration(SqlConfiguration sqlInitCfg) |
IgniteConfiguration |
setSqlConnectorConfiguration(SqlConnectorConfiguration sqlConnCfg)
Deprecated.
|
IgniteConfiguration |
setSqlGlobalMemoryQuota(String size)
Deprecated.
Use
SqlConfiguration.setSqlGlobalMemoryQuota(String) instead. |
IgniteConfiguration |
setSqlOffloadingEnabled(boolean offloadingEnabled)
Deprecated.
Use
SqlConfiguration.setSqlOffloadingEnabled(boolean) instead. |
IgniteConfiguration |
setSqlQueryHistorySize(int size)
Deprecated.
Use
SqlConfiguration.getSqlQueryHistorySize() instead. |
IgniteConfiguration |
setSqlQueryMemoryQuota(String size)
Deprecated.
Use
SqlConfiguration.setSqlQueryMemoryQuota(String) instead. |
IgniteConfiguration |
setSqlSchemas(String... sqlSchemas)
Deprecated.
Use
SqlConfiguration.setSqlSchemas(String...) instead. |
IgniteConfiguration |
setSslContextFactory(javax.cache.configuration.Factory<SSLContext> sslCtxFactory)
Sets SSL context factory that will be used for creating a secure socket layer.
|
IgniteConfiguration |
setStripedPoolSize(int stripedPoolSize)
Sets striped pool size that should be used for cache requests
processing.
|
IgniteConfiguration |
setSystemThreadPoolSize(int poolSize)
Sets system thread pool size to use within grid.
|
IgniteConfiguration |
setSystemViewExporterSpi(SystemViewExporterSpi... sysViewExporterSpi)
Sets fully configured instances of
SystemViewExporterSpi . |
IgniteConfiguration |
setSystemWorkerBlockedTimeout(long sysWorkerBlockedTimeout)
Sets maximum inactivity period for system worker.
|
IgniteConfiguration |
setTimeServerPortBase(int timeSrvPortBase)
Sets time server port base.
|
IgniteConfiguration |
setTimeServerPortRange(int timeSrvPortRange)
Sets time server port range.
|
IgniteConfiguration |
setTracingSpi(TracingSpi tracingSpi)
Set fully configured instance of
TracingSpi . |
IgniteConfiguration |
setTransactionConfiguration(TransactionConfiguration txCfg)
Sets transactions configuration.
|
IgniteConfiguration |
setUserAttributes(Map<String,?> userAttrs)
Sets user attributes for this node.
|
IgniteConfiguration |
setUtilityCacheKeepAliveTime(long keepAliveTime)
Sets keep alive time of thread pool size that will be used to process utility cache messages.
|
IgniteConfiguration |
setUtilityCachePoolSize(int poolSize)
Sets default thread pool size that will be used to process utility cache messages.
|
IgniteConfiguration |
setWaitForSegmentOnStart(boolean waitForSegOnStart)
Sets wait for segment on start flag.
|
IgniteConfiguration |
setWarmupClosure(IgniteInClosure<IgniteConfiguration> warmupClos)
Sets warmup closure to execute before grid startup.
|
IgniteConfiguration |
setWorkDirectory(String igniteWorkDir)
Sets Ignite work folder.
|
String |
toString() |
public static final String COURTESY_LOGGER_NAME
public static final boolean DFLT_P2P_ENABLED
false
which means that peer class loading is disabled.public static final int DFLT_METRICS_HISTORY_SIZE
10000
).public static final long DFLT_METRICS_UPDATE_FREQ
public static final long DFLT_METRICS_EXPIRE_TIME
Long.MAX_VALUE
which
means that metrics never expire.public static final long DFLT_NETWORK_TIMEOUT
5,000ms
).public static final int DFLT_NETWORK_COMPRESSION
public static final long DFLT_SEND_RETRY_DELAY
public static final int DFLT_SEND_RETRY_CNT
public static final long DFLT_DISCOVERY_STARTUP_DELAY
60,000ms
).public static final DeploymentMode DFLT_DEPLOYMENT_MODE
DeploymentMode.SHARED
).public static final int DFLT_P2P_MISSED_RESOURCES_CACHE_SIZE
public static final int DFLT_TIME_SERVER_PORT_BASE
public static final int DFLT_TIME_SERVER_PORT_RANGE
public static final int AVAILABLE_PROC_CNT
public static final int DFLT_PUBLIC_THREAD_CNT
public static final int DFLT_DATA_STREAMER_POOL_SIZE
public static final int DFLT_REBALANCE_THREAD_POOL_SIZE
public static final long DFLT_REBALANCE_TIMEOUT
10000
).public static final long DFLT_REBALANCE_BATCHES_PREFETCH_COUNT
2
).public static final long DFLT_REBALANCE_THROTTLE
0
).public static final int DFLT_REBALANCE_BATCH_SIZE
512Kb
).public static final int DFLT_SYSTEM_CORE_THREAD_CNT
public static final int DFLT_QUERY_THREAD_POOL_SIZE
public static final int DFLT_BUILD_IDX_THREAD_POOL_SIZE
public static final long DFLT_THREAD_KEEP_ALIVE_TIME
public static final int DFLT_P2P_THREAD_CNT
public static final int DFLT_MGMT_THREAD_CNT
public static final SegmentationPolicy DFLT_SEG_PLC
public static final boolean DFLT_WAIT_FOR_SEG_ON_START
public static final boolean DFLT_ALL_SEG_RESOLVERS_PASS_REQ
public static final int DFLT_SEG_RESOLVE_ATTEMPTS
public static final long DFLT_SEG_CHK_FREQ
public static final long DFLT_METRICS_LOG_FREQ
public static final int DFLT_TCP_PORT
public static final boolean DFLT_MARSHAL_LOCAL_JOBS
public static final boolean DFLT_CACHE_SANITY_CHECK_ENABLED
@Deprecated public static final boolean DFLT_LATE_AFF_ASSIGNMENT
public static final ClusterState DFLT_STATE_ON_START
@Deprecated public static final boolean DFLT_ACTIVE_ON_START
@Deprecated public static final boolean DFLT_AUTO_ACTIVATION
public static final Long DFLT_FAILURE_DETECTION_TIMEOUT
public static final Long DFLT_SYS_WORKER_BLOCKED_TIMEOUT
public static final Long DFLT_CLIENT_FAILURE_DETECTION_TIMEOUT
public static final ShutdownPolicy DFLT_SHUTDOWN_POLICY
@Deprecated public static final long DFLT_LONG_QRY_WARN_TIMEOUT
SqlConfiguration.DFLT_LONG_QRY_WARN_TIMEOUT
.public static final int DFLT_MVCC_VACUUM_THREAD_CNT
public static final long DFLT_MVCC_VACUUM_FREQUENCY
@Deprecated public static final int DFLT_SQL_QUERY_HISTORY_SIZE
SqlConfiguration.DFLT_SQL_QUERY_HISTORY_SIZE
.@Deprecated public static final String DFLT_SQL_QUERY_GLOBAL_MEMORY_QUOTA
SqlConfiguration.DFLT_SQL_QUERY_GLOBAL_MEMORY_QUOTA
.@Deprecated public static final String DFLT_SQL_QUERY_MEMORY_QUOTA
SqlConfiguration.DFLT_SQL_QUERY_MEMORY_QUOTA
.@Deprecated public static final boolean DFLT_SQL_QUERY_OFFLOADING_ENABLED
SqlConfiguration.DFLT_SQL_QUERY_OFFLOADING_ENABLED
.public ShutdownPolicy shutdown
public IgniteConfiguration()
public IgniteConfiguration(IgniteConfiguration cfg)
cfg
- Grid configuration to copy from.public CommunicationFailureResolver getCommunicationFailureResolver()
public IgniteConfiguration setCommunicationFailureResolver(CommunicationFailureResolver commFailureRslvr)
commFailureRslvr
- Communication failure resovler.this
instance.@Deprecated public String getGridName()
getIgniteInstanceName()
instead.public String getIgniteInstanceName()
null
if it was not set.
The name only works locally and has no effect outside JVM.
null
, which is default.public boolean isDaemon()
Daemon nodes are the usual grid nodes that participate in topology but not
visible on the main APIs, i.e. they are not part of any cluster groups. The only
way to see daemon nodes is to use ClusterGroup.forDaemons()
method.
Daemon nodes are used primarily for management and monitoring functionality that is build on Ignite and needs to participate in the topology, but also needs to be excluded from the "normal" topology, so that it won't participate in the task execution or in-memory data grid storage.
True
if this node should be a daemon node, false
otherwise.ClusterGroup.forDaemons()
public IgniteConfiguration setDaemon(boolean daemon)
Daemon nodes are the usual grid nodes that participate in topology but not
visible on the main APIs, i.e. they are not part of any cluster group. The only
way to see daemon nodes is to use ClusterGroup.forDaemons()
method.
Daemon nodes are used primarily for management and monitoring functionality that is build on Ignite and needs to participate in the topology, but also needs to be excluded from the "normal" topology, so that it won't participate in the task execution or in-memory data grid storage.
daemon
- Daemon flag.this
for chaining.@Deprecated public IgniteConfiguration setGridName(String gridName)
setIgniteInstanceName(String)
instead.public IgniteConfiguration setIgniteInstanceName(String nodeName)
null
is a default node name.
This name will be widely used in all string constants (thread-names, JMX beans).
Also, it allows to get (check state, stop) node by name via Ignition
methods.nodeName
- Node name to set. Can be null
, which is default.this
for chaining.public IgniteConfiguration setConsistentId(Serializable consistentId)
consistentId
- Node consistent ID.this
for chaining.public Serializable getConsistentId()
public Map<String,?> getUserAttributes()
ClusterNode.attribute(String)
or
ClusterNode.attributes()
methods.
Note that system adds the following (among others) attributes automatically:
{@link System#getProperties()}
- All system properties.{@link System#getenv(String)}
- All environment properties.Note that grid will add all System properties and environment properties to grid node attributes also. SPIs may also add node attributes that are used for SPI implementation.
NOTE: attributes names starting with org.apache.ignite
are reserved
for internal use.
public IgniteConfiguration setUserAttributes(Map<String,?> userAttrs)
userAttrs
- User attributes for this node.this
for chaining.getUserAttributes()
public IgniteLogger getGridLogger()
Log4J2Logger
will be used.public IgniteConfiguration setGridLogger(IgniteLogger log)
log
- Logger to use within grid.this
for chaining.getGridLogger()
public int getStripedPoolSize()
Striped pool is better for typical cache operations.
getPublicThreadPoolSize()
,
getSystemThreadPoolSize()
public IgniteConfiguration setStripedPoolSize(int stripedPoolSize)
Striped pool is better for typical cache operations.
stripedPoolSize
- The number of threads (stripes) to be used for requests processing.this
for chaining.getPublicThreadPoolSize()
,
getSystemThreadPoolSize()
public int getPublicThreadPoolSize()
GridJobs
and user messages sent to node.
If not provided, executor service will have size DFLT_PUBLIC_THREAD_CNT
.
public int getServiceThreadPoolSize()
Service
proxy invocations.
If not provided, executor service will have size DFLT_PUBLIC_THREAD_CNT
.
public int getSystemThreadPoolSize()
If not provided, executor service will have size DFLT_SYSTEM_CORE_THREAD_CNT
.
public int getAsyncCallbackPoolSize()
This pool is used for callbacks annotated with IgniteAsyncCallback
.
If not provided, executor service will have size DFLT_PUBLIC_THREAD_CNT
.
IgniteAsyncCallback
public int getManagementThreadPoolSize()
GridJobs
.
If not provided, executor service will have size DFLT_MGMT_THREAD_CNT
public int getPeerClassLoadingThreadPoolSize()
1
.
If not provided, executor service will have size DFLT_P2P_THREAD_CNT
.
public int getDataStreamerThreadPoolSize()
If not provided, executor service will have size DFLT_DATA_STREAMER_POOL_SIZE
.
public int getUtilityCacheThreadPoolSize()
If not provided, executor service will have size DFLT_SYSTEM_CORE_THREAD_CNT
.
public long getUtilityCacheKeepAliveTime()
If not provided, executor service will have keep alive time DFLT_THREAD_KEEP_ALIVE_TIME
.
public int getQueryThreadPoolSize()
If not provided, executor service will have size DFLT_QUERY_THREAD_POOL_SIZE
.
public int getBuildIndexThreadPoolSize()
If not provided, executor service will have size
DFLT_BUILD_IDX_THREAD_POOL_SIZE
.
public IgniteConfiguration setBuildIndexThreadPoolSize(int poolSize)
poolSize
- Thread pool size to use within grid.this
for chaining.getBuildIndexThreadPoolSize()
@Deprecated public int getSqlQueryHistorySize()
SqlConfiguration.getSqlQueryHistorySize()
instead.SqlConfiguration.DFLT_SQL_QUERY_HISTORY_SIZE
is used. If provided value is less or equals 0, then gathering SQL query history
will be switched off.@Deprecated public IgniteConfiguration setSqlQueryHistorySize(int size)
SqlConfiguration.getSqlQueryHistorySize()
instead.SqlConfiguration.DFLT_SQL_QUERY_HISTORY_SIZE
.size
- Number of SQL query history elements kept in memory.this
for chaining.public ShutdownPolicy getShutdownPolicy()
IgniteCluster.DEFAULT_SHUTDOWN_POLICY
.public IgniteConfiguration setShutdownPolicy(ShutdownPolicy shutdownPolicy)
null
is passed as a parameter, policy will be set as default.shutdownPolicy
- Shutdown policy.this
for chaining.public IgniteConfiguration setPublicThreadPoolSize(int poolSize)
poolSize
- Thread pool size to use within grid.this
for chaining.getPublicThreadPoolSize()
public IgniteConfiguration setServiceThreadPoolSize(int poolSize)
poolSize
- Thread pool size to use within grid.this
for chaining.getServiceThreadPoolSize()
public IgniteConfiguration setSystemThreadPoolSize(int poolSize)
poolSize
- Thread pool size to use within grid.this
for chaining.getSystemThreadPoolSize()
public IgniteConfiguration setAsyncCallbackPoolSize(int poolSize)
poolSize
- Thread pool size to use within grid.this
for chaining.getAsyncCallbackPoolSize()
,
IgniteAsyncCallback
public IgniteConfiguration setManagementThreadPoolSize(int poolSize)
poolSize
- Thread pool size to use within grid.this
for chaining.getManagementThreadPoolSize()
public IgniteConfiguration setPeerClassLoadingThreadPoolSize(int poolSize)
poolSize
- Thread pool size to use within grid.this
for chaining.getPeerClassLoadingThreadPoolSize()
public IgniteConfiguration setDataStreamerThreadPoolSize(int poolSize)
poolSize
- Executor service to use for data stream messages.this
for chaining.getDataStreamerThreadPoolSize()
public IgniteConfiguration setUtilityCachePoolSize(int poolSize)
poolSize
- Default executor service size to use for utility cache messages.this
for chaining.getUtilityCacheThreadPoolSize()
,
getUtilityCacheKeepAliveTime()
public IgniteConfiguration setQueryThreadPoolSize(int poolSize)
poolSize
- Thread pool size to use within grid.this
for chaining.getQueryThreadPoolSize()
public IgniteConfiguration setUtilityCacheKeepAliveTime(long keepAliveTime)
keepAliveTime
- Keep alive time in milliseconds of executor service to use for utility cache messages.this
for chaining.getUtilityCacheThreadPoolSize()
,
getUtilityCacheKeepAliveTime()
public String getIgniteHome()
IGNITE_HOME
system property and environment variable in that order. If
IGNITE_HOME
still could not be obtained, then grid will not start and exception
will be thrown.null
to make the system attempt to
infer it automatically.IgniteSystemProperties.IGNITE_HOME
public IgniteConfiguration setIgniteHome(String igniteHome)
igniteHome
- Ignition
installation folder.this
for chaining.getIgniteHome()
,
IgniteSystemProperties.IGNITE_HOME
public String getWorkDirectory()
IGNITE_HOME
specified by setIgniteHome(String)
or
IGNITE_HOME
environment variable or system property.
If IGNITE_HOME
is not provided, then system temp directory is used.
null
to make the system attempt to infer it automatically.getIgniteHome()
,
IgniteSystemProperties.IGNITE_HOME
public IgniteConfiguration setWorkDirectory(String igniteWorkDir)
igniteWorkDir
- Ignite
work directory.this
for chaining.getWorkDirectory()
public MBeanServer getMBeanServer()
null
to make the system create a default one.ManagementFactory.getPlatformMBeanServer()
public IgniteConfiguration setMBeanServer(MBeanServer mbeanSrv)
mbeanSrv
- Initialized and started MBean server.this
for chaining.@Deprecated public UUID getNodeId()
@Deprecated public IgniteConfiguration setNodeId(UUID nodeId)
setConsistentId(Serializable)
instead.nodeId
- Unique identifier for local node.this
for chaining.getNodeId()
@Deprecated public Marshaller getMarshaller()
@Deprecated public IgniteConfiguration setMarshaller(Marshaller marsh)
marsh
- Marshaller to use within grid.this
for chaining.getMarshaller()
public boolean isPeerClassLoadingEnabled()
true
if peer class loading is enabled, false
otherwise. Default value is false
specified by DFLT_P2P_ENABLED
.
When peer class loading is enabled and task is not deployed on local node, local node will try to load classes from the node that initiated task execution. This way, a task can be physically deployed only on one node and then internally penetrate to all other nodes.
See ComputeTask
documentation for more information about task deployment.
true
if peer class loading is enabled, false
otherwise.public boolean isMarshalLocalJobs()
true
, jobs mapped to local node will be
marshalled as if it was remote node.
If not provided, default value is defined by DFLT_MARSHAL_LOCAL_JOBS
.
True
if local jobs should be marshalled.public IgniteConfiguration setMarshalLocalJobs(boolean marshLocJobs)
marshLocJobs
- True
if local jobs should be marshalled.this
for chaining.public IgniteConfiguration setPeerClassLoadingEnabled(boolean p2pEnabled)
p2pEnabled
- true
if peer class loading is
enabled, false
otherwise.this
for chaining.public String[] getPeerClassLoadingLocalClassPathExclude()
public IgniteConfiguration setPeerClassLoadingLocalClassPathExclude(String... p2pLocClsPathExcl)
p2pLocClsPathExcl
- List of P2P loaded packages. Package
name supports '*' at the end like in package import clause.this
for chaining.public int getMetricsHistorySize()
0
), then default value
DFLT_METRICS_HISTORY_SIZE
is used.DFLT_METRICS_HISTORY_SIZE
public IgniteConfiguration setMetricsHistorySize(int metricsHistSize)
10,000
.metricsHistSize
- Number of metrics kept in history to use for
metric totals and averages calculations.this
for chaining.DFLT_METRICS_HISTORY_SIZE
public long getMetricsUpdateFrequency()
Updating metrics too frequently may have negative performance impact.
If not provided, then default value DFLT_METRICS_UPDATE_FREQ
is used.
DFLT_METRICS_UPDATE_FREQ
public IgniteConfiguration setMetricsUpdateFrequency(long metricsUpdateFreq)
Positive value defines the actual update frequency.
If not provided, then default value
DFLT_METRICS_UPDATE_FREQ
is used.
metricsUpdateFreq
- Metrics update frequency in milliseconds.this
for chaining.public long getMetricsExpireTime()
DFLT_METRICS_EXPIRE_TIME
is used.DFLT_METRICS_EXPIRE_TIME
public IgniteConfiguration setMetricsExpireTime(long metricsExpTime)
600,000
milliseconds (10 minutes).metricsExpTime
- The metricsExpTime to set.this
for chaining.DFLT_METRICS_EXPIRE_TIME
public long getNetworkTimeout()
If not provided, then default value
DFLT_NETWORK_TIMEOUT
is used.
DFLT_NETWORK_TIMEOUT
public IgniteConfiguration setNetworkTimeout(long netTimeout)
If not provided (value is 0
), then default value
DFLT_NETWORK_TIMEOUT
is used.
netTimeout
- Maximum timeout for network requests.this
for chaining.DFLT_NETWORK_TIMEOUT
public int getNetworkCompressionLevel()
If not provided, then default value Deflater.BEST_SPEED is used.
public void setNetworkCompressionLevel(int netCompressionLevel)
If not provided, then default value Deflater.BEST_SPEED is used.
public long getNetworkSendRetryDelay()
If not provided, then default value
DFLT_SEND_RETRY_DELAY
is used.
getNetworkSendRetryCount()
,
DFLT_SEND_RETRY_DELAY
public IgniteConfiguration setNetworkSendRetryDelay(long sndRetryDelay)
If not provided, then default value
DFLT_SEND_RETRY_DELAY
is used.
sndRetryDelay
- Interval between message send retries.this
for chaining.public int getNetworkSendRetryCount()
If not provided, then default value
DFLT_SEND_RETRY_CNT
is used.
getNetworkSendRetryDelay()
,
DFLT_SEND_RETRY_CNT
public IgniteConfiguration setNetworkSendRetryCount(int sndRetryCnt)
If not provided, then default value
DFLT_SEND_RETRY_CNT
is used.
sndRetryCnt
- Message send retries count.this
for chaining.public int getRebalanceThreadPoolSize()
public IgniteConfiguration setRebalanceThreadPoolSize(int rebalanceThreadPoolSize)
1
which has minimal impact on the operation of the grid.rebalanceThreadPoolSize
- Number of system threads that will be assigned for partition transfer during
rebalancing.this
for chaining.public long getRebalanceTimeout()
rebalanceTimeout
parameter
specifies how long a message will stay in a receiving queue, waiting for other ordered messages that are
ordered ahead of it to arrive will be processed. If timeout expires, then all messages that have not arrived
before this message will be skipped. If an expired supply (demand) message actually does arrive, it will be
ignored.
Default value is defined by DFLT_REBALANCE_TIMEOUT
, if 0
than the
getNetworkTimeout()
will be used instead.
public IgniteConfiguration setRebalanceTimeout(long rebalanceTimeout)
rebalanceTimeout
parameter
specifies how long a message will stay in a receiving queue, waiting for other ordered messages that are
ordered ahead of it to arrive will be processed. If timeout expires, then all messages that have not arrived
before this message will be skipped. If an expired supply (demand) message actually does arrive, it will be
ignored.
Default value is defined by DFLT_REBALANCE_TIMEOUT
, if 0
than the
getNetworkTimeout()
will be used instead.
rebalanceTimeout
- Rebalance message timeout in milliseconds.this
for chaining.public long getRebalanceBatchesPrefetchCount()
Default value is defined by DFLT_REBALANCE_BATCHES_PREFETCH_COUNT
, minimum value is 1
.
public IgniteConfiguration setRebalanceBatchesPrefetchCount(long rebalanceBatchesCnt)
Default value is defined by DFLT_REBALANCE_BATCHES_PREFETCH_COUNT
, minimum value is 1
.
rebalanceBatchesCnt
- The number of batches prefetch count.this
for chaining.public long getRebalanceThrottle()
Value of 0
means that throttling is disabled. By default throttling is disabled -
the default is defined by DFLT_REBALANCE_THROTTLE
constant.
0
to disable throttling.public IgniteConfiguration setRebalanceThrottle(long rebalanceThrottle)
Value of 0
means that throttling is disabled. By default throttling is disabled -
the default is defined by DFLT_REBALANCE_THROTTLE
constant.
rebalanceThrottle
- Time in milliseconds to wait between rebalance messages, 0
to disable throttling.this
for chaining.public int getRebalanceBatchSize()
Default value is defined by DFLT_REBALANCE_BATCH_SIZE
.
public IgniteConfiguration setRebalanceBatchSize(int rebalanceBatchSize)
Default value is defined by DFLT_REBALANCE_BATCH_SIZE
.
rebalanceBatchSize
- Rebalance message size in bytes.this
for chaining.public LifecycleBean[] getLifecycleBeans()
LifecycleBean
,
LifecycleEventType
public IgniteConfiguration setLifecycleBeans(LifecycleBean... lifecycleBeans)
lifecycleBeans
- Collection of lifecycle beans.this
for chaining.LifecycleEventType
public IgniteConfiguration setSslContextFactory(javax.cache.configuration.Factory<SSLContext> sslCtxFactory)
sslCtxFactory
- Ssl context factory.SslContextFactory
public javax.cache.configuration.Factory<SSLContext> getSslContextFactory()
SslContextFactory
public EventStorageSpi getEventStorageSpi()
NoopEventStorageSpi
will be used.null
to use default implementation.public IgniteConfiguration setEventStorageSpi(EventStorageSpi evtSpi)
EventStorageSpi
.evtSpi
- Fully configured instance of EventStorageSpi
.this
for chaining.getEventStorageSpi()
public DiscoverySpi getDiscoverySpi()
TcpDiscoverySpi
will be used by default.null
to use default implementation.public IgniteConfiguration setDiscoverySpi(DiscoverySpi discoSpi)
DiscoverySpi
.discoSpi
- Fully configured instance of DiscoverySpi
.this
for chaining.getDiscoverySpi()
public SegmentationPolicy getSegmentationPolicy()
DFLT_SEG_PLC
.public IgniteConfiguration setSegmentationPolicy(SegmentationPolicy segPlc)
segPlc
- Segmentation policy.this
for chaining.public boolean isWaitForSegmentOnStart()
DFLT_WAIT_FOR_SEG_ON_START
.
Returns true
if node should wait for correct segment on start.
If node detects that segment is incorrect on startup and this method
returns true
, node waits until segment becomes correct.
If segment is incorrect on startup and this method returns false
,
exception is thrown.
True
to wait for segment on startup, false
otherwise.public IgniteConfiguration setWaitForSegmentOnStart(boolean waitForSegOnStart)
waitForSegOnStart
- True
to wait for segment on start.this
for chaining.public boolean isAllSegmentationResolversPassRequired()
Returns true
if all segmentation resolvers should succeed
for node to be in correct segment.
Returns false
if at least one segmentation resolver should succeed
for node to be in correct segment.
Default is DFLT_ALL_SEG_RESOLVERS_PASS_REQ
.
True
if all segmentation resolvers should succeed,
false
if only one is enough.public IgniteConfiguration setAllSegmentationResolversPassRequired(boolean allResolversPassReq)
allResolversPassReq
- True
if all segmentation resolvers should
succeed for node to be in the correct segment.this
for chaining.public int getSegmentationResolveAttempts()
DFLT_SEG_RESOLVE_ATTEMPTS
.public IgniteConfiguration setSegmentationResolveAttempts(int segResolveAttempts)
segResolveAttempts
- Segmentation resolve attempts.this
for chaining.public SegmentationResolver[] getSegmentationResolvers()
If array is null
or empty, periodical and on-start network
segment checks do not happen.
public IgniteConfiguration setSegmentationResolvers(SegmentationResolver... segResolvers)
segResolvers
- Segmentation resolvers.this
for chaining.public long getSegmentCheckFrequency()
if 0, periodic segment check is disabled and segment is checked only on topology changes (if segmentation resolvers are configured).
Default is DFLT_SEG_CHK_FREQ
.
public IgniteConfiguration setSegmentCheckFrequency(long segChkFreq)
segChkFreq
- Segment check frequency.this
for chaining.public CommunicationSpi getCommunicationSpi()
TcpCommunicationSpi
will be used by default.null
to use default implementation.public IgniteConfiguration setCommunicationSpi(CommunicationSpi commSpi)
CommunicationSpi
.commSpi
- Fully configured instance of CommunicationSpi
.this
for chaining.getCommunicationSpi()
public CollisionSpi getCollisionSpi()
NoopCollisionSpi
is used and jobs get activated immediately
on arrive to mapped node. This approach suits well for large amount of small
jobs (which is a wide-spread use case). User still can control the number
of concurrent jobs by setting maximum thread pool size defined by
IgniteConfiguration.getPublicThreadPoolSize() configuration property.null
to use default implementation.public IgniteConfiguration setCollisionSpi(CollisionSpi colSpi)
CollisionSpi
.colSpi
- Fully configured instance of CollisionSpi
or
null
if no SPI provided.this
for chaining.getCollisionSpi()
public DeploymentSpi getDeploymentSpi()
LocalDeploymentSpi
will be used.null
to use default implementation.public IgniteConfiguration setDeploymentSpi(DeploymentSpi deploySpi)
DeploymentSpi
.deploySpi
- Fully configured instance of DeploymentSpi
.this
for chaining.getDeploymentSpi()
public CheckpointSpi[] getCheckpointSpi()
NoopCheckpointSpi
will be used.null
to use default implementation.public IgniteConfiguration setCheckpointSpi(CheckpointSpi... cpSpi)
CheckpointSpi
.cpSpi
- Fully configured instance of CheckpointSpi
.this
for chaining.getCheckpointSpi()
public FailoverSpi[] getFailoverSpi()
AlwaysFailoverSpi
will be used.null
to use default implementation.public IgniteConfiguration setFailoverSpi(FailoverSpi... failSpi)
FailoverSpi
.failSpi
- Fully configured instance of FailoverSpi
or
null
if no SPI provided.this
for chaining.getFailoverSpi()
public Long getClientFailureDetectionTimeout()
TcpDiscoverySpi
and TcpCommunicationSpi
.
Default is DFLT_CLIENT_FAILURE_DETECTION_TIMEOUT
.
setClientFailureDetectionTimeout(long)
public IgniteConfiguration setClientFailureDetectionTimeout(long clientFailureDetectionTimeout)
TcpDiscoverySpi
and TcpCommunicationSpi
.
Failure detection timeout is used to determine how long the communication or discovery SPIs should wait before considering a remote connection failed.
clientFailureDetectionTimeout
- Failure detection timeout in milliseconds.this
for chaining.public Long getFailureDetectionTimeout()
TcpDiscoverySpi
and TcpCommunicationSpi
.
Default is DFLT_FAILURE_DETECTION_TIMEOUT
.
setFailureDetectionTimeout(long)
public IgniteConfiguration setFailureDetectionTimeout(long failureDetectionTimeout)
TcpDiscoverySpi
and TcpCommunicationSpi
.
Failure detection timeout is used to determine how long the communication or discovery SPIs should wait before considering a remote connection failed.
failureDetectionTimeout
- Failure detection timeout in milliseconds.this
for chaining.public Long getSystemWorkerBlockedTimeout()
setSystemWorkerBlockedTimeout(long)
public IgniteConfiguration setSystemWorkerBlockedTimeout(long sysWorkerBlockedTimeout)
sysWorkerBlockedTimeout
- Maximum inactivity period for system worker in milliseconds.this
for chaining.setFailureHandler(FailureHandler)
public LoadBalancingSpi[] getLoadBalancingSpi()
RoundRobinLoadBalancingSpi
will be used.null
to use default implementation.@Deprecated public long getDiscoveryStartupDelay()
During startup, it is possible for some SPIs to have a small time window when Node A has discovered Node B, but Node B has not discovered Node A yet. Such time window is usually very small, a matter of milliseconds, but certain JMS providers, for example, may be very slow and hence have larger discovery delay window.
The default value of this property is 60,000
specified by
DFLT_DISCOVERY_STARTUP_DELAY
. This should be good enough for vast
majority of configurations. However, if you do anticipate an even larger
delay, you should increase this value.
@Deprecated public IgniteConfiguration setDiscoveryStartupDelay(long discoStartupDelay)
600,000
milliseconds (10 minutes).discoStartupDelay
- Time in milliseconds for when nodes
can be out-of-sync during startup.this
for chaining.public IgniteConfiguration setLoadBalancingSpi(LoadBalancingSpi... loadBalancingSpi)
LoadBalancingSpi
.loadBalancingSpi
- Fully configured instance of LoadBalancingSpi
or
null
if no SPI provided.this
for chaining.getLoadBalancingSpi()
public IgniteConfiguration setIndexingSpi(IndexingSpi indexingSpi)
IndexingSpi
.indexingSpi
- Fully configured instance of IndexingSpi
.this
for chaining.getIndexingSpi()
public IndexingSpi getIndexingSpi()
public IgniteConfiguration setEncryptionSpi(EncryptionSpi encryptionSpi)
EncryptionSpi
.encryptionSpi
- Fully configured instance of EncryptionSpi
.this
for chaining.getEncryptionSpi()
public EncryptionSpi getEncryptionSpi()
public IgniteConfiguration setMetricExporterSpi(MetricExporterSpi... metricExporterSpi)
MetricExporterSpi
.metricExporterSpi
- Fully configured instances of MetricExporterSpi
.this
for chaining.getMetricExporterSpi()
public IgniteConfiguration setSystemViewExporterSpi(SystemViewExporterSpi... sysViewExporterSpi)
SystemViewExporterSpi
.sysViewExporterSpi
- Fully configured instances of SystemViewExporterSpi
.this
for chaining.getSystemViewExporterSpi()
public MetricExporterSpi[] getMetricExporterSpi()
public IgniteConfiguration setTracingSpi(TracingSpi tracingSpi)
TracingSpi
.tracingSpi
- Fully configured instance of TracingSpi
.this
for chaining.public TracingSpi getTracingSpi()
public SystemViewExporterSpi[] getSystemViewExporterSpi()
public AddressResolver getAddressResolver()
public IgniteConfiguration setAddressResolver(AddressResolver addrRslvr)
addrRslvr
- Address resolver.this
for chaining.public IgniteConfiguration setDeploymentMode(DeploymentMode deployMode)
deployMode
- Task classes and resources sharing mode.this
for chaining.public DeploymentMode getDeploymentMode()
DeploymentMode
documentation for more information.public IgniteConfiguration setPeerClassLoadingMissedResourcesCacheSize(int p2pMissedCacheSize)
p2pMissedCacheSize
- Size of missed resources cache.this
for chaining.public int getPeerClassLoadingMissedResourcesCacheSize()
0
, missed
resources will be cached and next resource request ignored. If size is 0
,
then request for the resource will be sent to the remote node every time this
resource is requested.public CacheConfiguration[] getCacheConfiguration()
public IgniteConfiguration setCacheConfiguration(CacheConfiguration... cacheCfg)
cacheCfg
- Cache configurations.public Boolean isClientMode()
DiscoverySpi
in client mode if this property is true
.TcpDiscoverySpi.setForceServerMode(boolean)
public IgniteConfiguration setClientMode(boolean clientMode)
clientMode
- Client mode flag.this
for chaining.public CacheKeyConfiguration[] getCacheKeyConfiguration()
public IgniteConfiguration setCacheKeyConfiguration(CacheKeyConfiguration... cacheKeyCfg)
cacheKeyCfg
- Cache key configuration.public BinaryConfiguration getBinaryConfiguration()
public IgniteConfiguration setBinaryConfiguration(BinaryConfiguration binaryCfg)
binaryCfg
- Binary configuration object.public DataStorageConfiguration getDataStorageConfiguration()
public IgniteConfiguration setDataStorageConfiguration(DataStorageConfiguration dsCfg)
dsCfg
- Data storage configuration.this
for chaining.@Deprecated public MemoryConfiguration getMemoryConfiguration()
DataStorageConfiguration
instead.@Deprecated public IgniteConfiguration setMemoryConfiguration(MemoryConfiguration memCfg)
DataStorageConfiguration
instead.memCfg
- Memory configuration.this
for chaining.@Deprecated public PersistentStoreConfiguration getPersistentStoreConfiguration()
DataStorageConfiguration
for configuring persistence instead.@Deprecated public boolean isPersistentStoreEnabled()
true
if persistence is enabled, false
if disabled.@Deprecated public IgniteConfiguration setPersistentStoreConfiguration(PersistentStoreConfiguration pstCfg)
DataStorageConfiguration
for configuring persistence instead.pstCfg
- Persistence configuration.this
for chaining.@Deprecated public boolean isActiveOnStart()
getClusterStateOnStart()
instead.
Default value is DFLT_ACTIVE_ON_START
.
This flag is ignored when Ignite Persistence is enabled see DataStorageConfiguration
.
Cluster is always inactive on start when Ignite Persistence is enabled.
@Deprecated public IgniteConfiguration setActiveOnStart(boolean activeOnStart)
setClusterStateOnStart(ClusterState)
instead.
This flag is ignored when DataStorageConfiguration
has at least one configured persistent region:
cluster is always inactive on start when Ignite Persistence is enabled.
activeOnStart
- Active on start flag value.this
instance.isActiveOnStart()
@Deprecated public boolean isAutoActivationEnabled()
getClusterStateOnStart()
instead.true
and BaselineTopology is set as well than cluster activates automatically
when all nodes from the BaselineTopology join the cluster.
Default value is DFLT_AUTO_ACTIVATION
.
@Deprecated public IgniteConfiguration setAutoActivationEnabled(boolean autoActivation)
setClusterStateOnStart(ClusterState)
instead.autoActivation
- Auto activation enabled flag value.this
instance.isAutoActivationEnabled()
@Nullable public @Nullable ClusterState getClusterStateOnStart()
ClusterState.INACTIVE
, further hode joins will be handled by cluster faster and
manual cluster activation should be performed in order to start working the cluster and caches.
ClusterState.INACTIVE
and BaselineTopology is
set (cluster was activated before, for example before cluster restart) as well then cluster moves to given
cluster state when all nodes from the BaselineTopology join the cluster, i.e. manual activation isn't required
in that case.
Default value is DFLT_STATE_ON_START
.
null
, if property wasn't set. Null
means that default
value will be used.public IgniteConfiguration setClusterStateOnStart(ClusterState state)
state
- New cluster state on start.this
for chaining.getClusterStateOnStart()
public boolean isCacheSanityCheckEnabled()
lock(...)
or lockAsync(...)
methods when entry is enlisted to transaction.These checks are not required for cache operation, but help to find subtle bugs. Disabling of this checks usually yields a noticeable performance gain.
If not provided, default value is DFLT_CACHE_SANITY_CHECK_ENABLED
.
True
if group lock sanity check is enabled.public IgniteConfiguration setCacheSanityCheckEnabled(boolean cacheSanityCheckEnabled)
cacheSanityCheckEnabled
- True
if cache sanity check is enabled.this
for chaining.isCacheSanityCheckEnabled()
public int[] getIncludeEventTypes()
Note that by default all events in Ignite are disabled. Ignite can and often does generate thousands events per seconds under the load and therefore it creates a significant additional load on the system. If these events are not needed by the application this load is unnecessary and leads to significant performance degradation. So it is highly recommended to enable only those events that your application logic requires. Note that certain events are required for Ignite's internal operations and such events will still be generated but not stored by event storage SPI if they are disabled in Ignite configuration.
public IgniteConfiguration setIncludeEventTypes(int... inclEvtTypes)
GridEventStorageManager.record(Event)
.
Note, that either the include event types or the exclude event types can be established.inclEvtTypes
- Include event types.this
for chaining.public IgniteConfiguration setLocalHost(String locHost)
locHost
- Local IP address or host to bind to.this
for chaining.public String getLocalHost()
If null
then Ignite tries to use local wildcard address. That means that
all services will be available on all network interfaces of the host machine.
It is strongly recommended to set this parameter for all production environments.
If not provided, default is null
.
public int getTimeServerPortBase()
[timeServerPortBase, timeServerPortBase + timeServerPortRange - 1]
.
Time server provides clock synchronization between nodes.
public IgniteConfiguration setTimeServerPortBase(int timeSrvPortBase)
timeSrvPortBase
- Time server port base.this
for chaining.public int getTimeServerPortRange()
setTimeServerPortBase(int)
method and fail if binding to this port did not succeed.public IgniteConfiguration setTimeServerPortRange(int timeSrvPortRange)
timeSrvPortRange
- Time server port range.this
for chaining.public String[] getIncludeProperties()
null
, which is default, then all system and environment
properties will be included. If this array is empty, then none will be included.
Otherwise, for every name provided, first a system property will be looked up,
and then, if it is not found, environment property will be looked up.public IgniteConfiguration setIncludeProperties(String... includeProps)
getIncludeProperties()
for more info.includeProps
- Array of system or environment property names to include into node attributes.this
for chaining.public long getMetricsLogFrequency()
If 0
, metrics print out is disabled.
If not provided, then default value DFLT_METRICS_LOG_FREQ
is used.
public IgniteConfiguration setMetricsLogFrequency(long metricsLogFreq)
If 0
, metrics print out is disabled.
If not provided, then default value DFLT_METRICS_LOG_FREQ
is used.
metricsLogFreq
- Frequency of metrics log print out.this
for chaining.public ConnectorConfiguration getConnectorConfiguration()
public IgniteConfiguration setConnectorConfiguration(ConnectorConfiguration connectorCfg)
connectorCfg
- Connector configuration.this
for chaining.@Deprecated public OdbcConfiguration getOdbcConfiguration()
getClientConnectorConfiguration()
()} instead.@Deprecated public IgniteConfiguration setOdbcConfiguration(OdbcConfiguration odbcCfg)
setClientConnectorConfiguration(ClientConnectorConfiguration)
instead.odbcCfg
- ODBC configuration.this
for chaining.public ServiceConfiguration[] getServiceConfiguration()
public IgniteConfiguration setServiceConfiguration(ServiceConfiguration... svcCfgs)
svcCfgs
- Configurations for services to be deployed on the grid.this
for chaining.public Map<IgnitePredicate<? extends Event>,int[]> getLocalEventListeners()
EventType
public IgniteConfiguration setLocalEventListeners(Map<IgnitePredicate<? extends Event>,int[]> lsnrs)
lsnrs
- Pre-configured event listeners map.this
for chaining.public IgniteInClosure<IgniteConfiguration> getWarmupClosure()
public IgniteConfiguration setWarmupClosure(IgniteInClosure<IgniteConfiguration> warmupClos)
warmupClos
- Warmup closure to execute.this
for chaining.getWarmupClosure()
public TransactionConfiguration getTransactionConfiguration()
public IgniteConfiguration setTransactionConfiguration(TransactionConfiguration txCfg)
txCfg
- Transactions configuration.this
for chaining.@Deprecated public PluginConfiguration[] getPluginConfigurations()
PluginProvider
public IgniteConfiguration setPluginConfigurations(PluginConfiguration... pluginCfgs)
pluginCfgs
- Plugin configurations.this
for chaining.PluginProvider
public AtomicConfiguration getAtomicConfiguration()
public IgniteConfiguration setAtomicConfiguration(AtomicConfiguration atomicCfg)
atomicCfg
- Atomic data structures configuration.this
for chaining.public IgniteConfiguration setClassLoader(ClassLoader classLdr)
EntryProcessors
,
CacheEntryListeners
, CacheLoaders
and
ExpiryPolicys
).classLdr
- Class loader.this
for chaining.public ClassLoader getClassLoader()
public javax.cache.configuration.Factory<CacheStoreSessionListener>[] getCacheStoreSessionListenerFactories()
CacheStoreSessionListener
public IgniteConfiguration setCacheStoreSessionListenerFactories(javax.cache.configuration.Factory<CacheStoreSessionListener>... storeSesLsnrs)
These are global store session listeners, so they are applied to
all caches. If you need to override listeners for a
particular cache, use CacheConfiguration.setCacheStoreSessionListenerFactories(Factory[])
configuration property.
storeSesLsnrs
- Cache store session listener factories.this
for chaining.CacheStoreSessionListener
public PlatformConfiguration getPlatformConfiguration()
public IgniteConfiguration setPlatformConfiguration(PlatformConfiguration platformCfg)
platformCfg
- Platform configuration.this
for chaining.@Deprecated public boolean isLateAffinityAssignment()
On each topology change, for each started cache partition-to-node mapping is
calculated using AffinityFunction
configured for cache. When late
affinity assignment mode is disabled then new affinity mapping is applied immediately.
With late affinity assignment mode if primary node was changed for some partition, but data for this partition is not rebalanced yet on this node, then current primary is not changed and new primary is temporary assigned as backup. This nodes becomes primary only when rebalancing for all assigned primary partitions is finished. This mode can show better performance for cache operations, since when cache primary node executes some operation and data is not rebalanced yet, then it sends additional message to force rebalancing from other nodes.
Note, that Affinity
interface provides assignment information taking into account late assignment,
so while rebalancing for new primary nodes is not finished it can return assignment which differs
from assignment calculated by AffinityFunction.assignPartitions(org.apache.ignite.cache.affinity.AffinityFunctionContext)
.
This property should have the same value for all nodes in cluster.
AffinityFunction
@Deprecated public IgniteConfiguration setLateAffinityAssignment(boolean lateAffAssignment)
lateAffAssignment
- Late affinity assignment flag.this
for chaining.public ExecutorConfiguration[] getExecutorConfiguration()
See setExecutorConfiguration(ExecutorConfiguration...)
for more information.
public IgniteConfiguration setExecutorConfiguration(ExecutorConfiguration... execCfgs)
See IgniteCompute.withExecutor(String)
for more information.
execCfgs
- Executor configurations.this
for chaining.@Deprecated public long getLongQueryWarningTimeout()
SqlConfiguration.getLongQueryWarningTimeout()
instead.@Deprecated public IgniteConfiguration setLongQueryWarningTimeout(long longQryWarnTimeout)
SqlConfiguration.setLongQueryWarningTimeout(long)
()} instead.longQryWarnTimeout
- Timeout in milliseconds.this
for chaining.@Deprecated public IgniteConfiguration setSqlConnectorConfiguration(SqlConnectorConfiguration sqlConnCfg)
setClientConnectorConfiguration(ClientConnectorConfiguration)
instead.sqlConnCfg
- SQL connector configuration.this
for chaining.@Deprecated public SqlConnectorConfiguration getSqlConnectorConfiguration()
getClientConnectorConfiguration()
instead.public IgniteConfiguration setClientConnectorConfiguration(ClientConnectorConfiguration cliConnCfg)
cliConnCfg
- Client connector configuration. If null
, will clear
previously set connector configuration.this
for chaining.public FailureHandler getFailureHandler()
public IgniteConfiguration setFailureHandler(FailureHandler failureHnd)
failureHnd
- Failure handler.This
for chaining.public ClientConnectorConfiguration getClientConnectorConfiguration()
public int getMvccVacuumThreadCount()
Returns number of MVCC vacuum threads.
public IgniteConfiguration setMvccVacuumThreadCount(int mvccVacuumThreadCnt)
Sets number of MVCC vacuum threads.
mvccVacuumThreadCnt
- Number of MVCC vacuum threads.this
for chaining.public long getMvccVacuumFrequency()
Returns time interval between MVCC vacuum runs in milliseconds.
public IgniteConfiguration setMvccVacuumFrequency(long mvccVacuumFreq)
Sets time interval between MVCC vacuum runs in milliseconds.
mvccVacuumFreq
- Time interval between MVCC vacuum runs in milliseconds.this
for chaining.public boolean isAuthenticationEnabled()
true
if user authentication is enabled for cluster. Otherwise returns false
.
Default value is false; authentication is disabled.true
if user authentication is enabled for cluster. Otherwise returns false
.public IgniteConfiguration setAuthenticationEnabled(boolean authEnabled)
authEnabled
- User authentication enabled flag. true
enabthis
for chaining.@Deprecated public String[] getSqlSchemas()
SqlConfiguration.getSqlSchemas()
instead.
See setSqlSchemas(String...)
for more information.
@Deprecated public IgniteConfiguration setSqlSchemas(String... sqlSchemas)
SqlConfiguration.setSqlSchemas(String...)
instead.
By default schema names are case-insensitive, i.e. my_schema
and My_Schema
represents the same
object. Use quotes to enforce case sensitivity (e.g. "My_Schema"
).
Property is ignored if ignite-indexing
module is not in classpath.
sqlSchemas
- SQL schemas to be created on node startup.this
for chaining.@Deprecated public String getSqlGlobalMemoryQuota()
SqlConfiguration.getSqlGlobalMemoryQuota()
instead.
See setSqlGlobalMemoryQuota(String)
for details.
@Deprecated public IgniteConfiguration setSqlGlobalMemoryQuota(String size)
SqlConfiguration.setSqlGlobalMemoryQuota(String)
instead.
Global SQL query memory pool size or SQL query memory quota - is an upper bound for the heap memory part
which might be occupied by the SQL query execution engine. This quota is shared among all simultaneously
running queries, hence it be easily consumed by the single heavy analytics query. If you want to control
memory quota on per-query basis consider setSqlQueryMemoryQuota(String)
.
There are two options of query behaviour when either query or global memory quota is exceeded:
setSqlOffloadingEnabled(boolean)
for details.
If not provided, the default value is defined by SqlConfiguration.DFLT_SQL_QUERY_GLOBAL_MEMORY_QUOTA
.
The value is specified as string value of size of in bytes.
Value 0
means no quota at all.
Quota may be specified also in:
10k, 400K
60m, 420M
7g, 2G
45%, 80%
size
- Size of global memory pool for SQL queries in bytes, kilobytes, megabytes,
or percentage of the max heap.this
for chaining.@Deprecated public String getSqlQueryMemoryQuota()
SqlConfiguration.getSqlQueryMemoryQuota()
instead.setSqlQueryMemoryQuota(String)
for details.@Deprecated public IgniteConfiguration setSqlQueryMemoryQuota(String size)
SqlConfiguration.setSqlQueryMemoryQuota(String)
instead.It is the maximum amount of memory intended for the particular single query execution. If a query execution exceeds this bound, the either would happen:
setSqlOffloadingEnabled(boolean)
for details.
If not provided, the default value is defined by SqlConfiguration.DFLT_SQL_QUERY_MEMORY_QUOTA
.
The value is specified as string value of size of in bytes.
Value 0
means no quota at all.
Quota may be specified also in:
10k, 400K
60m, 420M
7g, 2G
45%, 80%
size
- Size of per-query memory quota in bytes, kilobytes, megabytes, or percentage of the max heap.this
for chaining.@Deprecated public boolean isSqlOffloadingEnabled()
SqlConfiguration.isSqlOffloadingEnabled()
instead.setSqlOffloadingEnabled(boolean)
for details.@Deprecated public IgniteConfiguration setSqlOffloadingEnabled(boolean offloadingEnabled)
SqlConfiguration.setSqlOffloadingEnabled(boolean)
instead.
Offloading flag specifies the query execution behavior on memory quota excess - either global quota
(see setSqlGlobalMemoryQuota(String)
) or per query quota (see setSqlQueryMemoryQuota(String)
).
Possible options on quota excess are:
offloadingEnabled
flag set to false
, the exception will be thrown when
memory quota is exceeded.
offloadingEnabled
flag set to true
, the intermediate query results will be
offloaded to disk. It may slow down the query execution time by orders of magnitude, but eventually
the query will be executed and the caller will get a result.
false
.offloadingEnabled
- Offloading enabled flag.this
for chaining.public PluginProvider[] getPluginProviders()
public IgniteConfiguration setPluginProviders(PluginProvider... pluginProvs)
pluginProvs
- Plugin providers.this
for chaining.public SqlConfiguration getSqlConfiguration()
public IgniteConfiguration setSqlConfiguration(SqlConfiguration sqlInitCfg)
sqlInitCfg
- Initial configuration of the SQL subsystem.this
for chaining.public Executor getAsyncContinuationExecutor()
null
(default), ForkJoinPool.commonPool()
is used.
When async operation completes, corresponding IgniteFuture
listeners
will be invoked using this executor.public IgniteConfiguration setAsyncContinuationExecutor(Executor asyncContinuationExecutor)
null
(default), ForkJoinPool.commonPool()
is used.
When async operation completes, corresponding IgniteFuture
listeners
will be invoked using this executor.asyncContinuationExecutor
- Executor for async continuations.this
for chaining.
GridGain In-Memory Computing Platform : ver. 8.9.14 Release Date : November 5 2024