Class IgniteConfiguration
- java.lang.Object
-
- org.apache.ignite.configuration.IgniteConfiguration
-
public class IgniteConfiguration extends Object
This class defines grid runtime configuration. This configuration is passed toIgnition.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 applyIgnition.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
Ignitiondocumentation.
-
-
Field Summary
Fields Modifier and Type Field Description static intAVAILABLE_PROC_CNTDefault core size of public thread pool.static StringCOURTESY_LOGGER_NAMECourtesy notice log category.static booleanDFLT_ACTIVE_ON_STARTDeprecated.static booleanDFLT_ALL_SEG_RESOLVERS_PASS_REQDefault value for all segmentation resolvers pass required.static booleanDFLT_AUTO_ACTIVATIONDeprecated.static intDFLT_BUILD_IDX_THREAD_POOL_SIZEDefault size of index create/rebuild thread pool.static booleanDFLT_CACHE_SANITY_CHECK_ENABLEDDefault value for cache sanity check enabled flag.static LongDFLT_CLIENT_FAILURE_DETECTION_TIMEOUTDefault failure detection timeout for client nodes in millis.static intDFLT_DATA_STREAMER_POOL_SIZEDefault size of data streamer thread pool.static DeploymentModeDFLT_DEPLOYMENT_MODEDefault deployment mode (value isDeploymentMode.SHARED).static longDFLT_DISCOVERY_STARTUP_DELAYDefault discovery startup delay in milliseconds (value is60,000ms).static LongDFLT_FAILURE_DETECTION_TIMEOUTDefault failure detection timeout in millis.static booleanDFLT_LATE_AFF_ASSIGNMENTDeprecated.static longDFLT_LONG_QRY_WARN_TIMEOUTDeprecated.Please useSqlConfiguration.DFLT_LONG_QRY_WARN_TIMEOUT.static booleanDFLT_MARSHAL_LOCAL_JOBSDefault marshal local jobs flag.static longDFLT_METRICS_EXPIRE_TIMEDefault metrics expire time.static intDFLT_METRICS_HISTORY_SIZEDefault metrics history size (value is10000).static longDFLT_METRICS_LOG_FREQDefault frequency of metrics log print out.static longDFLT_METRICS_UPDATE_FREQDefault metrics update frequency.static intDFLT_MGMT_THREAD_CNTDefault size of management thread pool.static intDFLT_NETWORK_COMPRESSIONDefault compression level for network messages (value is Deflater.BEST_SPEED.static longDFLT_NETWORK_TIMEOUTDefault maximum timeout to wait for network responses in milliseconds (value is5,000ms).static booleanDFLT_P2P_ENABLEDDefault flag for peer class loading.static intDFLT_P2P_MISSED_RESOURCES_CACHE_SIZEDefault cache size for missed resources.static intDFLT_P2P_THREAD_CNTDefault size of peer class loading thread pool.static intDFLT_PUBLIC_THREAD_CNTDefault core size of public thread pool.static intDFLT_QUERY_THREAD_POOL_SIZEDefault size of query thread pool.static intDFLT_REBALANCE_BATCH_SIZEDefault rebalance batch size in bytes (value is512Kb).static longDFLT_REBALANCE_BATCHES_PREFETCH_COUNTDefault rebalance batches prefetch count (value is3).static intDFLT_REBALANCE_THREAD_POOL_SIZEDefault limit of threads used for rebalance.static longDFLT_REBALANCE_THROTTLETime to wait between rebalance messages in milliseconds to avoid overloading CPU (value is0).static longDFLT_REBALANCE_TIMEOUTDefault rebalance message timeout in milliseconds (value is10000).static longDFLT_SEG_CHK_FREQDefault segment check frequency in discovery manager.static SegmentationPolicyDFLT_SEG_PLCDefault segmentation policy.static intDFLT_SEG_RESOLVE_ATTEMPTSDefault value segmentation resolve attempts count.static intDFLT_SEND_RETRY_CNTDefault message send retries count.static longDFLT_SEND_RETRY_DELAYDefault interval between message send retries.static ShutdownPolicyDFLT_SHUTDOWN_POLICYDefault policy for node shutdown.static StringDFLT_SNAPSHOT_DIRECTORYDefault relative working directory path for snapshot operation result.static intDFLT_SNAPSHOT_THREAD_POOL_SIZEDefault number of threads to perform snapshot operations.static intDFLT_SQL_QUERY_HISTORY_SIZEDeprecated.Please useSqlConfiguration.DFLT_SQL_QUERY_HISTORY_SIZE.static ClusterStateDFLT_STATE_ON_STARTDefault value for cluster state on start.static intDFLT_SYSTEM_CORE_THREAD_CNTDefault size of system thread pool.static intDFLT_TCP_PORTDefault TCP server port.static longDFLT_THREAD_KEEP_ALIVE_TIMEDefault Ignite thread keep alive time.static intDFLT_TIME_SERVER_PORT_BASEDefault time server port base.static intDFLT_TIME_SERVER_PORT_RANGEDefault time server port range.static booleanDFLT_WAIT_FOR_SEG_ON_STARTDefault value for wait for segment on startup flag.ShutdownPolicyshutdownShutdown policy for cluster.
-
Constructor Summary
Constructors Constructor Description IgniteConfiguration()Creates valid grid configuration with all default values.IgniteConfiguration(IgniteConfiguration cfg)Creates grid configuration by coping all configuration properties from given configuration.
-
Method Summary
All Methods Instance Methods Concrete Methods Deprecated Methods Modifier and Type Method Description AddressResolvergetAddressResolver()Gets address resolver for addresses mapping determination.intgetAsyncCallbackPoolSize()Size of thread pool that is in charge of processing asynchronous callbacks.ExecutorgetAsyncContinuationExecutor()Gets the continuation executor for cache async APIs.AtomicConfigurationgetAtomicConfiguration()BinaryConfigurationgetBinaryConfiguration()Gets configuration for Ignite Binary objects.intgetBuildIndexThreadPoolSize()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.ClassLoadergetClassLoader()@Nullable ClientConnectorConfigurationgetClientConnectorConfiguration()Gets client connector configuration.LonggetClientFailureDetectionTimeout()Returns failure detection timeout for client nodes used byTcpDiscoverySpiandTcpCommunicationSpi.@Nullable ClusterStategetClusterStateOnStart()Gets state of cluster on start.CollisionSpigetCollisionSpi()Should return fully configured collision SPI implementation.CommunicationFailureResolvergetCommunicationFailureResolver()CommunicationSpigetCommunicationSpi()Should return fully configured SPI communication implementation.ConnectorConfigurationgetConnectorConfiguration()SerializablegetConsistentId()Gets consistent globally unique node ID which survives node restarts.DataStorageConfigurationgetDataStorageConfiguration()Gets page memory configuration.intgetDataStreamerThreadPoolSize()Size of thread pool that is in charge of processing data stream messages.longgetDefaultQueryTimeout()Deprecated.UseSqlConfiguration.getDefaultQueryTimeout()instead.DeploymentModegetDeploymentMode()Gets deployment mode for deploying tasks and other classes on this node.DeploymentSpigetDeploymentSpi()Should return fully configured deployment SPI implementation.DiscoverySpigetDiscoverySpi()Should return fully configured discovery SPI implementation.longgetDiscoveryStartupDelay()Deprecated.Not used any more.Map<String,String>getDistributedPropertiesDefaultValues()Gets default values for distributed properties.EncryptionSpigetEncryptionSpi()Gets fully configured encryption SPI implementations.EventStorageSpigetEventStorageSpi()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.LonggetFailureDetectionTimeout()Returns failure detection timeout used byTcpDiscoverySpiandTcpCommunicationSpi.FailureHandlergetFailureHandler()Gets failure handler.IgniteLoggergetGridLogger()Should return an instance of logger to use in grid.StringgetGridName()Deprecated.UsegetIgniteInstanceName()instead.StringgetIgniteHome()Should return Ignite installation home folder.StringgetIgniteInstanceName()Gets optional local instance 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.IndexingSpigetIndexingSpi()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.StringgetLocalHost()Gets system-wide local address or host for all Ignite components to bind to.longgetLongQueryWarningTimeout()Deprecated.UseSqlConfiguration.getLongQueryWarningTimeout()instead.intgetManagementThreadPoolSize()Size of thread pool that is in charge of processing internal and VisorGridJobs.MarshallergetMarshaller()Deprecated.Since 2.1.MBeanServergetMBeanServer()Should return MBean server instance.MemoryConfigurationgetMemoryConfiguration()Deprecated.UseDataStorageConfigurationinstead.MetricExporterSpi[]getMetricExporterSpi()Gets fully configured metric SPI implementations.longgetMetricsExpireTime()Elapsed time in milliseconds after which node metrics are considered expired.intgetMetricsHistorySize()Number of node metrics to keep in memory to calculate totals and averages.longgetMetricsLogFrequency()Gets frequency of metrics log print out.longgetMetricsUpdateFrequency()Gets Ignite metrics update frequency in milliseconds.intgetNetworkCompressionLevel()Compression level of internal network messages.intgetNetworkSendRetryCount()Message send retries count.longgetNetworkSendRetryDelay()Interval in milliseconds between message send retries.longgetNetworkTimeout()Maximum timeout in milliseconds for network requests.UUIDgetNodeId()Deprecated.OdbcConfigurationgetOdbcConfiguration()Deprecated.UsegetClientConnectorConfiguration()()} 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.intgetPeerClassLoadingMissedResourcesCacheSize()Returns missed resources cache size.intgetPeerClassLoadingThreadPoolSize()Size of thread pool which is in charge of peer class loading requests/responses.PersistentStoreConfigurationgetPersistentStoreConfiguration()Deprecated.Part of old API.PlatformConfigurationgetPlatformConfiguration()Gets platform configuration.PluginConfiguration[]getPluginConfigurations()Deprecated.PluginProvider[]getPluginProviders()Gets plugin providers.intgetPublicThreadPoolSize()Should return a thread pool size to be used in grid.intgetQueryThreadPoolSize()Size of thread pool that is in charge of processing query messages.longgetRebalanceBatchesPrefetchCount()The number of batches generated by supply node at rebalancing procedure start.intgetRebalanceBatchSize()The supply message size in bytes to be loaded within a single rebalance batch.intgetRebalanceThreadPoolSize()Gets Max count of threads can be used at rebalancing.longgetRebalanceThrottle()Time in milliseconds to wait between rebalance messages to avoid overloading of CPU or network.longgetRebalanceTimeout()Rebalance timeout for supply and demand messages in milliseconds.SegmentationPolicygetSegmentationPolicy()Returns segmentation policy.intgetSegmentationResolveAttempts()Gets segmentation resolve attempts.SegmentationResolver[]getSegmentationResolvers()Returns a collection of segmentation resolvers.longgetSegmentCheckFrequency()Returns frequency of network segment check by discovery manager.ServiceConfiguration[]getServiceConfiguration()Gets configurations for services to be deployed on the grid.intgetServiceThreadPoolSize()Should return a thread pool size to be used in grid.ShutdownPolicygetShutdownPolicy()Gets shutdown policy.StringgetSnapshotPath()intgetSnapshotThreadPoolSize()SqlConfigurationgetSqlConfiguration()Gets Configuration of the SQL subsystem.SqlConnectorConfigurationgetSqlConnectorConfiguration()Deprecated.UsegetClientConnectorConfiguration()instead.intgetSqlQueryHistorySize()Deprecated.UseSqlConfiguration.setSqlQueryHistorySize(int)instead.String[]getSqlSchemas()Deprecated.UseSqlConfiguration.getSqlSchemas()instead.javax.cache.configuration.Factory<SSLContext>getSslContextFactory()Returns SSL context factory that will be used for creating a secure socket layer.intgetStripedPoolSize()Returns striped pool size that should be used for cache requests processing.intgetSystemThreadPoolSize()Size of thread pool that is in charge of processing internal system messages.SystemViewExporterSpi[]getSystemViewExporterSpi()Gets fully configured system view SPI implementations.LonggetSystemWorkerBlockedTimeout()Returns maximum inactivity period for system worker.intgetTimeServerPortBase()Gets base UPD port number for grid time server.intgetTimeServerPortRange()Defines port range to try for time server start.TracingSpigetTracingSpi()Gets fully configured tracing SPI implementation.TransactionConfigurationgetTransactionConfiguration()Gets transactions configuration.Map<String,?>getUserAttributes()Should return any user-defined attributes to be added to this node.longgetUtilityCacheKeepAliveTime()Keep alive time of thread pool that is in charge of processing utility cache messages.intgetUtilityCacheThreadPoolSize()Default size of thread pool that is in charge of processing utility cache messages.IgniteInClosure<IgniteConfiguration>getWarmupClosure()Gets grid warmup closure.StringgetWorkDirectory()Gets Ignite work directory.booleanisActiveOnStart()Deprecated.UsegetClusterStateOnStart()instead.booleanisAllSegmentationResolversPassRequired()Gets all segmentation resolvers pass required flag.booleanisAuthenticationEnabled()Returnstrueif user authentication is enabled for cluster.booleanisAutoActivationEnabled()Deprecated.UsegetClusterStateOnStart()instead.booleanisCacheSanityCheckEnabled()Gets flag indicating whether cache sanity check is enabled.BooleanisClientMode()Gets client mode flag.booleanisLateAffinityAssignment()Deprecated.Starting from Ignite 2.1 late affinity assignment is always enabled.booleanisMarshalLocalJobs()If this flag is set totrue, jobs mapped to local node will be marshalled as if it was remote node.booleanisPeerClassLoadingEnabled()Returnstrueif peer class loading is enabled,falseotherwise.booleanisPersistentStoreEnabled()Deprecated.Part of legacy configuration API.booleanisWaitForSegmentOnStart()Gets wait for segment on startup flag.IgniteConfigurationsetActiveOnStart(boolean activeOnStart)Deprecated.UsesetClusterStateOnStart(ClusterState)instead.IgniteConfigurationsetAddressResolver(AddressResolver addrRslvr)Sets address resolver for addresses mapping determination.IgniteConfigurationsetAllSegmentationResolversPassRequired(boolean allResolversPassReq)Sets all segmentation resolvers pass required flag.IgniteConfigurationsetAsyncCallbackPoolSize(int poolSize)Sets async callback thread pool size to use within grid.IgniteConfigurationsetAsyncContinuationExecutor(Executor asyncContinuationExecutor)Sets the continuation executor for cache async APIs.IgniteConfigurationsetAtomicConfiguration(AtomicConfiguration atomicCfg)IgniteConfigurationsetAuthenticationEnabled(boolean authEnabled)Sets flag indicating whether the user authentication is enabled for cluster.IgniteConfigurationsetAutoActivationEnabled(boolean autoActivation)Deprecated.UsesetClusterStateOnStart(ClusterState)instead.IgniteConfigurationsetBinaryConfiguration(BinaryConfiguration binaryCfg)Sets configuration for Ignite Binary objects.IgniteConfigurationsetBuildIndexThreadPoolSize(int poolSize)Sets index create/rebuild thread pool size to use within grid.IgniteConfigurationsetCacheConfiguration(CacheConfiguration... cacheCfg)Sets cache configurations.IgniteConfigurationsetCacheKeyConfiguration(CacheKeyConfiguration... cacheKeyCfg)Sets cache key configuration.IgniteConfigurationsetCacheSanityCheckEnabled(boolean cacheSanityCheckEnabled)Sets cache sanity check flag.IgniteConfigurationsetCacheStoreSessionListenerFactories(javax.cache.configuration.Factory<CacheStoreSessionListener>... storeSesLsnrs)Cache store session listener factories.IgniteConfigurationsetCheckpointSpi(CheckpointSpi... cpSpi)Sets fully configured instance ofCheckpointSpi.IgniteConfigurationsetClassLoader(ClassLoader classLdr)Sets loader which will be used for instantiating execution context (EntryProcessors,CacheEntryListeners,CacheLoadersandExpiryPolicys).IgniteConfigurationsetClientConnectorConfiguration(@Nullable ClientConnectorConfiguration cliConnCfg)Sets client connector configuration.IgniteConfigurationsetClientFailureDetectionTimeout(long clientFailureDetectionTimeout)Sets failure detection timeout to use inTcpDiscoverySpiandTcpCommunicationSpi.IgniteConfigurationsetClientMode(boolean clientMode)Sets client mode flag.IgniteConfigurationsetClusterStateOnStart(ClusterState state)Sets state of cluster on start.IgniteConfigurationsetCollisionSpi(CollisionSpi colSpi)Sets fully configured instance ofCollisionSpi.IgniteConfigurationsetCommunicationFailureResolver(CommunicationFailureResolver commFailureRslvr)IgniteConfigurationsetCommunicationSpi(CommunicationSpi commSpi)Sets fully configured instance ofCommunicationSpi.IgniteConfigurationsetConnectorConfiguration(ConnectorConfiguration connectorCfg)IgniteConfigurationsetConsistentId(Serializable consistentId)Sets consistent globally unique node ID which survives node restarts.IgniteConfigurationsetDataStorageConfiguration(DataStorageConfiguration dsCfg)Sets durable memory configuration.IgniteConfigurationsetDataStreamerThreadPoolSize(int poolSize)Set thread pool size that will be used to process data stream messages.IgniteConfigurationsetDefaultQueryTimeout(long dfltQryTimeout)Deprecated.UseSqlConfiguration.setDefaultQueryTimeout(long)instead.IgniteConfigurationsetDeploymentMode(DeploymentMode deployMode)Sets task classes and resources sharing mode.IgniteConfigurationsetDeploymentSpi(DeploymentSpi deploySpi)Sets fully configured instance ofDeploymentSpi.IgniteConfigurationsetDiscoverySpi(DiscoverySpi discoSpi)Sets fully configured instance ofDiscoverySpi.IgniteConfigurationsetDiscoveryStartupDelay(long discoStartupDelay)Deprecated.Not used any more.IgniteConfigurationsetDistributedPropertiesDefaultValues(Map<String,String> distrProps)Sets default values for distributed properties.IgniteConfigurationsetEncryptionSpi(EncryptionSpi encryptionSpi)Sets fully configured instances ofEncryptionSpi.IgniteConfigurationsetEventStorageSpi(EventStorageSpi evtSpi)Sets fully configured instance ofEventStorageSpi.IgniteConfigurationsetExecutorConfiguration(ExecutorConfiguration... execCfgs)Sets custom executors for user compute tasks.IgniteConfigurationsetFailoverSpi(FailoverSpi... failSpi)Sets fully configured instance ofFailoverSpi.IgniteConfigurationsetFailureDetectionTimeout(long failureDetectionTimeout)Sets failure detection timeout to use inTcpDiscoverySpiandTcpCommunicationSpi.IgniteConfigurationsetFailureHandler(FailureHandler failureHnd)Sets failure handler.IgniteConfigurationsetGridLogger(IgniteLogger log)Sets logger to use within grid.IgniteConfigurationsetGridName(String gridName)Deprecated.UsesetIgniteInstanceName(String)instead.IgniteConfigurationsetIgniteHome(String igniteHome)Sets Ignite installation folder.IgniteConfigurationsetIgniteInstanceName(String instanceName)Sets of local instance name.IgniteConfigurationsetIncludeEventTypes(int... inclEvtTypes)Sets array of event types, which will be recorded byGridEventStorageManager.record(Event).IgniteConfigurationsetIncludeProperties(String... includeProps)Sets array of system or environment property names to include into node attributes.IgniteConfigurationsetIndexingSpi(IndexingSpi indexingSpi)Sets fully configured instances ofIndexingSpi.IgniteConfigurationsetLateAffinityAssignment(boolean lateAffAssignment)Deprecated.Starting from Ignite 2.1 late affinity assignment is always enabled.IgniteConfigurationsetLifecycleBeans(LifecycleBean... lifecycleBeans)Sets a collection of lifecycle beans.IgniteConfigurationsetLoadBalancingSpi(LoadBalancingSpi... loadBalancingSpi)Sets fully configured instance ofLoadBalancingSpi.IgniteConfigurationsetLocalEventListeners(Map<IgnitePredicate<? extends Event>,int[]> lsnrs)Sets map of pre-configured local event listeners.IgniteConfigurationsetLocalHost(String locHost)Sets system-wide local address or host for all Ignite components to bind to.IgniteConfigurationsetLongQueryWarningTimeout(long longQryWarnTimeout)Deprecated.UseSqlConfiguration.setLongQueryWarningTimeout(long)instead.IgniteConfigurationsetManagementThreadPoolSize(int poolSize)Sets management thread pool size to use within grid.IgniteConfigurationsetMarshaller(Marshaller marsh)Deprecated.Since 2.1.IgniteConfigurationsetMarshalLocalJobs(boolean marshLocJobs)Sets marshal local jobs flag.IgniteConfigurationsetMBeanServer(MBeanServer mbeanSrv)Sets initialized and started MBean server.IgniteConfigurationsetMemoryConfiguration(MemoryConfiguration memCfg)Deprecated.UseDataStorageConfigurationinstead.IgniteConfigurationsetMetricExporterSpi(MetricExporterSpi... metricExporterSpi)Sets fully configured instances ofMetricExporterSpi.IgniteConfigurationsetMetricsExpireTime(long metricsExpTime)Sets time in milliseconds after which a certain metric value is considered expired.IgniteConfigurationsetMetricsHistorySize(int metricsHistSize)Sets number of metrics kept in history to compute totals and averages.IgniteConfigurationsetMetricsLogFrequency(long metricsLogFreq)Sets frequency of metrics log print out.IgniteConfigurationsetMetricsUpdateFrequency(long metricsUpdateFreq)Sets Ignite metrics update frequency in milliseconds.voidsetNetworkCompressionLevel(int netCompressionLevel)Sets compression level for internal network messages.IgniteConfigurationsetNetworkSendRetryCount(int sndRetryCnt)Sets message send retries count.IgniteConfigurationsetNetworkSendRetryDelay(long sndRetryDelay)Sets interval in milliseconds between message send retries.IgniteConfigurationsetNetworkTimeout(long netTimeout)Maximum timeout in milliseconds for network requests.IgniteConfigurationsetNodeId(UUID nodeId)Deprecated.UsesetConsistentId(Serializable)instead.IgniteConfigurationsetOdbcConfiguration(OdbcConfiguration odbcCfg)Deprecated.IgniteConfigurationsetPeerClassLoadingEnabled(boolean p2pEnabled)Enables/disables peer class loading.IgniteConfigurationsetPeerClassLoadingLocalClassPathExclude(String... p2pLocClsPathExcl)Sets list of packages in a system class path that should be P2P loaded even if they exist locally.IgniteConfigurationsetPeerClassLoadingMissedResourcesCacheSize(int p2pMissedCacheSize)Sets size of missed resources cache.IgniteConfigurationsetPeerClassLoadingThreadPoolSize(int poolSize)Sets thread pool size to use for peer class loading.IgniteConfigurationsetPersistentStoreConfiguration(PersistentStoreConfiguration pstCfg)Deprecated.Part of old API.IgniteConfigurationsetPlatformConfiguration(PlatformConfiguration platformCfg)Sets platform configuration.IgniteConfigurationsetPluginConfigurations(PluginConfiguration... pluginCfgs)Deprecated.SincePluginProviders can be set explicitly viasetPluginProviders(PluginProvider[])it's preferable to storePluginConfigurationas a part ofPluginProvider.IgniteConfigurationsetPluginProviders(PluginProvider... pluginProvs)Sets plugin providers.IgniteConfigurationsetPublicThreadPoolSize(int poolSize)Sets thread pool size to use within grid.IgniteConfigurationsetQueryThreadPoolSize(int poolSize)Sets query thread pool size to use within grid.IgniteConfigurationsetRebalanceBatchesPrefetchCount(long rebalanceBatchesCnt)The number of batches generated by supply node at rebalancing procedure start.IgniteConfigurationsetRebalanceBatchSize(int rebalanceBatchSize)The supply message size in bytes to be loaded within a single rebalance batch.IgniteConfigurationsetRebalanceThreadPoolSize(int rebalanceThreadPoolSize)Sets Max count of threads can be used at rebalancing.IgniteConfigurationsetRebalanceThrottle(long rebalanceThrottle)Time in milliseconds to wait between rebalance messages to avoid overloading of CPU or network.IgniteConfigurationsetRebalanceTimeout(long rebalanceTimeout)Rebalance timeout for supply and demand messages in milliseconds.IgniteConfigurationsetSegmentationPolicy(SegmentationPolicy segPlc)Sets segmentation policy.IgniteConfigurationsetSegmentationResolveAttempts(int segResolveAttempts)Sets segmentation resolve attempts count.IgniteConfigurationsetSegmentationResolvers(SegmentationResolver... segResolvers)Sets segmentation resolvers.IgniteConfigurationsetSegmentCheckFrequency(long segChkFreq)Sets network segment check frequency.IgniteConfigurationsetServiceConfiguration(ServiceConfiguration... svcCfgs)Sets configurations for services to be deployed on the grid.IgniteConfigurationsetServiceThreadPoolSize(int poolSize)Sets thread pool size to use within grid.IgniteConfigurationsetShutdownPolicy(ShutdownPolicy shutdownPolicy)Sets shutdown policy.IgniteConfigurationsetSnapshotPath(String snapshotPath)IgniteConfigurationsetSnapshotThreadPoolSize(int snapshotThreadPoolSize)IgniteConfigurationsetSqlConfiguration(SqlConfiguration sqlCfg)IgniteConfigurationsetSqlConnectorConfiguration(SqlConnectorConfiguration sqlConnCfg)Deprecated.IgniteConfigurationsetSqlQueryHistorySize(int size)Deprecated.UseSqlConfiguration.getSqlQueryHistorySize()instead.IgniteConfigurationsetSqlSchemas(String... sqlSchemas)Deprecated.UseSqlConfiguration.setSqlSchemas(String...)instead.IgniteConfigurationsetSslContextFactory(javax.cache.configuration.Factory<SSLContext> sslCtxFactory)Sets SSL context factory that will be used for creating a secure socket layer.IgniteConfigurationsetStripedPoolSize(int stripedPoolSize)Sets striped pool size that should be used for cache requests processing.IgniteConfigurationsetSystemThreadPoolSize(int poolSize)Sets system thread pool size to use within grid.IgniteConfigurationsetSystemViewExporterSpi(SystemViewExporterSpi... sysViewExporterSpi)Sets fully configured instances ofSystemViewExporterSpi.IgniteConfigurationsetSystemWorkerBlockedTimeout(long sysWorkerBlockedTimeout)Sets maximum inactivity period for system worker.IgniteConfigurationsetTimeServerPortBase(int timeSrvPortBase)Sets time server port base.IgniteConfigurationsetTimeServerPortRange(int timeSrvPortRange)Sets time server port range.IgniteConfigurationsetTracingSpi(TracingSpi tracingSpi)Set fully configured instance ofTracingSpi.IgniteConfigurationsetTransactionConfiguration(TransactionConfiguration txCfg)Sets transactions configuration.IgniteConfigurationsetUserAttributes(Map<String,?> userAttrs)Sets user attributes for this node.IgniteConfigurationsetUtilityCacheKeepAliveTime(long keepAliveTime)Sets keep alive time of thread pool size that will be used to process utility cache messages.IgniteConfigurationsetUtilityCachePoolSize(int poolSize)Sets default thread pool size that will be used to process utility cache messages.IgniteConfigurationsetWaitForSegmentOnStart(boolean waitForSegOnStart)Sets wait for segment on start flag.IgniteConfigurationsetWarmupClosure(IgniteInClosure<IgniteConfiguration> warmupClos)Sets warmup closure to execute before grid startup.IgniteConfigurationsetWorkDirectory(String igniteWorkDir)Sets Ignite work folder.StringtoString()
-
-
-
Field Detail
-
COURTESY_LOGGER_NAME
public static final String COURTESY_LOGGER_NAME
Courtesy notice log category.- See Also:
- Constant Field Values
-
DFLT_P2P_ENABLED
public static final boolean DFLT_P2P_ENABLED
Default flag for peer class loading. By default the value isfalsewhich means that peer class loading is disabled.- See Also:
- Constant Field Values
-
DFLT_METRICS_HISTORY_SIZE
public static final int DFLT_METRICS_HISTORY_SIZE
Default metrics history size (value is10000).- See Also:
- Constant Field Values
-
DFLT_METRICS_UPDATE_FREQ
public static final long DFLT_METRICS_UPDATE_FREQ
Default metrics update frequency.- See Also:
- Constant Field Values
-
DFLT_METRICS_EXPIRE_TIME
public static final long DFLT_METRICS_EXPIRE_TIME
Default metrics expire time. The value isLong.MAX_VALUEwhich means that metrics never expire.- See Also:
- Constant Field Values
-
DFLT_NETWORK_TIMEOUT
public static final long DFLT_NETWORK_TIMEOUT
Default maximum timeout to wait for network responses in milliseconds (value is5,000ms).- See Also:
- Constant Field Values
-
DFLT_NETWORK_COMPRESSION
public static final int DFLT_NETWORK_COMPRESSION
Default compression level for network messages (value is Deflater.BEST_SPEED.- See Also:
- Constant Field Values
-
DFLT_SEND_RETRY_DELAY
public static final long DFLT_SEND_RETRY_DELAY
Default interval between message send retries.- See Also:
- Constant Field Values
-
DFLT_SEND_RETRY_CNT
public static final int DFLT_SEND_RETRY_CNT
Default message send retries count.- See Also:
- Constant Field Values
-
DFLT_DISCOVERY_STARTUP_DELAY
public static final long DFLT_DISCOVERY_STARTUP_DELAY
Default discovery startup delay in milliseconds (value is60,000ms).- See Also:
- Constant Field Values
-
DFLT_DEPLOYMENT_MODE
public static final DeploymentMode DFLT_DEPLOYMENT_MODE
Default deployment mode (value isDeploymentMode.SHARED).
-
DFLT_P2P_MISSED_RESOURCES_CACHE_SIZE
public static final int DFLT_P2P_MISSED_RESOURCES_CACHE_SIZE
Default cache size for missed resources.- See Also:
- Constant Field Values
-
DFLT_TIME_SERVER_PORT_BASE
public static final int DFLT_TIME_SERVER_PORT_BASE
Default time server port base.- See Also:
- Constant Field Values
-
DFLT_TIME_SERVER_PORT_RANGE
public static final int DFLT_TIME_SERVER_PORT_RANGE
Default time server port range.- See Also:
- Constant Field Values
-
AVAILABLE_PROC_CNT
public static final int AVAILABLE_PROC_CNT
Default core size of public thread pool.
-
DFLT_PUBLIC_THREAD_CNT
public static final int DFLT_PUBLIC_THREAD_CNT
Default core size of public thread pool.
-
DFLT_DATA_STREAMER_POOL_SIZE
public static final int DFLT_DATA_STREAMER_POOL_SIZE
Default size of data streamer thread pool.
-
DFLT_REBALANCE_THREAD_POOL_SIZE
public static final int DFLT_REBALANCE_THREAD_POOL_SIZE
Default limit of threads used for rebalance.
-
DFLT_REBALANCE_TIMEOUT
public static final long DFLT_REBALANCE_TIMEOUT
Default rebalance message timeout in milliseconds (value is10000).- See Also:
- Constant Field Values
-
DFLT_REBALANCE_BATCHES_PREFETCH_COUNT
public static final long DFLT_REBALANCE_BATCHES_PREFETCH_COUNT
Default rebalance batches prefetch count (value is3).- See Also:
- Constant Field Values
-
DFLT_REBALANCE_THROTTLE
public static final long DFLT_REBALANCE_THROTTLE
Time to wait between rebalance messages in milliseconds to avoid overloading CPU (value is0).- See Also:
- Constant Field Values
-
DFLT_REBALANCE_BATCH_SIZE
public static final int DFLT_REBALANCE_BATCH_SIZE
Default rebalance batch size in bytes (value is512Kb).- See Also:
- Constant Field Values
-
DFLT_SYSTEM_CORE_THREAD_CNT
public static final int DFLT_SYSTEM_CORE_THREAD_CNT
Default size of system thread pool.
-
DFLT_QUERY_THREAD_POOL_SIZE
public static final int DFLT_QUERY_THREAD_POOL_SIZE
Default size of query thread pool.
-
DFLT_BUILD_IDX_THREAD_POOL_SIZE
public static final int DFLT_BUILD_IDX_THREAD_POOL_SIZE
Default size of index create/rebuild thread pool.
-
DFLT_THREAD_KEEP_ALIVE_TIME
public static final long DFLT_THREAD_KEEP_ALIVE_TIME
Default Ignite thread keep alive time.- See Also:
- Constant Field Values
-
DFLT_P2P_THREAD_CNT
public static final int DFLT_P2P_THREAD_CNT
Default size of peer class loading thread pool.- See Also:
- Constant Field Values
-
DFLT_MGMT_THREAD_CNT
public static final int DFLT_MGMT_THREAD_CNT
Default size of management thread pool.- See Also:
- Constant Field Values
-
DFLT_SEG_PLC
public static final SegmentationPolicy DFLT_SEG_PLC
Default segmentation policy.
-
DFLT_WAIT_FOR_SEG_ON_START
public static final boolean DFLT_WAIT_FOR_SEG_ON_START
Default value for wait for segment on startup flag.- See Also:
- Constant Field Values
-
DFLT_ALL_SEG_RESOLVERS_PASS_REQ
public static final boolean DFLT_ALL_SEG_RESOLVERS_PASS_REQ
Default value for all segmentation resolvers pass required.- See Also:
- Constant Field Values
-
DFLT_SEG_RESOLVE_ATTEMPTS
public static final int DFLT_SEG_RESOLVE_ATTEMPTS
Default value segmentation resolve attempts count.- See Also:
- Constant Field Values
-
DFLT_SEG_CHK_FREQ
public static final long DFLT_SEG_CHK_FREQ
Default segment check frequency in discovery manager.- See Also:
- Constant Field Values
-
DFLT_METRICS_LOG_FREQ
public static final long DFLT_METRICS_LOG_FREQ
Default frequency of metrics log print out.- See Also:
- Constant Field Values
-
DFLT_TCP_PORT
public static final int DFLT_TCP_PORT
Default TCP server port.- See Also:
- Constant Field Values
-
DFLT_MARSHAL_LOCAL_JOBS
public static final boolean DFLT_MARSHAL_LOCAL_JOBS
Default marshal local jobs flag.- See Also:
- Constant Field Values
-
DFLT_CACHE_SANITY_CHECK_ENABLED
public static final boolean DFLT_CACHE_SANITY_CHECK_ENABLED
Default value for cache sanity check enabled flag.- See Also:
- Constant Field Values
-
DFLT_SNAPSHOT_DIRECTORY
public static final String DFLT_SNAPSHOT_DIRECTORY
Default relative working directory path for snapshot operation result. The default directory is snapshots.- See Also:
- Constant Field Values
-
DFLT_SNAPSHOT_THREAD_POOL_SIZE
public static final int DFLT_SNAPSHOT_THREAD_POOL_SIZE
Default number of threads to perform snapshot operations. The default value is 4.- See Also:
- Constant Field Values
-
DFLT_LATE_AFF_ASSIGNMENT
@Deprecated public static final boolean DFLT_LATE_AFF_ASSIGNMENT
Deprecated.Default value for late affinity assignment flag.- See Also:
- Constant Field Values
-
DFLT_STATE_ON_START
public static final ClusterState DFLT_STATE_ON_START
Default value for cluster state on start.
-
DFLT_ACTIVE_ON_START
@Deprecated public static final boolean DFLT_ACTIVE_ON_START
Deprecated.Default value for active on start flag.- See Also:
- Constant Field Values
-
DFLT_AUTO_ACTIVATION
@Deprecated public static final boolean DFLT_AUTO_ACTIVATION
Deprecated.Default value for auto-activation flag.- See Also:
- Constant Field Values
-
DFLT_FAILURE_DETECTION_TIMEOUT
public static final Long DFLT_FAILURE_DETECTION_TIMEOUT
Default failure detection timeout in millis.
-
DFLT_CLIENT_FAILURE_DETECTION_TIMEOUT
public static final Long DFLT_CLIENT_FAILURE_DETECTION_TIMEOUT
Default failure detection timeout for client nodes in millis.
-
DFLT_SHUTDOWN_POLICY
public static final ShutdownPolicy DFLT_SHUTDOWN_POLICY
Default policy for node shutdown.
-
DFLT_LONG_QRY_WARN_TIMEOUT
@Deprecated public static final long DFLT_LONG_QRY_WARN_TIMEOUT
Deprecated.Please useSqlConfiguration.DFLT_LONG_QRY_WARN_TIMEOUT.Default timeout after which long query warning will be printed.- See Also:
- Constant Field Values
-
DFLT_SQL_QUERY_HISTORY_SIZE
@Deprecated public static final int DFLT_SQL_QUERY_HISTORY_SIZE
Deprecated.Please useSqlConfiguration.DFLT_SQL_QUERY_HISTORY_SIZE.Default SQL query history size.- See Also:
- Constant Field Values
-
shutdown
public ShutdownPolicy shutdown
Shutdown policy for cluster.
-
-
Constructor Detail
-
IgniteConfiguration
public IgniteConfiguration()
Creates valid grid configuration with all default values.
-
IgniteConfiguration
public IgniteConfiguration(IgniteConfiguration cfg)
Creates grid configuration by coping all configuration properties from given configuration.- Parameters:
cfg- Grid configuration to copy from.
-
-
Method Detail
-
getCommunicationFailureResolver
public CommunicationFailureResolver getCommunicationFailureResolver()
- Returns:
- Communication failure resovler.
-
setCommunicationFailureResolver
public IgniteConfiguration setCommunicationFailureResolver(CommunicationFailureResolver commFailureRslvr)
- Parameters:
commFailureRslvr- Communication failure resovler.- Returns:
thisinstance.
-
getGridName
@Deprecated public String getGridName()
Deprecated.UsegetIgniteInstanceName()instead.Gets optional grid name. Returnsnullif non-default grid name was not provided.The name only works locally and has no effect on topology
- Returns:
- Optional grid name. Can be
null, which is default grid name, if non-default grid name was not provided.
-
getIgniteInstanceName
public String getIgniteInstanceName()
Gets optional local instance name. Returnsnullif non-default local instance name was not provided.The name only works locally and has no effect on topology
- Returns:
- Optional local instance name. Can be
null, which is default local instance name, if non-default local instance name was not provided.
-
setGridName
@Deprecated public IgniteConfiguration setGridName(String gridName)
Deprecated.UsesetIgniteInstanceName(String)instead.Sets grid name. Note thatnullis a default grid name.- Parameters:
gridName- Grid name to set. Can benull, which is default grid name.- Returns:
thisfor chaining.
-
setIgniteInstanceName
public IgniteConfiguration setIgniteInstanceName(String instanceName)
Sets of local instance name. Note thatnullis a default local instance name.- Parameters:
instanceName- Local instance name to set. Can benull. which is default local instance name.- Returns:
thisfor chaining.
-
setConsistentId
public IgniteConfiguration setConsistentId(Serializable consistentId)
Sets consistent globally unique node ID which survives node restarts.- Parameters:
consistentId- Node consistent ID.- Returns:
thisfor chaining.
-
getConsistentId
public Serializable getConsistentId()
Gets consistent globally unique node ID which survives node restarts.- Returns:
- Node consistent ID.
-
getUserAttributes
public Map<String,?> getUserAttributes()
Should return any user-defined attributes to be added to this node. These attributes can then be accessed on nodes by callingClusterNode.attribute(String)orClusterNode.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.igniteare reserved for internal use.- Returns:
- User defined attributes for this node.
-
setUserAttributes
public IgniteConfiguration setUserAttributes(Map<String,?> userAttrs)
Sets user attributes for this node.- Parameters:
userAttrs- User attributes for this node.- Returns:
thisfor chaining.- See Also:
getUserAttributes()
-
getGridLogger
public IgniteLogger getGridLogger()
Should return an instance of logger to use in grid. If not provided,Log4J2Loggerwill be used.- Returns:
- Logger to use in grid.
-
setGridLogger
public IgniteConfiguration setGridLogger(IgniteLogger log)
Sets logger to use within grid.- Parameters:
log- Logger to use within grid.- Returns:
thisfor chaining.- See Also:
getGridLogger()
-
getStripedPoolSize
public int getStripedPoolSize()
Returns striped pool size that should be used for cache requests processing.Striped pool is better for typical cache operations.
- Returns:
- The number of threads (stripes) to be used for requests processing.
- See Also:
getPublicThreadPoolSize(),getSystemThreadPoolSize()
-
setStripedPoolSize
public IgniteConfiguration setStripedPoolSize(int stripedPoolSize)
Sets striped pool size that should be used for cache requests processing.Striped pool is better for typical cache operations.
- Parameters:
stripedPoolSize- The number of threads (stripes) to be used for requests processing.- Returns:
thisfor chaining.- See Also:
getPublicThreadPoolSize(),getSystemThreadPoolSize()
-
getPublicThreadPoolSize
public int getPublicThreadPoolSize()
Should return a thread pool size to be used in grid. This executor service will be in charge of processingGridJobsand user messages sent to node.If not provided, executor service will have size
DFLT_PUBLIC_THREAD_CNT.- Returns:
- Thread pool size to be used in grid to process job execution requests and user messages sent to the node.
-
getServiceThreadPoolSize
public int getServiceThreadPoolSize()
Should return a thread pool size to be used in grid. This executor service will be in charge of processingServiceproxy invocations.If not provided, executor service will have size
DFLT_PUBLIC_THREAD_CNT.- Returns:
- Thread pool size to be used in grid to process service proxy invocations.
-
getSystemThreadPoolSize
public int getSystemThreadPoolSize()
Size of thread pool that is in charge of processing internal system messages.If not provided, executor service will have size
DFLT_SYSTEM_CORE_THREAD_CNT.- Returns:
- Thread pool size to be used in grid for internal system messages.
-
getAsyncCallbackPoolSize
public int getAsyncCallbackPoolSize()
Size of thread pool that is in charge of processing asynchronous callbacks.This pool is used for callbacks annotated with
IgniteAsyncCallback.If not provided, executor service will have size
DFLT_PUBLIC_THREAD_CNT.- Returns:
- Thread pool size to be used.
- See Also:
IgniteAsyncCallback
-
getManagementThreadPoolSize
public int getManagementThreadPoolSize()
Size of thread pool that is in charge of processing internal and VisorGridJobs.If not provided, executor service will have size
DFLT_MGMT_THREAD_CNT- Returns:
- Thread pool size to be used in grid for internal and Visor jobs processing.
-
getPeerClassLoadingThreadPoolSize
public int getPeerClassLoadingThreadPoolSize()
Size of thread pool which is in charge of peer class loading requests/responses. If you don't use peer class loading and use GAR deployment only we would recommend to decrease the value of total threads to1.If not provided, executor service will have size
DFLT_P2P_THREAD_CNT.- Returns:
- Thread pool size to be used for peer class loading requests handling.
-
getDataStreamerThreadPoolSize
public int getDataStreamerThreadPoolSize()
Size of thread pool that is in charge of processing data stream messages.If not provided, executor service will have size
DFLT_DATA_STREAMER_POOL_SIZE.- Returns:
- Thread pool size to be used for data stream messages.
-
getUtilityCacheThreadPoolSize
public int getUtilityCacheThreadPoolSize()
Default size of thread pool that is in charge of processing utility cache messages.If not provided, executor service will have size
DFLT_SYSTEM_CORE_THREAD_CNT.- Returns:
- Default thread pool size to be used in grid for utility cache messages.
-
getUtilityCacheKeepAliveTime
public long getUtilityCacheKeepAliveTime()
Keep alive time of thread pool that is in charge of processing utility cache messages.If not provided, executor service will have keep alive time
DFLT_THREAD_KEEP_ALIVE_TIME.- Returns:
- Thread pool keep alive time (in milliseconds) to be used in grid for utility cache messages.
-
getQueryThreadPoolSize
public int getQueryThreadPoolSize()
Size of thread pool that is in charge of processing query messages.If not provided, executor service will have size
DFLT_QUERY_THREAD_POOL_SIZE.- Returns:
- Thread pool size to be used in grid for query messages.
-
getBuildIndexThreadPoolSize
public int getBuildIndexThreadPoolSize()
Size of thread pool for create/rebuild index.If not provided, executor service will have size
DFLT_BUILD_IDX_THREAD_POOL_SIZE.- Returns:
- Thread pool size for create/rebuild index.
-
setBuildIndexThreadPoolSize
public IgniteConfiguration setBuildIndexThreadPoolSize(int poolSize)
Sets index create/rebuild thread pool size to use within grid.- Parameters:
poolSize- Thread pool size to use within grid.- Returns:
thisfor chaining.- See Also:
getBuildIndexThreadPoolSize()
-
getSqlQueryHistorySize
@Deprecated public int getSqlQueryHistorySize()
Deprecated.UseSqlConfiguration.setSqlQueryHistorySize(int)instead.Number of SQL query history elements to keep in memory. If not provided, then default valueSqlConfiguration.DFLT_SQL_QUERY_HISTORY_SIZEis used. If provided value is less or equals 0, then gathering SQL query history will be switched off.- Returns:
- SQL query history size.
-
setSqlQueryHistorySize
@Deprecated public IgniteConfiguration setSqlQueryHistorySize(int size)
Deprecated.UseSqlConfiguration.getSqlQueryHistorySize()instead.Sets number of SQL query history elements kept in memory. If not explicitly set, then default value isSqlConfiguration.DFLT_SQL_QUERY_HISTORY_SIZE.- Parameters:
size- Number of SQL query history elements kept in memory.- Returns:
thisfor chaining.
-
getShutdownPolicy
public ShutdownPolicy getShutdownPolicy()
Gets shutdown policy. If policy was not set default policy will be returnIgniteCluster.DEFAULT_SHUTDOWN_POLICY.- Returns:
- Shutdown policy.
-
setShutdownPolicy
public IgniteConfiguration setShutdownPolicy(ShutdownPolicy shutdownPolicy)
Sets shutdown policy. Ifnullis passed as a parameter, policy will be set as default.- Parameters:
shutdownPolicy- Shutdown policy.- Returns:
thisfor chaining.
-
getDefaultQueryTimeout
@Deprecated public long getDefaultQueryTimeout()
Deprecated.UseSqlConfiguration.getDefaultQueryTimeout()instead.Defines the default query timeout. Defaults toSqlConfiguration.DFLT_QRY_TIMEOUT.0means there is no timeout (this is a default value)- Returns:
- Default query timeout.
-
setDefaultQueryTimeout
@Deprecated public IgniteConfiguration setDefaultQueryTimeout(long dfltQryTimeout)
Deprecated.UseSqlConfiguration.setDefaultQueryTimeout(long)instead.Sets timeout in milliseconds for default query timeout.0means there is no timeout (this is a default value)- Parameters:
dfltQryTimeout- Timeout in milliseconds.- Returns:
thisfor chaining.
-
setPublicThreadPoolSize
public IgniteConfiguration setPublicThreadPoolSize(int poolSize)
Sets thread pool size to use within grid.- Parameters:
poolSize- Thread pool size to use within grid.- Returns:
thisfor chaining.- See Also:
getPublicThreadPoolSize()
-
setServiceThreadPoolSize
public IgniteConfiguration setServiceThreadPoolSize(int poolSize)
Sets thread pool size to use within grid.- Parameters:
poolSize- Thread pool size to use within grid.- Returns:
thisfor chaining.- See Also:
getServiceThreadPoolSize()
-
setSystemThreadPoolSize
public IgniteConfiguration setSystemThreadPoolSize(int poolSize)
Sets system thread pool size to use within grid.- Parameters:
poolSize- Thread pool size to use within grid.- Returns:
thisfor chaining.- See Also:
getSystemThreadPoolSize()
-
setAsyncCallbackPoolSize
public IgniteConfiguration setAsyncCallbackPoolSize(int poolSize)
Sets async callback thread pool size to use within grid.- Parameters:
poolSize- Thread pool size to use within grid.- Returns:
thisfor chaining.- See Also:
getAsyncCallbackPoolSize(),IgniteAsyncCallback
-
setManagementThreadPoolSize
public IgniteConfiguration setManagementThreadPoolSize(int poolSize)
Sets management thread pool size to use within grid.- Parameters:
poolSize- Thread pool size to use within grid.- Returns:
thisfor chaining.- See Also:
getManagementThreadPoolSize()
-
setPeerClassLoadingThreadPoolSize
public IgniteConfiguration setPeerClassLoadingThreadPoolSize(int poolSize)
Sets thread pool size to use for peer class loading.- Parameters:
poolSize- Thread pool size to use within grid.- Returns:
thisfor chaining.- See Also:
getPeerClassLoadingThreadPoolSize()
-
setDataStreamerThreadPoolSize
public IgniteConfiguration setDataStreamerThreadPoolSize(int poolSize)
Set thread pool size that will be used to process data stream messages.- Parameters:
poolSize- Executor service to use for data stream messages.- Returns:
thisfor chaining.- See Also:
getDataStreamerThreadPoolSize()
-
setUtilityCachePoolSize
public IgniteConfiguration setUtilityCachePoolSize(int poolSize)
Sets default thread pool size that will be used to process utility cache messages.- Parameters:
poolSize- Default executor service size to use for utility cache messages.- Returns:
thisfor chaining.- See Also:
getUtilityCacheThreadPoolSize(),getUtilityCacheKeepAliveTime()
-
setQueryThreadPoolSize
public IgniteConfiguration setQueryThreadPoolSize(int poolSize)
Sets query thread pool size to use within grid.- Parameters:
poolSize- Thread pool size to use within grid.- Returns:
thisfor chaining.- See Also:
getQueryThreadPoolSize()
-
setUtilityCacheKeepAliveTime
public IgniteConfiguration setUtilityCacheKeepAliveTime(long keepAliveTime)
Sets keep alive time of thread pool size that will be used to process utility cache messages.- Parameters:
keepAliveTime- Keep alive time of executor service to use for utility cache messages.- Returns:
thisfor chaining.- See Also:
getUtilityCacheThreadPoolSize(),getUtilityCacheKeepAliveTime()
-
getIgniteHome
public String getIgniteHome()
Should return Ignite installation home folder. If not provided, the system will checkIGNITE_HOMEsystem property and environment variable in that order. IfIGNITE_HOMEstill could not be obtained, then grid will not start and exception will be thrown.- Returns:
- Ignite installation home or
nullto make the system attempt to infer it automatically. - See Also:
IgniteSystemProperties.IGNITE_HOME
-
setIgniteHome
public IgniteConfiguration setIgniteHome(String igniteHome)
Sets Ignite installation folder.- Parameters:
igniteHome-Ignitioninstallation folder.- Returns:
thisfor chaining.- See Also:
getIgniteHome(),IgniteSystemProperties.IGNITE_HOME
-
getWorkDirectory
public String getWorkDirectory()
Gets Ignite work directory. If not provided, the method will use work directory underIGNITE_HOMEspecified bysetIgniteHome(String)orIGNITE_HOMEenvironment variable or system property.If
IGNITE_HOMEis not provided, then system temp directory is used.- Returns:
- Ignite work directory or
nullto make the system attempt to infer it automatically. - See Also:
getIgniteHome(),IgniteSystemProperties.IGNITE_HOME
-
setWorkDirectory
public IgniteConfiguration setWorkDirectory(String igniteWorkDir)
Sets Ignite work folder.- Parameters:
igniteWorkDir-Ignitework directory.- Returns:
thisfor chaining.- See Also:
getWorkDirectory()
-
getMBeanServer
public MBeanServer getMBeanServer()
Should return MBean server instance. If not provided, the system will use default platform MBean server.- Returns:
- MBean server instance or
nullto make the system create a default one. - See Also:
ManagementFactory.getPlatformMBeanServer()
-
setMBeanServer
public IgniteConfiguration setMBeanServer(MBeanServer mbeanSrv)
Sets initialized and started MBean server.- Parameters:
mbeanSrv- Initialized and started MBean server.- Returns:
thisfor chaining.
-
getNodeId
@Deprecated public UUID getNodeId()
Deprecated.Unique identifier for this node within grid.- Returns:
- Unique identifier for this node within grid.
-
setNodeId
@Deprecated public IgniteConfiguration setNodeId(UUID nodeId)
Deprecated.UsesetConsistentId(Serializable)instead.Sets unique identifier for local node.- Parameters:
nodeId- Unique identifier for local node.- Returns:
thisfor chaining.- See Also:
getNodeId()
-
getMarshaller
@Deprecated public Marshaller getMarshaller()
Deprecated.Since 2.1. Some Ignite features will not work if non-null marshaller is set (IgniteCache.withKeepBinary(), .NET, CPP, ODBC)Should return an instance of marshaller to use in grid. If not provided, default marshaller implementation that allows to read object field values without deserialization will be used.- Returns:
- Marshaller to use in grid.
-
setMarshaller
@Deprecated public 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)Sets marshaller to use within grid.- Parameters:
marsh- Marshaller to use within grid.- Returns:
thisfor chaining.- See Also:
getMarshaller()
-
isPeerClassLoadingEnabled
public boolean isPeerClassLoadingEnabled()
Returnstrueif peer class loading is enabled,falseotherwise. Default value isfalsespecified byDFLT_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
ComputeTaskdocumentation for more information about task deployment.- Returns:
trueif peer class loading is enabled,falseotherwise.
-
isMarshalLocalJobs
public boolean isMarshalLocalJobs()
If this flag is set totrue, 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.- Returns:
Trueif local jobs should be marshalled.
-
setMarshalLocalJobs
public IgniteConfiguration setMarshalLocalJobs(boolean marshLocJobs)
Sets marshal local jobs flag.- Parameters:
marshLocJobs-Trueif local jobs should be marshalled.- Returns:
thisfor chaining.
-
setPeerClassLoadingEnabled
public IgniteConfiguration setPeerClassLoadingEnabled(boolean p2pEnabled)
Enables/disables peer class loading.- Parameters:
p2pEnabled-trueif peer class loading is enabled,falseotherwise.- Returns:
thisfor chaining.
-
getPeerClassLoadingLocalClassPathExclude
public 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.- Returns:
- List of peer-to-peer loaded package names.
-
setPeerClassLoadingLocalClassPathExclude
public IgniteConfiguration setPeerClassLoadingLocalClassPathExclude(String... p2pLocClsPathExcl)
Sets list of packages in a system class path that should be P2P loaded even if they exist locally.- Parameters:
p2pLocClsPathExcl- List of P2P loaded packages. Package name supports '*' at the end like in package import clause.- Returns:
thisfor chaining.
-
getMetricsHistorySize
public int getMetricsHistorySize()
Number of node metrics to keep in memory to calculate totals and averages. If not provided (value is0), then default valueDFLT_METRICS_HISTORY_SIZEis used.- Returns:
- Metrics history size.
- See Also:
DFLT_METRICS_HISTORY_SIZE
-
setMetricsHistorySize
public IgniteConfiguration setMetricsHistorySize(int metricsHistSize)
Sets number of metrics kept in history to compute totals and averages. If not explicitly set, then default value is10,000.- Parameters:
metricsHistSize- Number of metrics kept in history to use for metric totals and averages calculations.- Returns:
thisfor chaining.- See Also:
DFLT_METRICS_HISTORY_SIZE
-
getMetricsUpdateFrequency
public long getMetricsUpdateFrequency()
Gets Ignite metrics update frequency in milliseconds.Updating metrics too frequently may have negative performance impact.
If not provided, then default value
DFLT_METRICS_UPDATE_FREQis used.- Returns:
- Metrics update frequency in milliseconds.
- See Also:
DFLT_METRICS_UPDATE_FREQ
-
setMetricsUpdateFrequency
public IgniteConfiguration setMetricsUpdateFrequency(long metricsUpdateFreq)
Sets Ignite metrics update frequency in milliseconds.Positive value defines the actual update frequency. If not provided, then default value
DFLT_METRICS_UPDATE_FREQis used.- Parameters:
metricsUpdateFreq- Metrics update frequency in milliseconds.- Returns:
thisfor chaining.
-
getMetricsExpireTime
public long getMetricsExpireTime()
Elapsed time in milliseconds after which node metrics are considered expired. If not provided, then default valueDFLT_METRICS_EXPIRE_TIMEis used.- Returns:
- Metrics expire time.
- See Also:
DFLT_METRICS_EXPIRE_TIME
-
setMetricsExpireTime
public IgniteConfiguration setMetricsExpireTime(long metricsExpTime)
Sets time in milliseconds after which a certain metric value is considered expired. If not set explicitly, then default value is600,000milliseconds (10 minutes).- Parameters:
metricsExpTime- The metricsExpTime to set.- Returns:
thisfor chaining.- See Also:
DFLT_METRICS_EXPIRE_TIME
-
getNetworkTimeout
public long getNetworkTimeout()
Maximum timeout in milliseconds for network requests.If not provided, then default value
DFLT_NETWORK_TIMEOUTis used.- Returns:
- Maximum timeout for network requests.
- See Also:
DFLT_NETWORK_TIMEOUT
-
setNetworkTimeout
public IgniteConfiguration setNetworkTimeout(long netTimeout)
Maximum timeout in milliseconds for network requests.If not provided (value is
0), then default valueDFLT_NETWORK_TIMEOUTis used.- Parameters:
netTimeout- Maximum timeout for network requests.- Returns:
thisfor chaining.- See Also:
DFLT_NETWORK_TIMEOUT
-
getNetworkCompressionLevel
public int getNetworkCompressionLevel()
Compression level of internal network messages.If not provided, then default value Deflater.BEST_SPEED is used.
- Returns:
- Network messages default compression level.
-
setNetworkCompressionLevel
public void setNetworkCompressionLevel(int netCompressionLevel)
Sets compression level for internal network messages.- Parameters:
netCompressionLevel- Compression level for internal network messages.If not provided, then default value
Deflater.BEST_SPEEDis used.
-
getNetworkSendRetryDelay
public long getNetworkSendRetryDelay()
Interval in milliseconds between message send retries.If not provided, then default value
DFLT_SEND_RETRY_DELAYis used.- Returns:
- Interval between message send retries.
- See Also:
getNetworkSendRetryCount(),DFLT_SEND_RETRY_DELAY
-
setNetworkSendRetryDelay
public IgniteConfiguration setNetworkSendRetryDelay(long sndRetryDelay)
Sets interval in milliseconds between message send retries.If not provided, then default value
DFLT_SEND_RETRY_DELAYis used.- Parameters:
sndRetryDelay- Interval between message send retries.- Returns:
thisfor chaining.
-
getNetworkSendRetryCount
public int getNetworkSendRetryCount()
Message send retries count.If not provided, then default value
DFLT_SEND_RETRY_CNTis used.- Returns:
- Message send retries count.
- See Also:
getNetworkSendRetryDelay(),DFLT_SEND_RETRY_CNT
-
setNetworkSendRetryCount
public IgniteConfiguration setNetworkSendRetryCount(int sndRetryCnt)
Sets message send retries count.If not provided, then default value
DFLT_SEND_RETRY_CNTis used.- Parameters:
sndRetryCnt- Message send retries count.- Returns:
thisfor chaining.
-
getSnapshotThreadPoolSize
public int getSnapshotThreadPoolSize()
- Returns:
- Total number of threads to perform snapshot operation. By default,
the
DFLT_SNAPSHOT_THREAD_POOL_SIZEis used.
-
setSnapshotThreadPoolSize
public IgniteConfiguration setSnapshotThreadPoolSize(int snapshotThreadPoolSize)
- Parameters:
snapshotThreadPoolSize- Total number of threads to perform snapshot operation. By default, theDFLT_SNAPSHOT_THREAD_POOL_SIZEis used.- Returns:
thisfor chaining.
-
getRebalanceThreadPoolSize
public int getRebalanceThreadPoolSize()
Gets Max count of threads can be used at rebalancing. Minimum is 1.- Returns:
- count.
-
setRebalanceThreadPoolSize
public IgniteConfiguration setRebalanceThreadPoolSize(int rebalanceThreadPoolSize)
Sets Max count of threads can be used at rebalancing. Default is1which has minimal impact on the operation of the grid.- Parameters:
rebalanceThreadPoolSize- Number of system threads that will be assigned for partition transfer during rebalancing.- Returns:
thisfor chaining.
-
getRebalanceTimeout
public long getRebalanceTimeout()
Rebalance timeout for supply and demand messages in milliseconds. TherebalanceTimeoutparameter 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, if0than thegetNetworkTimeout()will be used instead.- Returns:
- Rebalance message timeout in milliseconds.
-
setRebalanceTimeout
public IgniteConfiguration setRebalanceTimeout(long rebalanceTimeout)
Rebalance timeout for supply and demand messages in milliseconds. TherebalanceTimeoutparameter 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, if0than thegetNetworkTimeout()will be used instead.- Parameters:
rebalanceTimeout- Rebalance message timeout in milliseconds.- Returns:
thisfor chaining.
-
getRebalanceBatchesPrefetchCount
public long getRebalanceBatchesPrefetchCount()
The number of batches generated by supply node at rebalancing procedure start. To gain better rebalancing performance supplier node can provide more than one batch at rebalancing start and provide one new to each next demand request.Default value is defined by
DFLT_REBALANCE_BATCHES_PREFETCH_COUNT, minimum value is1.- Returns:
- The number of batches prefetch count.
-
setRebalanceBatchesPrefetchCount
public IgniteConfiguration setRebalanceBatchesPrefetchCount(long rebalanceBatchesCnt)
The number of batches generated by supply node at rebalancing procedure start. To gain better rebalancing performance supplier node can provide more than one batch at rebalancing start and provide one new to each next demand request.Default value is defined by
DFLT_REBALANCE_BATCHES_PREFETCH_COUNT, minimum value is1.- Parameters:
rebalanceBatchesCnt- The number of batches prefetch count.- Returns:
thisfor chaining.
-
getRebalanceThrottle
public long getRebalanceThrottle()
Time in milliseconds to wait between rebalance messages to avoid overloading of CPU or network. When rebalancing large data sets, the CPU or network can get over-consumed with rebalancing messages, which consecutively may slow down the application performance. This parameter helps tune the amount of time to wait between rebalance messages to make sure that rebalancing process does not have any negative performance impact. Note that application will continue to work properly while rebalancing is still in progress.Value of
0means that throttling is disabled. By default throttling is disabled - the default is defined byDFLT_REBALANCE_THROTTLEconstant.- Returns:
- Time in milliseconds to wait between rebalance messages,
0to disable throttling.
-
setRebalanceThrottle
public IgniteConfiguration setRebalanceThrottle(long rebalanceThrottle)
Time in milliseconds to wait between rebalance messages to avoid overloading of CPU or network. When rebalancing large data sets, the CPU or network can get over-consumed with rebalancing messages, which consecutively may slow down the application performance. This parameter helps tune the amount of time to wait between rebalance messages to make sure that rebalancing process does not have any negative performance impact. Note that application will continue to work properly while rebalancing is still in progress.Value of
0means that throttling is disabled. By default throttling is disabled - the default is defined byDFLT_REBALANCE_THROTTLEconstant.- Parameters:
rebalanceThrottle- Time in milliseconds to wait between rebalance messages,0to disable throttling.- Returns:
thisfor chaining.
-
getRebalanceBatchSize
public int getRebalanceBatchSize()
The supply message size in bytes to be loaded within a single rebalance batch. The data balancing algorithm splits all the cache data entries on supply node into multiple batches prior to sending them to the demand node.Default value is defined by
DFLT_REBALANCE_BATCH_SIZE.- Returns:
- Rebalance message size in bytes.
-
setRebalanceBatchSize
public IgniteConfiguration setRebalanceBatchSize(int rebalanceBatchSize)
The supply message size in bytes to be loaded within a single rebalance batch. The data balancing algorithm splits all the cache data entries on supply node into multiple batches prior to sending them to the demand node.Default value is defined by
DFLT_REBALANCE_BATCH_SIZE.- Parameters:
rebalanceBatchSize- Rebalance message size in bytes.- Returns:
thisfor chaining.
-
getLifecycleBeans
public LifecycleBean[] getLifecycleBeans()
Returns a collection of life-cycle beans. These beans will be automatically notified of grid life-cycle events. Use life-cycle beans whenever you want to perform certain logic before and after grid startup and stopping routines.- Returns:
- Collection of life-cycle beans.
- See Also:
LifecycleBean,LifecycleEventType
-
setLifecycleBeans
public IgniteConfiguration setLifecycleBeans(LifecycleBean... lifecycleBeans)
Sets a collection of lifecycle beans. These beans will be automatically notified of grid lifecycle events. Use lifecycle beans whenever you want to perform certain logic before and after grid startup and stopping routines.- Parameters:
lifecycleBeans- Collection of lifecycle beans.- Returns:
thisfor chaining.- See Also:
LifecycleEventType
-
setSslContextFactory
public IgniteConfiguration setSslContextFactory(javax.cache.configuration.Factory<SSLContext> sslCtxFactory)
Sets SSL context factory that will be used for creating a secure socket layer.- Parameters:
sslCtxFactory- Ssl context factory.- Returns:
thisfor chaining.- See Also:
SslContextFactory
-
getSslContextFactory
public javax.cache.configuration.Factory<SSLContext> getSslContextFactory()
Returns SSL context factory that will be used for creating a secure socket layer.- Returns:
- SSL connection factory.
- See Also:
SslContextFactory
-
getEventStorageSpi
public EventStorageSpi getEventStorageSpi()
Should return fully configured event SPI implementation. If not provided,NoopEventStorageSpiwill be used.- Returns:
- Grid event SPI implementation or
nullto use default implementation.
-
setEventStorageSpi
public IgniteConfiguration setEventStorageSpi(EventStorageSpi evtSpi)
Sets fully configured instance ofEventStorageSpi.- Parameters:
evtSpi- Fully configured instance ofEventStorageSpi.- Returns:
thisfor chaining.- See Also:
getEventStorageSpi()
-
getDiscoverySpi
public DiscoverySpi getDiscoverySpi()
Should return fully configured discovery SPI implementation. If not provided,TcpDiscoverySpiwill be used by default.- Returns:
- Grid discovery SPI implementation or
nullto use default implementation.
-
setDiscoverySpi
public IgniteConfiguration setDiscoverySpi(DiscoverySpi discoSpi)
Sets fully configured instance ofDiscoverySpi.- Parameters:
discoSpi- Fully configured instance ofDiscoverySpi.- Returns:
thisfor chaining.- See Also:
getDiscoverySpi()
-
getSegmentationPolicy
public SegmentationPolicy getSegmentationPolicy()
Returns segmentation policy. Default isDFLT_SEG_PLC.- Returns:
- Segmentation policy.
-
setSegmentationPolicy
public IgniteConfiguration setSegmentationPolicy(SegmentationPolicy segPlc)
Sets segmentation policy.- Parameters:
segPlc- Segmentation policy.- Returns:
thisfor chaining.
-
isWaitForSegmentOnStart
public boolean isWaitForSegmentOnStart()
Gets wait for segment on startup flag. Default isDFLT_WAIT_FOR_SEG_ON_START.Returns
trueif node should wait for correct segment on start. If node detects that segment is incorrect on startup and this method returnstrue, node waits until segment becomes correct. If segment is incorrect on startup and this method returnsfalse, exception is thrown.- Returns:
Trueto wait for segment on startup,falseotherwise.
-
setWaitForSegmentOnStart
public IgniteConfiguration setWaitForSegmentOnStart(boolean waitForSegOnStart)
Sets wait for segment on start flag.- Parameters:
waitForSegOnStart-Trueto wait for segment on start.- Returns:
thisfor chaining.
-
isAllSegmentationResolversPassRequired
public boolean isAllSegmentationResolversPassRequired()
Gets all segmentation resolvers pass required flag.Returns
trueif all segmentation resolvers should succeed for node to be in correct segment. Returnsfalseif at least one segmentation resolver should succeed for node to be in correct segment.Default is
DFLT_ALL_SEG_RESOLVERS_PASS_REQ.- Returns:
Trueif all segmentation resolvers should succeed,falseif only one is enough.
-
setAllSegmentationResolversPassRequired
public IgniteConfiguration setAllSegmentationResolversPassRequired(boolean allResolversPassReq)
Sets all segmentation resolvers pass required flag.- Parameters:
allResolversPassReq-Trueif all segmentation resolvers should succeed for node to be in the correct segment.- Returns:
thisfor chaining.
-
getSegmentationResolveAttempts
public int getSegmentationResolveAttempts()
Gets segmentation resolve attempts. Each configured resolver will have this attempts number to pass segmentation check prior to check failure. Default isDFLT_SEG_RESOLVE_ATTEMPTS.- Returns:
- Segmentation resolve attempts.
-
setSegmentationResolveAttempts
public IgniteConfiguration setSegmentationResolveAttempts(int segResolveAttempts)
Sets segmentation resolve attempts count.- Parameters:
segResolveAttempts- Segmentation resolve attempts.- Returns:
thisfor chaining.
-
getSegmentationResolvers
public SegmentationResolver[] getSegmentationResolvers()
Returns a collection of segmentation resolvers.If array is
nullor empty, periodical and on-start network segment checks do not happen.- Returns:
- Segmentation resolvers.
-
setSegmentationResolvers
public IgniteConfiguration setSegmentationResolvers(SegmentationResolver... segResolvers)
Sets segmentation resolvers.- Parameters:
segResolvers- Segmentation resolvers.- Returns:
thisfor chaining.
-
getSegmentCheckFrequency
public long getSegmentCheckFrequency()
Returns frequency of network segment check by discovery manager.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.- Returns:
- Segment check frequency.
-
setSegmentCheckFrequency
public IgniteConfiguration setSegmentCheckFrequency(long segChkFreq)
Sets network segment check frequency.- Parameters:
segChkFreq- Segment check frequency.- Returns:
thisfor chaining.
-
getCommunicationSpi
public CommunicationSpi getCommunicationSpi()
Should return fully configured SPI communication implementation. If not provided,TcpCommunicationSpiwill be used by default.- Returns:
- Grid communication SPI implementation or
nullto use default implementation.
-
setCommunicationSpi
public IgniteConfiguration setCommunicationSpi(CommunicationSpi commSpi)
Sets fully configured instance ofCommunicationSpi.- Parameters:
commSpi- Fully configured instance ofCommunicationSpi.- Returns:
thisfor chaining.- See Also:
getCommunicationSpi()
-
getCollisionSpi
public CollisionSpi getCollisionSpi()
Should return fully configured collision SPI implementation. If not provided,NoopCollisionSpiis 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 bygetPublicThreadPoolSize()configuration property.- Returns:
- Grid collision SPI implementation or
nullto use default implementation.
-
setCollisionSpi
public IgniteConfiguration setCollisionSpi(CollisionSpi colSpi)
Sets fully configured instance ofCollisionSpi.- Parameters:
colSpi- Fully configured instance ofCollisionSpiornullif no SPI provided.- Returns:
thisfor chaining.- See Also:
getCollisionSpi()
-
getDeploymentSpi
public DeploymentSpi getDeploymentSpi()
Should return fully configured deployment SPI implementation. If not provided,LocalDeploymentSpiwill be used.- Returns:
- Grid deployment SPI implementation or
nullto use default implementation.
-
setDeploymentSpi
public IgniteConfiguration setDeploymentSpi(DeploymentSpi deploySpi)
Sets fully configured instance ofDeploymentSpi.- Parameters:
deploySpi- Fully configured instance ofDeploymentSpi.- Returns:
thisfor chaining.- See Also:
getDeploymentSpi()
-
getCheckpointSpi
public CheckpointSpi[] getCheckpointSpi()
Should return fully configured checkpoint SPI implementation. If not provided,NoopCheckpointSpiwill be used.- Returns:
- Grid checkpoint SPI implementation or
nullto use default implementation.
-
setCheckpointSpi
public IgniteConfiguration setCheckpointSpi(CheckpointSpi... cpSpi)
Sets fully configured instance ofCheckpointSpi.- Parameters:
cpSpi- Fully configured instance ofCheckpointSpi.- Returns:
thisfor chaining.- See Also:
getCheckpointSpi()
-
getFailoverSpi
public FailoverSpi[] getFailoverSpi()
Should return fully configured failover SPI implementation. If not provided,AlwaysFailoverSpiwill be used.- Returns:
- Grid failover SPI implementation or
nullto use default implementation.
-
setFailoverSpi
public IgniteConfiguration setFailoverSpi(FailoverSpi... failSpi)
Sets fully configured instance ofFailoverSpi.- Parameters:
failSpi- Fully configured instance ofFailoverSpiornullif no SPI provided.- Returns:
thisfor chaining.- See Also:
getFailoverSpi()
-
getClientFailureDetectionTimeout
public Long getClientFailureDetectionTimeout()
Returns failure detection timeout for client nodes used byTcpDiscoverySpiandTcpCommunicationSpi.Default is
DFLT_CLIENT_FAILURE_DETECTION_TIMEOUT.- Returns:
- Failure detection timeout for client nodes in milliseconds.
- See Also:
setClientFailureDetectionTimeout(long)
-
setClientFailureDetectionTimeout
public IgniteConfiguration setClientFailureDetectionTimeout(long clientFailureDetectionTimeout)
Sets failure detection timeout to use inTcpDiscoverySpiandTcpCommunicationSpi.Failure detection timeout is used to determine how long the communication or discovery SPIs should wait before considering a remote connection failed.
- Parameters:
clientFailureDetectionTimeout- Failure detection timeout in milliseconds.- Returns:
thisfor chaining.
-
getFailureDetectionTimeout
public Long getFailureDetectionTimeout()
Returns failure detection timeout used byTcpDiscoverySpiandTcpCommunicationSpi.Default is
DFLT_FAILURE_DETECTION_TIMEOUT.- Returns:
- Failure detection timeout in milliseconds.
- See Also:
setFailureDetectionTimeout(long)
-
setFailureDetectionTimeout
public IgniteConfiguration setFailureDetectionTimeout(long failureDetectionTimeout)
Sets failure detection timeout to use inTcpDiscoverySpiandTcpCommunicationSpi.Failure detection timeout is used to determine how long the communication or discovery SPIs should wait before considering a remote connection failed.
- Parameters:
failureDetectionTimeout- Failure detection timeout in milliseconds.- Returns:
thisfor chaining.
-
getSystemWorkerBlockedTimeout
public Long getSystemWorkerBlockedTimeout()
Returns maximum inactivity period for system worker. When this value is exceeded, worker is considered blocked with consequent critical failure handler invocation.- Returns:
- Maximum inactivity period for system worker in milliseconds.
- See Also:
setSystemWorkerBlockedTimeout(long)
-
setSystemWorkerBlockedTimeout
public IgniteConfiguration setSystemWorkerBlockedTimeout(long sysWorkerBlockedTimeout)
Sets maximum inactivity period for system worker. When this value is exceeded, worker is considered blocked with consequent critical failure handler invocation.- Parameters:
sysWorkerBlockedTimeout- Maximum inactivity period for system worker in milliseconds.- Returns:
thisfor chaining.- See Also:
setFailureHandler(FailureHandler)
-
getLoadBalancingSpi
public LoadBalancingSpi[] getLoadBalancingSpi()
Should return fully configured load balancing SPI implementation. If not provided,RoundRobinLoadBalancingSpiwill be used.- Returns:
- Grid load balancing SPI implementation or
nullto use default implementation.
-
getDiscoveryStartupDelay
@Deprecated public long getDiscoveryStartupDelay()
Deprecated.Not used any more.This value is used to expire messages from waiting list whenever node discovery discrepancies happen.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,000specified byDFLT_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.- Returns:
- Time in milliseconds for when nodes can be out-of-sync.
-
setDiscoveryStartupDelay
@Deprecated public IgniteConfiguration setDiscoveryStartupDelay(long discoStartupDelay)
Deprecated.Not used any more.Sets time in milliseconds after which a certain metric value is considered expired. If not set explicitly, then default value is600,000milliseconds (10 minutes).- Parameters:
discoStartupDelay- Time in milliseconds for when nodes can be out-of-sync during startup.- Returns:
thisfor chaining.
-
setLoadBalancingSpi
public IgniteConfiguration setLoadBalancingSpi(LoadBalancingSpi... loadBalancingSpi)
Sets fully configured instance ofLoadBalancingSpi.- Parameters:
loadBalancingSpi- Fully configured instance ofLoadBalancingSpiornullif no SPI provided.- Returns:
thisfor chaining.- See Also:
getLoadBalancingSpi()
-
setIndexingSpi
public IgniteConfiguration setIndexingSpi(IndexingSpi indexingSpi)
Sets fully configured instances ofIndexingSpi.- Parameters:
indexingSpi- Fully configured instance ofIndexingSpi.- Returns:
thisfor chaining.- See Also:
getIndexingSpi()
-
getIndexingSpi
public IndexingSpi getIndexingSpi()
Should return fully configured indexing SPI implementations.- Returns:
- Indexing SPI implementation.
-
setEncryptionSpi
public IgniteConfiguration setEncryptionSpi(EncryptionSpi encryptionSpi)
Sets fully configured instances ofEncryptionSpi.- Parameters:
encryptionSpi- Fully configured instance ofEncryptionSpi.- Returns:
thisfor chaining.- See Also:
getEncryptionSpi()
-
getEncryptionSpi
public EncryptionSpi getEncryptionSpi()
Gets fully configured encryption SPI implementations.- Returns:
- Encryption SPI implementation.
-
setMetricExporterSpi
public IgniteConfiguration setMetricExporterSpi(MetricExporterSpi... metricExporterSpi)
Sets fully configured instances ofMetricExporterSpi.JmxMetricExporterSpiis used by default.- Parameters:
metricExporterSpi- Fully configured instances ofMetricExporterSpi.- Returns:
thisfor chaining.- See Also:
getMetricExporterSpi(),JmxMetricExporterSpi
-
setSystemViewExporterSpi
public IgniteConfiguration setSystemViewExporterSpi(SystemViewExporterSpi... sysViewExporterSpi)
Sets fully configured instances ofSystemViewExporterSpi.- Parameters:
sysViewExporterSpi- Fully configured instances ofSystemViewExporterSpi.- Returns:
thisfor chaining.- See Also:
getSystemViewExporterSpi()
-
getMetricExporterSpi
public MetricExporterSpi[] getMetricExporterSpi()
Gets fully configured metric SPI implementations.JmxMetricExporterSpiis used by default.- Returns:
- Metric exporter SPI implementations.
- See Also:
JmxMetricExporterSpi
-
getSystemViewExporterSpi
public SystemViewExporterSpi[] getSystemViewExporterSpi()
Gets fully configured system view SPI implementations.- Returns:
- System view exporter SPI implementations.
-
setTracingSpi
public IgniteConfiguration setTracingSpi(TracingSpi tracingSpi)
Set fully configured instance ofTracingSpi.- Parameters:
tracingSpi- Fully configured instance ofTracingSpi.- Returns:
thisfor chaining.
-
getTracingSpi
public TracingSpi getTracingSpi()
Gets fully configured tracing SPI implementation.- Returns:
- Tracing SPI implementation.
-
getAddressResolver
public AddressResolver getAddressResolver()
Gets address resolver for addresses mapping determination.- Returns:
- Address resolver.
-
setAddressResolver
public IgniteConfiguration setAddressResolver(AddressResolver addrRslvr)
Sets address resolver for addresses mapping determination.- Parameters:
addrRslvr- Address resolver.- Returns:
thisfor chaining.
-
setDeploymentMode
public IgniteConfiguration setDeploymentMode(DeploymentMode deployMode)
Sets task classes and resources sharing mode.- Parameters:
deployMode- Task classes and resources sharing mode.- Returns:
thisfor chaining.
-
getDeploymentMode
public DeploymentMode getDeploymentMode()
Gets deployment mode for deploying tasks and other classes on this node. Refer toDeploymentModedocumentation for more information.- Returns:
- Deployment mode.
-
setPeerClassLoadingMissedResourcesCacheSize
public IgniteConfiguration setPeerClassLoadingMissedResourcesCacheSize(int p2pMissedCacheSize)
Sets size of missed resources cache. Set 0 to avoid missed resources caching.- Parameters:
p2pMissedCacheSize- Size of missed resources cache.- Returns:
thisfor chaining.
-
getPeerClassLoadingMissedResourcesCacheSize
public int getPeerClassLoadingMissedResourcesCacheSize()
Returns missed resources cache size. If size greater than0, missed resources will be cached and next resource request ignored. If size is0, then request for the resource will be sent to the remote node every time this resource is requested.- Returns:
- Missed resources cache size.
-
getCacheConfiguration
public CacheConfiguration[] getCacheConfiguration()
Gets configuration (descriptors) for all caches.- Returns:
- Array of fully initialized cache descriptors.
-
setCacheConfiguration
public IgniteConfiguration setCacheConfiguration(CacheConfiguration... cacheCfg)
Sets cache configurations.- Parameters:
cacheCfg- Cache configurations.- Returns:
thisfor chaining.
-
isClientMode
public Boolean isClientMode()
Gets client mode flag. Client node cannot hold data in the caches. It's recommended to useDiscoverySpiin client mode if this property istrue.- Returns:
- Client mode flag.
- See Also:
TcpDiscoverySpi.setForceServerMode(boolean)
-
setClientMode
public IgniteConfiguration setClientMode(boolean clientMode)
Sets client mode flag.- Parameters:
clientMode- Client mode flag.- Returns:
thisfor chaining.
-
getCacheKeyConfiguration
public CacheKeyConfiguration[] getCacheKeyConfiguration()
Gets cache key configuration.- Returns:
- Cache key configuration.
-
setCacheKeyConfiguration
public IgniteConfiguration setCacheKeyConfiguration(CacheKeyConfiguration... cacheKeyCfg)
Sets cache key configuration. Cache key configuration defines- Parameters:
cacheKeyCfg- Cache key configuration.- Returns:
thisfor chaining.
-
getBinaryConfiguration
public BinaryConfiguration getBinaryConfiguration()
Gets configuration for Ignite Binary objects.- Returns:
- Binary configuration object.
-
setBinaryConfiguration
public IgniteConfiguration setBinaryConfiguration(BinaryConfiguration binaryCfg)
Sets configuration for Ignite Binary objects.- Parameters:
binaryCfg- Binary configuration object.- Returns:
thisfor chaining.
-
getDataStorageConfiguration
public DataStorageConfiguration getDataStorageConfiguration()
Gets page memory configuration.- Returns:
- Memory configuration.
-
setDataStorageConfiguration
public IgniteConfiguration setDataStorageConfiguration(DataStorageConfiguration dsCfg)
Sets durable memory configuration.- Parameters:
dsCfg- Data storage configuration.- Returns:
thisfor chaining.
-
getMemoryConfiguration
@Deprecated public MemoryConfiguration getMemoryConfiguration()
Deprecated.UseDataStorageConfigurationinstead.Gets page memory configuration.- Returns:
- Memory configuration.
-
setMemoryConfiguration
@Deprecated public IgniteConfiguration setMemoryConfiguration(MemoryConfiguration memCfg)
Deprecated.UseDataStorageConfigurationinstead.Sets page memory configuration.- Parameters:
memCfg- Memory configuration.- Returns:
thisfor chaining.
-
getPersistentStoreConfiguration
@Deprecated public PersistentStoreConfiguration getPersistentStoreConfiguration()
Deprecated.Part of old API. UseDataStorageConfigurationfor configuring persistence instead.Gets persistence configuration used by Apache Ignite Persistent Store.- Returns:
- Persistence configuration.
-
isPersistentStoreEnabled
@Deprecated public boolean isPersistentStoreEnabled()
Deprecated.Part of legacy configuration API. Doesn't work if new configuration API is used.- Returns:
- Flag
trueif persistence is enabled,falseif disabled.
-
setPersistentStoreConfiguration
@Deprecated public IgniteConfiguration setPersistentStoreConfiguration(PersistentStoreConfiguration pstCfg)
Deprecated.Part of old API. UseDataStorageConfigurationfor configuring persistence instead.Sets persistence configuration activating Apache Ignite Persistent Store.- Parameters:
pstCfg- Persistence configuration.- Returns:
thisfor chaining.
-
isActiveOnStart
@Deprecated public boolean isActiveOnStart()
Deprecated.UsegetClusterStateOnStart()instead.Gets flag indicating whether the cluster will be active on start. If cluster is not active on start, there will be no cache partition map exchanges performed until the cluster is activated. This should significantly speed up large topology startup time.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.- Returns:
- Active on start flag value.
-
setActiveOnStart
@Deprecated public IgniteConfiguration setActiveOnStart(boolean activeOnStart)
Deprecated.UsesetClusterStateOnStart(ClusterState)instead.Sets flag indicating whether the cluster will be active on start. This value should be the same on all nodes in the cluster.This flag is ignored when
DataStorageConfigurationhas at least one configured persistent region: cluster is always inactive on start when Ignite Persistence is enabled.- Parameters:
activeOnStart- Active on start flag value.- Returns:
thisinstance.- See Also:
isActiveOnStart()
-
isAutoActivationEnabled
@Deprecated public boolean isAutoActivationEnabled()
Deprecated.UsegetClusterStateOnStart()instead.Get the flag indicating that cluster is enabled to activate automatically. If it is set totrueand BaselineTopology is set as well than cluster activates automatically when all nodes from the BaselineTopology join the cluster.Default value is
DFLT_AUTO_ACTIVATION.- Returns:
- Auto activation enabled flag value.
-
setAutoActivationEnabled
@Deprecated public IgniteConfiguration setAutoActivationEnabled(boolean autoActivation)
Deprecated.UsesetClusterStateOnStart(ClusterState)instead.Sets flag indicating whether the cluster is enabled to activate automatically. This value should be the same on all nodes in the cluster.- Parameters:
autoActivation- Auto activation enabled flag value.- Returns:
thisinstance.- See Also:
isAutoActivationEnabled()
-
getClusterStateOnStart
@Nullable public @Nullable ClusterState getClusterStateOnStart()
Gets state of cluster on start.
For in-memory cluster this state will be applied to the first started node. If cluster state on start isClusterState.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.
For persistent cluster If state is different fromClusterState.INACTIVEand 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.- Returns:
- State of cluster on start or
null, if property wasn't set.Nullmeans that default value will be used.
-
setClusterStateOnStart
public IgniteConfiguration setClusterStateOnStart(ClusterState state)
Sets state of cluster on start.- Parameters:
state- New cluster state on start.- Returns:
thisfor chaining.- See Also:
getClusterStateOnStart()
-
isCacheSanityCheckEnabled
public boolean isCacheSanityCheckEnabled()
Gets flag indicating whether cache sanity check is enabled. If enabled, then Ignite will perform the following checks and throw an exception if check fails:- Cache entry is not externally locked with
lock(...)orlockAsync(...)methods when entry is enlisted to transaction. - Each entry in affinity group-lock transaction has the same affinity key as was specified on affinity transaction start.
- Each entry in partition group-lock transaction belongs to the same partition as was specified on partition transaction start.
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.- Returns:
Trueif group lock sanity check is enabled.
- Cache entry is not externally locked with
-
setCacheSanityCheckEnabled
public IgniteConfiguration setCacheSanityCheckEnabled(boolean cacheSanityCheckEnabled)
Sets cache sanity check flag.- Parameters:
cacheSanityCheckEnabled-Trueif cache sanity check is enabled.- Returns:
thisfor chaining.- See Also:
isCacheSanityCheckEnabled()
-
getIncludeEventTypes
public int[] getIncludeEventTypes()
Gets array of event types, which will be recorded.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.
- Returns:
- Include event types.
-
setIncludeEventTypes
public IgniteConfiguration setIncludeEventTypes(int... inclEvtTypes)
Sets array of event types, which will be recorded byGridEventStorageManager.record(Event). Note, that either the include event types or the exclude event types can be established.- Parameters:
inclEvtTypes- Include event types.- Returns:
thisfor chaining.
-
setLocalHost
public IgniteConfiguration setLocalHost(String locHost)
Sets system-wide local address or host for all Ignite components to bind to. If provided it will override all default local bind settings within Ignite or any of its SPIs.- Parameters:
locHost- Local IP address or host to bind to.- Returns:
thisfor chaining.
-
getLocalHost
public String getLocalHost()
Gets system-wide local address or host for all Ignite components to bind to. If provided it will override all default local bind settings within Ignite or any of its SPIs.If
nullthen 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.- Returns:
- Local address or host to bind to.
-
getTimeServerPortBase
public int getTimeServerPortBase()
Gets base UPD port number for grid time server. Time server will be started on one of free ports in range[timeServerPortBase, timeServerPortBase + timeServerPortRange - 1].Time server provides clock synchronization between nodes.
- Returns:
- Time
-
setTimeServerPortBase
public IgniteConfiguration setTimeServerPortBase(int timeSrvPortBase)
Sets time server port base.- Parameters:
timeSrvPortBase- Time server port base.- Returns:
thisfor chaining.
-
getTimeServerPortRange
public int getTimeServerPortRange()
Defines port range to try for time server start. If port range value is 0, then implementation will try bind only to the port provided bysetTimeServerPortBase(int)method and fail if binding to this port did not succeed.- Returns:
- Number of ports to try before server initialization fails.
-
setTimeServerPortRange
public IgniteConfiguration setTimeServerPortRange(int timeSrvPortRange)
Sets time server port range.- Parameters:
timeSrvPortRange- Time server port range.- Returns:
thisfor chaining.
-
getIncludeProperties
public String[] getIncludeProperties()
Gets array of system or environment properties to include into node attributes. If this array isnull, 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.- Returns:
- Array of system or environment properties to include into node attributes.
-
setIncludeProperties
public IgniteConfiguration setIncludeProperties(String... includeProps)
Sets array of system or environment property names to include into node attributes. SeegetIncludeProperties()for more info.- Parameters:
includeProps- Array of system or environment property names to include into node attributes.- Returns:
thisfor chaining.
-
getMetricsLogFrequency
public long getMetricsLogFrequency()
Gets frequency of metrics log print out.If
0, metrics print out is disabled.If not provided, then default value
DFLT_METRICS_LOG_FREQis used.- Returns:
- Frequency of metrics log print out.
-
setMetricsLogFrequency
public IgniteConfiguration setMetricsLogFrequency(long metricsLogFreq)
Sets frequency of metrics log print out.If
0, metrics print out is disabled.If not provided, then default value
DFLT_METRICS_LOG_FREQis used.- Parameters:
metricsLogFreq- Frequency of metrics log print out.- Returns:
thisfor chaining.
-
getConnectorConfiguration
public ConnectorConfiguration getConnectorConfiguration()
- Returns:
- Connector configuration.
-
setConnectorConfiguration
public IgniteConfiguration setConnectorConfiguration(ConnectorConfiguration connectorCfg)
- Parameters:
connectorCfg- Connector configuration.- Returns:
thisfor chaining.
-
getOdbcConfiguration
@Deprecated public OdbcConfiguration getOdbcConfiguration()
Deprecated.UsegetClientConnectorConfiguration()()} instead.Gets configuration for ODBC.- Returns:
- ODBC configuration.
-
setOdbcConfiguration
@Deprecated public IgniteConfiguration setOdbcConfiguration(OdbcConfiguration odbcCfg)
Deprecated.Sets configuration for ODBC.- Parameters:
odbcCfg- ODBC configuration.- Returns:
thisfor chaining.
-
getServiceConfiguration
public ServiceConfiguration[] getServiceConfiguration()
Gets configurations for services to be deployed on the grid.- Returns:
- Configurations for services to be deployed on the grid.
-
setServiceConfiguration
public IgniteConfiguration setServiceConfiguration(ServiceConfiguration... svcCfgs)
Sets configurations for services to be deployed on the grid.- Parameters:
svcCfgs- Configurations for services to be deployed on the grid.- Returns:
thisfor chaining.
-
getLocalEventListeners
public Map<IgnitePredicate<? extends Event>,int[]> getLocalEventListeners()
Gets map of pre-configured local event listeners. Each listener is mapped to array of event types.- Returns:
- Pre-configured event listeners map.
- See Also:
EventType
-
setLocalEventListeners
public IgniteConfiguration setLocalEventListeners(Map<IgnitePredicate<? extends Event>,int[]> lsnrs)
Sets map of pre-configured local event listeners. Each listener is mapped to array of event types.- Parameters:
lsnrs- Pre-configured event listeners map.- Returns:
thisfor chaining.
-
getSnapshotPath
public String getSnapshotPath()
- Returns:
- By default, the relative
DFLT_SNAPSHOT_DIRECTORYis used. The value can be configured as relative path starting from the IgnitesgetWorkDirectory()or the value can be represented as an absolute snapshot working path.
-
setSnapshotPath
public IgniteConfiguration setSnapshotPath(String snapshotPath)
- Parameters:
snapshotPath- By default, the relativeDFLT_SNAPSHOT_DIRECTORYis used. The value can be configured as relative path starting from the IgnitesgetWorkDirectory()or the value can be represented as an absolute snapshot working path instead.- Returns:
thisfor chaining.
-
getWarmupClosure
public IgniteInClosure<IgniteConfiguration> getWarmupClosure()
Gets grid warmup closure. This closure will be executed before actual grid instance start. Configuration of a starting instance will be passed to the closure so it can decide what operations to warm up.- Returns:
- Warmup closure to execute.
-
setWarmupClosure
public IgniteConfiguration setWarmupClosure(IgniteInClosure<IgniteConfiguration> warmupClos)
Sets warmup closure to execute before grid startup.- Parameters:
warmupClos- Warmup closure to execute.- Returns:
thisfor chaining.- See Also:
getWarmupClosure()
-
getTransactionConfiguration
public TransactionConfiguration getTransactionConfiguration()
Gets transactions configuration.- Returns:
- Transactions configuration.
-
setTransactionConfiguration
public IgniteConfiguration setTransactionConfiguration(TransactionConfiguration txCfg)
Sets transactions configuration.- Parameters:
txCfg- Transactions configuration.- Returns:
thisfor chaining.
-
getPluginConfigurations
@Deprecated public PluginConfiguration[] getPluginConfigurations()
Deprecated.Gets plugin configurations.- Returns:
- Plugin configurations.
- See Also:
PluginProvider
-
setPluginConfigurations
@Deprecated public IgniteConfiguration setPluginConfigurations(PluginConfiguration... pluginCfgs)
Deprecated.SincePluginProviders can be set explicitly viasetPluginProviders(PluginProvider[])it's preferable to storePluginConfigurationas a part ofPluginProvider.Sets plugin configurations.- Parameters:
pluginCfgs- Plugin configurations.- Returns:
thisfor chaining.- See Also:
PluginProvider
-
getAtomicConfiguration
public AtomicConfiguration getAtomicConfiguration()
- Returns:
- Atomic data structures configuration.
-
setAtomicConfiguration
public IgniteConfiguration setAtomicConfiguration(AtomicConfiguration atomicCfg)
- Parameters:
atomicCfg- Atomic data structures configuration.- Returns:
thisfor chaining.
-
setClassLoader
public IgniteConfiguration setClassLoader(ClassLoader classLdr)
Sets loader which will be used for instantiating execution context (EntryProcessors,CacheEntryListeners,CacheLoadersandExpiryPolicys).- Parameters:
classLdr- Class loader.- Returns:
thisfor chaining.
-
getClassLoader
public ClassLoader getClassLoader()
- Returns:
- User's class loader.
-
getCacheStoreSessionListenerFactories
public javax.cache.configuration.Factory<CacheStoreSessionListener>[] getCacheStoreSessionListenerFactories()
Gets cache store session listener factories.- Returns:
- Cache store session listener factories.
- See Also:
CacheStoreSessionListener
-
setCacheStoreSessionListenerFactories
public IgniteConfiguration setCacheStoreSessionListenerFactories(javax.cache.configuration.Factory<CacheStoreSessionListener>... storeSesLsnrs)
Cache store session listener factories.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.- Parameters:
storeSesLsnrs- Cache store session listener factories.- Returns:
thisfor chaining.- See Also:
CacheStoreSessionListener
-
getPlatformConfiguration
public PlatformConfiguration getPlatformConfiguration()
Gets platform configuration.- Returns:
- Platform configuration.
-
setPlatformConfiguration
public IgniteConfiguration setPlatformConfiguration(PlatformConfiguration platformCfg)
Sets platform configuration.- Parameters:
platformCfg- Platform configuration.- Returns:
thisfor chaining.
-
isLateAffinityAssignment
@Deprecated public boolean isLateAffinityAssignment()
Deprecated.Starting from Ignite 2.1 late affinity assignment is always enabled.Whether or not late affinity assignment mode should be used.On each topology change, for each started cache partition-to-node mapping is calculated using
AffinityFunctionconfigured 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
Affinityinterface 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 byAffinityFunction.assignPartitions(org.apache.ignite.cache.affinity.AffinityFunctionContext).This property should have the same value for all nodes in cluster.
- Returns:
- Late affinity assignment flag.
- See Also:
AffinityFunction
-
setLateAffinityAssignment
@Deprecated public IgniteConfiguration setLateAffinityAssignment(boolean lateAffAssignment)
Deprecated.Starting from Ignite 2.1 late affinity assignment is always enabled.Sets late affinity assignment flag.- Parameters:
lateAffAssignment- Late affinity assignment flag.- Returns:
thisfor chaining.
-
getExecutorConfiguration
public ExecutorConfiguration[] getExecutorConfiguration()
Gets custom executors for user compute tasks.See
setExecutorConfiguration(ExecutorConfiguration...)for more information.- Returns:
- Executor configurations.
-
setExecutorConfiguration
public IgniteConfiguration setExecutorConfiguration(ExecutorConfiguration... execCfgs)
Sets custom executors for user compute tasks.See
IgniteCompute.withExecutor(String)for more information.- Parameters:
execCfgs- Executor configurations.- Returns:
thisfor chaining.
-
getLongQueryWarningTimeout
@Deprecated public long getLongQueryWarningTimeout()
Deprecated.UseSqlConfiguration.getLongQueryWarningTimeout()instead.Gets timeout in milliseconds after which long query warning will be printed.- Returns:
- Timeout in milliseconds.
-
setLongQueryWarningTimeout
@Deprecated public IgniteConfiguration setLongQueryWarningTimeout(long longQryWarnTimeout)
Deprecated.UseSqlConfiguration.setLongQueryWarningTimeout(long)instead.Sets timeout in milliseconds after which long query warning will be printed.- Parameters:
longQryWarnTimeout- Timeout in milliseconds.- Returns:
thisfor chaining.
-
setSqlConnectorConfiguration
@Deprecated public IgniteConfiguration setSqlConnectorConfiguration(SqlConnectorConfiguration sqlConnCfg)
Deprecated.Sets SQL connector configuration.- Parameters:
sqlConnCfg- SQL connector configuration.- Returns:
thisfor chaining.
-
getSqlConnectorConfiguration
@Deprecated public SqlConnectorConfiguration getSqlConnectorConfiguration()
Deprecated.UsegetClientConnectorConfiguration()instead.Gets SQL connector configuration.- Returns:
- SQL connector configuration.
-
setClientConnectorConfiguration
public IgniteConfiguration setClientConnectorConfiguration(@Nullable @Nullable ClientConnectorConfiguration cliConnCfg)
Sets client connector configuration.- Parameters:
cliConnCfg- Client connector configuration.- Returns:
thisfor chaining.
-
getFailureHandler
public FailureHandler getFailureHandler()
Gets failure handler.- Returns:
- Failure handler.
-
setFailureHandler
public IgniteConfiguration setFailureHandler(FailureHandler failureHnd)
Sets failure handler.- Parameters:
failureHnd- Failure handler.- Returns:
Thisfor chaining.
-
getClientConnectorConfiguration
@Nullable public @Nullable ClientConnectorConfiguration getClientConnectorConfiguration()
Gets client connector configuration.- Returns:
- Client connector configuration.
-
isAuthenticationEnabled
public boolean isAuthenticationEnabled()
Returnstrueif user authentication is enabled for cluster. Otherwise returnsfalse. Default value is false; authentication is disabled.- Returns:
trueif user authentication is enabled for cluster. Otherwise returnsfalse.
-
setAuthenticationEnabled
public IgniteConfiguration setAuthenticationEnabled(boolean authEnabled)
Sets flag indicating whether the user authentication is enabled for cluster.- Parameters:
authEnabled- User authentication enabled flag.trueenab- Returns:
thisfor chaining.
-
getSqlSchemas
@Deprecated public String[] getSqlSchemas()
Deprecated.UseSqlConfiguration.getSqlSchemas()instead.Gets SQL schemas to be created on node startup.See
setSqlSchemas(String...)for more information.- Returns:
- SQL schemas to be created on node startup.
-
setSqlSchemas
@Deprecated public IgniteConfiguration setSqlSchemas(String... sqlSchemas)
Deprecated.UseSqlConfiguration.setSqlSchemas(String...)instead.Sets SQL schemas to be created on node startup. Schemas are created on local node only and are not propagated to other cluster nodes. Created schemas cannot be dropped.By default schema names are case-insensitive, i.e.
my_schemaandMy_Schemarepresents the same object. Use quotes to enforce case sensitivity (e.g."My_Schema").Property is ignored if
ignite-indexingmodule is not in classpath.- Parameters:
sqlSchemas- SQL schemas to be created on node startup.- Returns:
thisfor chaining.
-
getPluginProviders
public PluginProvider[] getPluginProviders()
Gets plugin providers.- Returns:
- Plugin providers.
-
setPluginProviders
public IgniteConfiguration setPluginProviders(PluginProvider... pluginProvs)
Sets plugin providers.- Parameters:
pluginProvs- Plugin providers.- Returns:
thisfor chaining.
-
getSqlConfiguration
public SqlConfiguration getSqlConfiguration()
Gets Configuration of the SQL subsystem.- Returns:
- SQL configuration.
-
setSqlConfiguration
public IgniteConfiguration setSqlConfiguration(SqlConfiguration sqlCfg)
- Parameters:
sqlCfg- Configuration of the SQL subsystem.- Returns:
thisfor chaining.
-
getAsyncContinuationExecutor
public Executor getAsyncContinuationExecutor()
Gets the continuation executor for cache async APIs. Whennull(default),ForkJoinPool.commonPool()is used. When async operation completes, correspondingIgniteFuturelisteners will be invoked using this executor.- Returns:
- Executor for async continuations.
-
setAsyncContinuationExecutor
public IgniteConfiguration setAsyncContinuationExecutor(Executor asyncContinuationExecutor)
Sets the continuation executor for cache async APIs. Whennull(default),ForkJoinPool.commonPool()is used. When async operation completes, correspondingIgniteFuturelisteners will be invoked using this executor.- Parameters:
asyncContinuationExecutor- Executor for async continuations.- Returns:
thisfor chaining.
-
getDistributedPropertiesDefaultValues
public Map<String,String> getDistributedPropertiesDefaultValues()
Gets default values for distributed properties.- Returns:
- Default values for distributed properties.
-
setDistributedPropertiesDefaultValues
public IgniteConfiguration setDistributedPropertiesDefaultValues(Map<String,String> distrProps)
Sets default values for distributed properties.- Parameters:
distrProps- Default values for distributed properties.- Returns:
thisfor chaining.
-
-