Return-Path: X-Original-To: apmail-ignite-commits-archive@minotaur.apache.org Delivered-To: apmail-ignite-commits-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 400C717A12 for ; Wed, 29 Apr 2015 15:52:47 +0000 (UTC) Received: (qmail 31495 invoked by uid 500); 29 Apr 2015 15:52:47 -0000 Delivered-To: apmail-ignite-commits-archive@ignite.apache.org Received: (qmail 31465 invoked by uid 500); 29 Apr 2015 15:52:47 -0000 Mailing-List: contact commits-help@ignite.incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@ignite.incubator.apache.org Delivered-To: mailing list commits@ignite.incubator.apache.org Received: (qmail 31454 invoked by uid 99); 29 Apr 2015 15:52:47 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 29 Apr 2015 15:52:47 +0000 X-ASF-Spam-Status: No, hits=-0.0 required=5.0 tests=SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (athena.apache.org: local policy) Received: from [54.164.171.186] (HELO mx1-us-east.apache.org) (54.164.171.186) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 29 Apr 2015 15:52:39 +0000 Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by mx1-us-east.apache.org (ASF Mail Server at mx1-us-east.apache.org) with SMTP id DF9DE43DD8 for ; Wed, 29 Apr 2015 15:52:17 +0000 (UTC) Received: (qmail 28595 invoked by uid 99); 29 Apr 2015 15:52:17 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 29 Apr 2015 15:52:17 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 5C6FDE083A; Wed, 29 Apr 2015 15:52:17 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: sboikov@apache.org To: commits@ignite.incubator.apache.org Date: Wed, 29 Apr 2015 15:52:19 -0000 Message-Id: <2ed73d45670248dda7e88ed7caf54e78@git.apache.org> In-Reply-To: <6dd74d22c9194409993da944631f2a6b@git.apache.org> References: <6dd74d22c9194409993da944631f2a6b@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: [3/3] incubator-ignite git commit: # ignite-786: review X-Virus-Checked: Checked by ClamAV on apache.org # ignite-786: review Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/4e0b661e Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/4e0b661e Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/4e0b661e Branch: refs/heads/ignite-786 Commit: 4e0b661e9705fcca7d4eb052ed76b730a35b7e14 Parents: 3978f9e Author: Artem Shutak Authored: Wed Apr 29 18:52:15 2015 +0300 Committer: Artem Shutak Committed: Wed Apr 29 18:52:15 2015 +0300 ---------------------------------------------------------------------- .../configuration/CacheConfiguration.java | 47 ++++++++++++++ .../configuration/IgniteConfiguration.java | 68 ++++++++++++++++++++ 2 files changed, 115 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/4e0b661e/modules/core/src/main/java/org/apache/ignite/configuration/CacheConfiguration.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/configuration/CacheConfiguration.java b/modules/core/src/main/java/org/apache/ignite/configuration/CacheConfiguration.java index 28242de..df6b2ee 100644 --- a/modules/core/src/main/java/org/apache/ignite/configuration/CacheConfiguration.java +++ b/modules/core/src/main/java/org/apache/ignite/configuration/CacheConfiguration.java @@ -481,6 +481,7 @@ public class CacheConfiguration extends MutableConfiguration { * Sets write synchronization mode. * * @param writeSync Write synchronization mode. + * @return {@code this} for chaining. */ public CacheConfiguration setWriteSynchronizationMode(CacheWriteSynchronizationMode writeSync) { this.writeSync = writeSync; @@ -501,6 +502,7 @@ public class CacheConfiguration extends MutableConfiguration { * Sets filter which determines on what nodes the cache should be started. * * @param nodeFilter Predicate specifying on which nodes the cache should be started. + * @return {@code this} for chaining. */ public CacheConfiguration setNodeFilter(IgnitePredicate nodeFilter) { this.nodeFilter = nodeFilter; @@ -532,6 +534,7 @@ public class CacheConfiguration extends MutableConfiguration { * (or the rest of the nodes for replicated cache). * * @param evictSync {@code true} if synchronized, {@code false} if not. + * @return {@code this} for chaining. */ public CacheConfiguration setEvictSynchronized(boolean evictSync) { this.evictSync = evictSync; @@ -554,6 +557,7 @@ public class CacheConfiguration extends MutableConfiguration { * Sets eviction key buffer size. * * @param evictKeyBufSize Eviction key buffer size. + * @return {@code this} for chaining. */ public CacheConfiguration setEvictSynchronizedKeyBufferSize(int evictKeyBufSize) { this.evictKeyBufSize = evictKeyBufSize; @@ -587,6 +591,7 @@ public class CacheConfiguration extends MutableConfiguration { * Sets concurrency level for synchronized evictions. * * @param evictSyncConcurrencyLvl Concurrency level for synchronized evictions. + * @return {@code this} for chaining. */ public CacheConfiguration setEvictSynchronizedConcurrencyLevel(int evictSyncConcurrencyLvl) { this.evictSyncConcurrencyLvl = evictSyncConcurrencyLvl; @@ -612,6 +617,7 @@ public class CacheConfiguration extends MutableConfiguration { * Sets timeout for synchronized evictions. * * @param evictSyncTimeout Timeout for synchronized evictions. + * @return {@code this} for chaining. */ public CacheConfiguration setEvictSynchronizedTimeout(long evictSyncTimeout) { this.evictSyncTimeout = evictSyncTimeout; @@ -643,6 +649,7 @@ public class CacheConfiguration extends MutableConfiguration { * Sets maximum eviction overflow ratio. * * @param evictMaxOverflowRatio Maximum eviction overflow ratio. + * @return {@code this} for chaining. */ public CacheConfiguration setEvictMaxOverflowRatio(float evictMaxOverflowRatio) { this.evictMaxOverflowRatio = evictMaxOverflowRatio; @@ -671,6 +678,7 @@ public class CacheConfiguration extends MutableConfiguration { * Sets eviction filter. * * @param evictFilter Eviction filter. + * @return {@code this} for chaining. */ public CacheConfiguration setEvictionFilter(EvictionFilter evictFilter) { this.evictFilter = evictFilter; @@ -699,6 +707,7 @@ public class CacheConfiguration extends MutableConfiguration { * * @param eagerTtl {@code True} if Ignite should eagerly remove expired cache entries. * @see #isEagerTtl() + * @return {@code this} for chaining. */ public CacheConfiguration setEagerTtl(boolean eagerTtl) { this.eagerTtl = eagerTtl; @@ -720,6 +729,7 @@ public class CacheConfiguration extends MutableConfiguration { * Initial size for internal hash map. * * @param startSize Cache start size. + * @return {@code this} for chaining. */ public CacheConfiguration setStartSize(int startSize) { this.startSize = startSize; @@ -764,6 +774,7 @@ public class CacheConfiguration extends MutableConfiguration { * * @param loadPrevVal Load previous value flag. * @return {@code this} for chaining. + * @return {@code this} for chaining. */ public CacheConfiguration setLoadPreviousValue(boolean loadPrevVal) { this.loadPrevVal = loadPrevVal; @@ -806,6 +817,7 @@ public class CacheConfiguration extends MutableConfiguration { * Sets affinity for cache keys. * * @param aff Cache key affinity. + * @return {@code this} for chaining. */ public CacheConfiguration setAffinity(AffinityFunction aff) { this.aff = aff; @@ -828,6 +840,7 @@ public class CacheConfiguration extends MutableConfiguration { * Sets caching mode. * * @param cacheMode Caching mode. + * @return {@code this} for chaining. */ public CacheConfiguration setCacheMode(CacheMode cacheMode) { this.cacheMode = cacheMode; @@ -850,6 +863,7 @@ public class CacheConfiguration extends MutableConfiguration { * Sets cache atomicity mode. * * @param atomicityMode Cache atomicity mode. + * @return {@code this} for chaining. */ public CacheConfiguration setAtomicityMode(CacheAtomicityMode atomicityMode) { this.atomicityMode = atomicityMode; @@ -872,6 +886,7 @@ public class CacheConfiguration extends MutableConfiguration { * cache (for other atomicity modes it will be ignored). * * @param atomicWriteOrderMode Cache write ordering mode. + * @return {@code this} for chaining. */ public CacheConfiguration setAtomicWriteOrderMode(CacheAtomicWriteOrderMode atomicWriteOrderMode) { this.atomicWriteOrderMode = atomicWriteOrderMode; @@ -896,6 +911,7 @@ public class CacheConfiguration extends MutableConfiguration { * If not set, default value is {@link #DFLT_BACKUPS}. * * @param backups Number of backup nodes for one partition. + * @return {@code this} for chaining. */ public CacheConfiguration setBackups(int backups) { this.backups = backups; @@ -917,6 +933,7 @@ public class CacheConfiguration extends MutableConfiguration { * Sets default lock timeout in milliseconds. By default this value is defined by {@link #DFLT_LOCK_TIMEOUT}. * * @param dfltLockTimeout Default lock timeout. + * @return {@code this} for chaining. */ public CacheConfiguration setDefaultLockTimeout(long dfltLockTimeout) { this.dfltLockTimeout = dfltLockTimeout; @@ -937,6 +954,7 @@ public class CacheConfiguration extends MutableConfiguration { * Sets invalidation flag for near cache entries in this transaction. Default is {@code false}. * * @param invalidate Flag to set this cache into invalidation-based mode. Default value is {@code false}. + * @return {@code this} for chaining. */ public CacheConfiguration setInvalidate(boolean invalidate) { this.invalidate = invalidate; @@ -958,6 +976,7 @@ public class CacheConfiguration extends MutableConfiguration { * * @param tmLookupClsName Name of class implementing GridCacheTmLookup interface that is used to * receive JTA transaction manager. + * @return {@code this} for chaining. */ public CacheConfiguration setTransactionManagerLookupClassName(String tmLookupClsName) { this.tmLookupClsName = tmLookupClsName; @@ -969,6 +988,7 @@ public class CacheConfiguration extends MutableConfiguration { * Sets cache rebalance mode. * * @param rebalanceMode Rebalance mode. + * @return {@code this} for chaining. */ public CacheConfiguration setRebalanceMode(CacheRebalanceMode rebalanceMode) { this.rebalanceMode = rebalanceMode; @@ -1011,6 +1031,7 @@ public class CacheConfiguration extends MutableConfiguration { * * @param rebalanceOrder Cache rebalance order. * @see #getRebalanceOrder() + * @return {@code this} for chaining. */ public CacheConfiguration setRebalanceOrder(int rebalanceOrder) { this.rebalanceOrder = rebalanceOrder; @@ -1034,6 +1055,7 @@ public class CacheConfiguration extends MutableConfiguration { * Sets rebalance batch size. * * @param rebalanceBatchSize Rebalance batch size. + * @return {@code this} for chaining. */ public CacheConfiguration setRebalanceBatchSize(int rebalanceBatchSize) { this.rebalanceBatchSize = rebalanceBatchSize; @@ -1055,6 +1077,7 @@ public class CacheConfiguration extends MutableConfiguration { * Flag indicating whether swap storage is enabled or not. * * @param swapEnabled {@code True} if swap storage is enabled. + * @return {@code this} for chaining. */ public CacheConfiguration setSwapEnabled(boolean swapEnabled) { this.swapEnabled = swapEnabled; @@ -1083,6 +1106,7 @@ public class CacheConfiguration extends MutableConfiguration { * * @param maxConcurrentAsyncOps Maximum number of concurrent asynchronous operations. * @see #getMaxConcurrentAsyncOperations() + * @return {@code this} for chaining. */ public CacheConfiguration setMaxConcurrentAsyncOperations(int maxConcurrentAsyncOps) { this.maxConcurrentAsyncOps = maxConcurrentAsyncOps; @@ -1105,6 +1129,7 @@ public class CacheConfiguration extends MutableConfiguration { * Sets flag indicating whether write-behind is enabled. * * @param writeBehindEnabled {@code true} if write-behind is enabled. + * @return {@code this} for chaining. */ public CacheConfiguration setWriteBehindEnabled(boolean writeBehindEnabled) { this.writeBehindEnabled = writeBehindEnabled; @@ -1132,6 +1157,7 @@ public class CacheConfiguration extends MutableConfiguration { * * @param writeBehindFlushSize Write-behind cache flush size. * @see #getWriteBehindFlushSize() + * @return {@code this} for chaining. */ public CacheConfiguration setWriteBehindFlushSize(int writeBehindFlushSize) { this.writeBehindFlushSize = writeBehindFlushSize; @@ -1160,6 +1186,7 @@ public class CacheConfiguration extends MutableConfiguration { * * @param writeBehindFlushFreq Write-behind flush frequency in milliseconds. * @see #getWriteBehindFlushFrequency() + * @return {@code this} for chaining. */ public CacheConfiguration setWriteBehindFlushFrequency(long writeBehindFlushFreq) { this.writeBehindFlushFreq = writeBehindFlushFreq; @@ -1186,6 +1213,7 @@ public class CacheConfiguration extends MutableConfiguration { * * @param writeBehindFlushThreadCnt Count of flush threads. * @see #getWriteBehindFlushThreadCount() + * @return {@code this} for chaining. */ public CacheConfiguration setWriteBehindFlushThreadCount(int writeBehindFlushThreadCnt) { this.writeBehindFlushThreadCnt = writeBehindFlushThreadCnt; @@ -1212,6 +1240,7 @@ public class CacheConfiguration extends MutableConfiguration { * * @param writeBehindBatchSize Maximum batch size. * @see #getWriteBehindBatchSize() + * @return {@code this} for chaining. */ public CacheConfiguration setWriteBehindBatchSize(int writeBehindBatchSize) { this.writeBehindBatchSize = writeBehindBatchSize; @@ -1236,6 +1265,7 @@ public class CacheConfiguration extends MutableConfiguration { * for rebalancing than specified here (but never less threads). * * @param rebalancePoolSize Size of rebalancing thread pool. + * @return {@code this} for chaining. */ public CacheConfiguration setRebalanceThreadPoolSize(int rebalancePoolSize) { this.rebalancePoolSize = rebalancePoolSize; @@ -1258,6 +1288,7 @@ public class CacheConfiguration extends MutableConfiguration { * Sets rebalance timeout (ms). * * @param rebalanceTimeout Rebalance timeout (ms). + * @return {@code this} for chaining. */ public CacheConfiguration setRebalanceTimeout(long rebalanceTimeout) { this.rebalanceTimeout = rebalanceTimeout; @@ -1295,6 +1326,7 @@ public class CacheConfiguration extends MutableConfiguration { * Sets rebalance delay (see {@link #getRebalanceDelay()} for more information). * * @param rebalanceDelay Rebalance delay to set. + * @return {@code this} for chaining. */ public CacheConfiguration setRebalanceDelay(long rebalanceDelay) { this.rebalanceDelay = rebalanceDelay; @@ -1330,6 +1362,7 @@ public class CacheConfiguration extends MutableConfiguration { * * @param rebalanceThrottle Time in milliseconds to wait between rebalance messages to avoid overloading of CPU, * {@code 0} to disable throttling. + * @return {@code this} for chaining. */ public CacheConfiguration setRebalanceThrottle(long rebalanceThrottle) { this.rebalanceThrottle = rebalanceThrottle; @@ -1356,6 +1389,7 @@ public class CacheConfiguration extends MutableConfiguration { * described in {@link AffinityKeyMapper} documentation. * * @param affMapper Affinity mapper. + * @return {@code this} for chaining. */ public CacheConfiguration setAffinityMapper(AffinityKeyMapper affMapper) { this.affMapper = affMapper; @@ -1402,6 +1436,7 @@ public class CacheConfiguration extends MutableConfiguration { * off-heap space without affecting JVM performance at all. * * @param offHeapMaxMem Maximum memory in bytes available to off-heap memory space. + * @return {@code this} for chaining. */ public CacheConfiguration setOffHeapMaxMemory(long offHeapMaxMem) { this.offHeapMaxMem = offHeapMaxMem; @@ -1425,6 +1460,7 @@ public class CacheConfiguration extends MutableConfiguration { * Sets memory mode for cache. * * @param memMode Memory mode. + * @return {@code this} for chaining. */ public CacheConfiguration setMemoryMode(CacheMemoryMode memMode) { this.memMode = memMode; @@ -1446,6 +1482,7 @@ public class CacheConfiguration extends MutableConfiguration { * Sets cache interceptor. * * @param interceptor Cache interceptor. + * @return {@code this} for chaining. */ public CacheConfiguration setInterceptor(CacheInterceptor interceptor) { this.interceptor = interceptor; @@ -1466,6 +1503,7 @@ public class CacheConfiguration extends MutableConfiguration { * Sets collection of type metadata objects. * * @param typeMeta Collection of type metadata. + * @return {@code this} for chaining. */ public CacheConfiguration setTypeMetadata(Collection typeMeta) { this.typeMeta = typeMeta; @@ -1490,6 +1528,7 @@ public class CacheConfiguration extends MutableConfiguration { * Sets read from backup flag. * * @param readFromBackup {@code true} to allow reads from backups. + * @return {@code this} for chaining. */ public CacheConfiguration setReadFromBackup(boolean readFromBackup) { this.readFromBackup = readFromBackup; @@ -1513,6 +1552,7 @@ public class CacheConfiguration extends MutableConfiguration { * * @param cpOnRead Copy on get flag. * @see #isCopyOnRead + * @return {@code this} for chaining. */ public CacheConfiguration setCopyOnRead(boolean cpOnRead) { this.cpOnRead = cpOnRead; @@ -1525,6 +1565,7 @@ public class CacheConfiguration extends MutableConfiguration { * to be used as user-defined functions from SQL queries. * * @param cls One or more classes with SQL functions. + * @return {@code this} for chaining. */ public CacheConfiguration setSqlFunctionClasses(Class... cls) { this.sqlFuncCls = cls; @@ -1555,6 +1596,7 @@ public class CacheConfiguration extends MutableConfiguration { * Gets timeout in milliseconds after which long query warning will be printed. * * @param longQryWarnTimeout Timeout in milliseconds. + * @return {@code this} for chaining. */ public CacheConfiguration setLongQueryWarningTimeout(long longQryWarnTimeout) { this.longQryWarnTimeout = longQryWarnTimeout; @@ -1579,6 +1621,7 @@ public class CacheConfiguration extends MutableConfiguration { * also allows having special characters in table and field names. * * @param sqlEscapeAll Flag value. + * @return {@code this} for chaining. */ public CacheConfiguration setSqlEscapeAll(boolean sqlEscapeAll) { this.sqlEscapeAll = sqlEscapeAll; @@ -1615,6 +1658,7 @@ public class CacheConfiguration extends MutableConfiguration { * from package {@link org.apache.ignite.cache.query.annotations}. * * @param indexedTypes Key and value type pairs. + * @return {@code this} for chaining. */ public CacheConfiguration setIndexedTypes(Class... indexedTypes) { A.ensure(indexedTypes == null || (indexedTypes.length & 1) == 0, @@ -1642,6 +1686,7 @@ public class CacheConfiguration extends MutableConfiguration { * * @param size Cache size. * @see #setOffHeapMaxMemory(long) + * @return {@code this} for chaining. */ public CacheConfiguration setSqlOnheapRowCacheSize(int size) { this.sqlOnheapRowCacheSize = size; @@ -1662,6 +1707,7 @@ public class CacheConfiguration extends MutableConfiguration { * Sets cache plugin configurations. * * @param pluginCfgs Cache plugin configurations. + * @return {@code this} for chaining. */ public CacheConfiguration setPluginConfigurations(CachePluginConfiguration... pluginCfgs) { this.pluginCfgs = pluginCfgs; @@ -1680,6 +1726,7 @@ public class CacheConfiguration extends MutableConfiguration { /** * Sets topology validator. * @param topValidator validator. + * @return {@code this} for chaining. */ public CacheConfiguration setTopologyValidator(TopologyValidator topValidator) { this.topValidator = topValidator; http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/4e0b661e/modules/core/src/main/java/org/apache/ignite/configuration/IgniteConfiguration.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/configuration/IgniteConfiguration.java b/modules/core/src/main/java/org/apache/ignite/configuration/IgniteConfiguration.java index b19c89e..ebe2b8e 100644 --- a/modules/core/src/main/java/org/apache/ignite/configuration/IgniteConfiguration.java +++ b/modules/core/src/main/java/org/apache/ignite/configuration/IgniteConfiguration.java @@ -533,6 +533,7 @@ public class IgniteConfiguration { * or in-memory data grid storage. * * @param daemon Daemon flag. + * @return {@code this} for chaining. */ public IgniteConfiguration setDaemon(boolean daemon) { this.daemon = daemon; @@ -545,6 +546,7 @@ public class IgniteConfiguration { * * @param gridName Grid name to set. Can be {@code null}, which is default * grid name. + * @return {@code this} for chaining. */ public IgniteConfiguration setGridName(String gridName) { this.gridName = gridName; @@ -581,6 +583,7 @@ public class IgniteConfiguration { * * @param userAttrs User attributes for this node. * @see IgniteConfiguration#getUserAttributes() + * @return {@code this} for chaining. */ public IgniteConfiguration setUserAttributes(Map userAttrs) { this.userAttrs = userAttrs; @@ -604,6 +607,7 @@ public class IgniteConfiguration { * * @param log Logger to use within grid. * @see IgniteConfiguration#getGridLogger() + * @return {@code this} for chaining. */ public IgniteConfiguration setGridLogger(IgniteLogger log) { this.log = log; @@ -723,6 +727,7 @@ public class IgniteConfiguration { * * @param poolSize Thread pool size to use within grid. * @see IgniteConfiguration#getPublicThreadPoolSize() + * @return {@code this} for chaining. */ public IgniteConfiguration setPublicThreadPoolSize(int poolSize) { pubPoolSize = poolSize; @@ -735,6 +740,7 @@ public class IgniteConfiguration { * * @param poolSize Thread pool size to use within grid. * @see IgniteConfiguration#getSystemThreadPoolSize() + * @return {@code this} for chaining. */ public IgniteConfiguration setSystemThreadPoolSize(int poolSize) { sysPoolSize = poolSize; @@ -747,6 +753,7 @@ public class IgniteConfiguration { * * @param poolSize Thread pool size to use within grid. * @see IgniteConfiguration#getManagementThreadPoolSize() + * @return {@code this} for chaining. */ public IgniteConfiguration setManagementThreadPoolSize(int poolSize) { mgmtPoolSize = poolSize; @@ -759,6 +766,7 @@ public class IgniteConfiguration { * * @param poolSize Thread pool size to use within grid. * @see IgniteConfiguration#getPeerClassLoadingThreadPoolSize() + * @return {@code this} for chaining. */ public IgniteConfiguration setPeerClassLoadingThreadPoolSize(int poolSize) { p2pPoolSize = poolSize; @@ -771,6 +779,7 @@ public class IgniteConfiguration { * * @param poolSize Executor service to use for outgoing IGFS messages. * @see IgniteConfiguration#getIgfsThreadPoolSize() + * @return {@code this} for chaining. */ public IgniteConfiguration setIgfsThreadPoolSize(int poolSize) { igfsPoolSize = poolSize; @@ -784,6 +793,7 @@ public class IgniteConfiguration { * @param poolSize Default executor service size to use for utility cache messages. * @see IgniteConfiguration#getUtilityCacheThreadPoolSize() * @see IgniteConfiguration#getUtilityCacheKeepAliveTime() + * @return {@code this} for chaining. */ public IgniteConfiguration setUtilityCachePoolSize(int poolSize) { utilityCachePoolSize = poolSize; @@ -797,6 +807,7 @@ public class IgniteConfiguration { * @param keepAliveTime Keep alive time of executor service to use for utility cache messages. * @see IgniteConfiguration#getUtilityCacheThreadPoolSize() * @see IgniteConfiguration#getUtilityCacheKeepAliveTime() + * @return {@code this} for chaining. */ public IgniteConfiguration setUtilityCacheKeepAliveTime(long keepAliveTime) { utilityCacheKeepAliveTime = keepAliveTime; @@ -810,6 +821,7 @@ public class IgniteConfiguration { * @param poolSize Default executor service size to use for marshaller messages. * @see IgniteConfiguration#getMarshallerCacheThreadPoolSize() * @see IgniteConfiguration#getMarshallerCacheKeepAliveTime() + * @return {@code this} for chaining. */ public IgniteConfiguration setMarshallerCachePoolSize(int poolSize) { marshCachePoolSize = poolSize; @@ -823,6 +835,7 @@ public class IgniteConfiguration { * @param keepAliveTime Keep alive time of executor service to use for marshaller messages. * @see IgniteConfiguration#getMarshallerCacheThreadPoolSize() * @see IgniteConfiguration#getMarshallerCacheKeepAliveTime() + * @return {@code this} for chaining. */ public IgniteConfiguration setMarshallerCacheKeepAliveTime(long keepAliveTime) { marshCacheKeepAliveTime = keepAliveTime; @@ -850,6 +863,7 @@ public class IgniteConfiguration { * @param ggHome {@code Ignition} installation folder. * @see IgniteConfiguration#getIgniteHome() * @see IgniteSystemProperties#IGNITE_HOME + * @return {@code this} for chaining. */ public IgniteConfiguration setIgniteHome(String ggHome) { this.ggHome = ggHome; @@ -877,6 +891,7 @@ public class IgniteConfiguration { * * @param ggWork {@code Ignite} work folder. * @see IgniteConfiguration#getWorkDirectory() + * @return {@code this} for chaining. */ public IgniteConfiguration setWorkDirectory(String ggWork) { this.ggWork = ggWork; @@ -899,6 +914,7 @@ public class IgniteConfiguration { * Sets initialized and started MBean server. * * @param mbeanSrv Initialized and started MBean server. + * @return {@code this} for chaining. */ public IgniteConfiguration setMBeanServer(MBeanServer mbeanSrv) { this.mbeanSrv = mbeanSrv; @@ -920,6 +936,7 @@ public class IgniteConfiguration { * * @param nodeId Unique identifier for local node. * @see IgniteConfiguration#getNodeId() + * @return {@code this} for chaining. */ public IgniteConfiguration setNodeId(UUID nodeId) { this.nodeId = nodeId; @@ -943,6 +960,7 @@ public class IgniteConfiguration { * * @param marsh Marshaller to use within grid. * @see IgniteConfiguration#getMarshaller() + * @return {@code this} for chaining. */ public IgniteConfiguration setMarshaller(Marshaller marsh) { this.marsh = marsh; @@ -985,6 +1003,7 @@ public class IgniteConfiguration { * Sets marshal local jobs flag. * * @param marshLocJobs {@code True} if local jobs should be marshalled. + * @return {@code this} for chaining. */ public IgniteConfiguration setMarshalLocalJobs(boolean marshLocJobs) { this.marshLocJobs = marshLocJobs; @@ -997,6 +1016,7 @@ public class IgniteConfiguration { * * @param p2pEnabled {@code true} if peer class loading is * enabled, {@code false} otherwise. + * @return {@code this} for chaining. */ public IgniteConfiguration setPeerClassLoadingEnabled(boolean p2pEnabled) { this.p2pEnabled = p2pEnabled; @@ -1023,6 +1043,7 @@ public class IgniteConfiguration { * * @param p2pLocClsPathExcl List of P2P loaded packages. Package * name supports '*' at the end like in package import clause. + * @return {@code this} for chaining. */ public IgniteConfiguration setPeerClassLoadingLocalClassPathExclude(String... p2pLocClsPathExcl) { this.p2pLocClsPathExcl = p2pLocClsPathExcl; @@ -1049,6 +1070,7 @@ public class IgniteConfiguration { * @param metricsHistSize Number of metrics kept in history to use for * metric totals and averages calculations. * @see #DFLT_METRICS_HISTORY_SIZE + * @return {@code this} for chaining. */ public IgniteConfiguration setMetricsHistorySize(int metricsHistSize) { this.metricsHistSize = metricsHistSize; @@ -1087,6 +1109,7 @@ public class IgniteConfiguration { * {@link #DFLT_METRICS_UPDATE_FREQ} is used. * * @param metricsUpdateFreq Job metrics update frequency in milliseconds. + * @return {@code this} for chaining. */ public IgniteConfiguration setMetricsUpdateFrequency(long metricsUpdateFreq) { this.metricsUpdateFreq = metricsUpdateFreq; @@ -1112,6 +1135,7 @@ public class IgniteConfiguration { * * @param metricsExpTime The metricsExpTime to set. * @see #DFLT_METRICS_EXPIRE_TIME + * @return {@code this} for chaining. */ public IgniteConfiguration setMetricsExpireTime(long metricsExpTime) { this.metricsExpTime = metricsExpTime; @@ -1140,6 +1164,7 @@ public class IgniteConfiguration { * * @param netTimeout Maximum timeout for network requests. * @see #DFLT_NETWORK_TIMEOUT + * @return {@code this} for chaining. */ public IgniteConfiguration setNetworkTimeout(long netTimeout) { this.netTimeout = netTimeout; @@ -1168,6 +1193,7 @@ public class IgniteConfiguration { * {@link #DFLT_SEND_RETRY_DELAY} is used. * * @param sndRetryDelay Interval between message send retries. + * @return {@code this} for chaining. */ public IgniteConfiguration setNetworkSendRetryDelay(long sndRetryDelay) { this.sndRetryDelay = sndRetryDelay; @@ -1196,6 +1222,7 @@ public class IgniteConfiguration { * {@link #DFLT_SEND_RETRY_CNT} is used. * * @param sndRetryCnt Message send retries count. + * @return {@code this} for chaining. */ public IgniteConfiguration setNetworkSendRetryCount(int sndRetryCnt) { this.sndRetryCnt = sndRetryCnt; @@ -1218,6 +1245,7 @@ public class IgniteConfiguration { * Sets number of samples used for clock synchronization. * * @param clockSyncSamples Number of samples. + * @return {@code this} for chaining. */ public IgniteConfiguration setClockSyncSamples(int clockSyncSamples) { this.clockSyncSamples = clockSyncSamples; @@ -1240,6 +1268,7 @@ public class IgniteConfiguration { * Sets clock synchronization frequency in milliseconds. * * @param clockSyncFreq Clock synchronization frequency. + * @return {@code this} for chaining. */ public IgniteConfiguration setClockSyncFrequency(long clockSyncFreq) { this.clockSyncFreq = clockSyncFreq; @@ -1269,6 +1298,7 @@ public class IgniteConfiguration { * * @param lifecycleBeans Collection of lifecycle beans. * @see LifecycleEventType + * @return {@code this} for chaining. */ public IgniteConfiguration setLifecycleBeans(LifecycleBean... lifecycleBeans) { this.lifecycleBeans = lifecycleBeans; @@ -1291,6 +1321,7 @@ public class IgniteConfiguration { * * @param evtSpi Fully configured instance of {@link EventStorageSpi}. * @see IgniteConfiguration#getEventStorageSpi() + * @return {@code this} for chaining. */ public IgniteConfiguration setEventStorageSpi(EventStorageSpi evtSpi) { this.evtSpi = evtSpi; @@ -1313,6 +1344,7 @@ public class IgniteConfiguration { * * @param discoSpi Fully configured instance of {@link DiscoverySpi}. * @see IgniteConfiguration#getDiscoverySpi() + * @return {@code this} for chaining. */ public IgniteConfiguration setDiscoverySpi(DiscoverySpi discoSpi) { this.discoSpi = discoSpi; @@ -1333,6 +1365,7 @@ public class IgniteConfiguration { * Sets segmentation policy. * * @param segPlc Segmentation policy. + * @return {@code this} for chaining. */ public IgniteConfiguration setSegmentationPolicy(SegmentationPolicy segPlc) { this.segPlc = segPlc; @@ -1359,6 +1392,7 @@ public class IgniteConfiguration { * Sets wait for segment on start flag. * * @param waitForSegOnStart {@code True} to wait for segment on start. + * @return {@code this} for chaining. */ public IgniteConfiguration setWaitForSegmentOnStart(boolean waitForSegOnStart) { this.waitForSegOnStart = waitForSegOnStart; @@ -1388,6 +1422,7 @@ public class IgniteConfiguration { * * @param allResolversPassReq {@code True} if all segmentation resolvers should * succeed for node to be in the correct segment. + * @return {@code this} for chaining. */ public IgniteConfiguration setAllSegmentationResolversPassRequired(boolean allResolversPassReq) { this.allResolversPassReq = allResolversPassReq; @@ -1411,6 +1446,7 @@ public class IgniteConfiguration { * Sets segmentation resolve attempts count. * * @param segResolveAttempts Segmentation resolve attempts. + * @return {@code this} for chaining. */ public IgniteConfiguration setSegmentationResolveAttempts(int segResolveAttempts) { this.segResolveAttempts = segResolveAttempts; @@ -1434,6 +1470,7 @@ public class IgniteConfiguration { * Sets segmentation resolvers. * * @param segResolvers Segmentation resolvers. + * @return {@code this} for chaining. */ public IgniteConfiguration setSegmentationResolvers(SegmentationResolver... segResolvers) { this.segResolvers = segResolvers; @@ -1459,6 +1496,7 @@ public class IgniteConfiguration { * Sets network segment check frequency. * * @param segChkFreq Segment check frequency. + * @return {@code this} for chaining. */ public IgniteConfiguration setSegmentCheckFrequency(long segChkFreq) { this.segChkFreq = segChkFreq; @@ -1481,6 +1519,7 @@ public class IgniteConfiguration { * * @param commSpi Fully configured instance of {@link CommunicationSpi}. * @see IgniteConfiguration#getCommunicationSpi() + * @return {@code this} for chaining. */ public IgniteConfiguration setCommunicationSpi(CommunicationSpi commSpi) { this.commSpi = commSpi; @@ -1508,6 +1547,7 @@ public class IgniteConfiguration { * @param colSpi Fully configured instance of {@link CollisionSpi} or * {@code null} if no SPI provided. * @see IgniteConfiguration#getCollisionSpi() + * @return {@code this} for chaining. */ public IgniteConfiguration setCollisionSpi(CollisionSpi colSpi) { this.colSpi = colSpi; @@ -1530,6 +1570,7 @@ public class IgniteConfiguration { * * @param deploySpi Fully configured instance of {@link DeploymentSpi}. * @see IgniteConfiguration#getDeploymentSpi() + * @return {@code this} for chaining. */ public IgniteConfiguration setDeploymentSpi(DeploymentSpi deploySpi) { this.deploySpi = deploySpi; @@ -1552,6 +1593,7 @@ public class IgniteConfiguration { * * @param cpSpi Fully configured instance of {@link CheckpointSpi}. * @see IgniteConfiguration#getCheckpointSpi() + * @return {@code this} for chaining. */ public IgniteConfiguration setCheckpointSpi(CheckpointSpi... cpSpi) { this.cpSpi = cpSpi; @@ -1575,6 +1617,7 @@ public class IgniteConfiguration { * @param failSpi Fully configured instance of {@link FailoverSpi} or * {@code null} if no SPI provided. * @see IgniteConfiguration#getFailoverSpi() + * @return {@code this} for chaining. */ public IgniteConfiguration setFailoverSpi(FailoverSpi... failSpi) { this.failSpi = failSpi; @@ -1619,6 +1662,7 @@ public class IgniteConfiguration { * * @param discoStartupDelay Time in milliseconds for when nodes * can be out-of-sync during startup. + * @return {@code this} for chaining. */ public IgniteConfiguration setDiscoveryStartupDelay(long discoStartupDelay) { this.discoStartupDelay = discoStartupDelay; @@ -1632,6 +1676,7 @@ public class IgniteConfiguration { * @param loadBalancingSpi Fully configured instance of {@link LoadBalancingSpi} or * {@code null} if no SPI provided. * @see IgniteConfiguration#getLoadBalancingSpi() + * @return {@code this} for chaining. */ public IgniteConfiguration setLoadBalancingSpi(LoadBalancingSpi... loadBalancingSpi) { this.loadBalancingSpi = loadBalancingSpi; @@ -1645,6 +1690,7 @@ public class IgniteConfiguration { * @param swapSpaceSpi Fully configured instances of {@link SwapSpaceSpi} or * null if no SPI provided. * @see IgniteConfiguration#getSwapSpaceSpi() + * @return {@code this} for chaining. */ public IgniteConfiguration setSwapSpaceSpi(SwapSpaceSpi swapSpaceSpi) { this.swapSpaceSpi = swapSpaceSpi; @@ -1670,6 +1716,7 @@ public class IgniteConfiguration { * * @param indexingSpi Fully configured instance of {@link IndexingSpi}. * @see IgniteConfiguration#getIndexingSpi() + * @return {@code this} for chaining. */ public IgniteConfiguration setIndexingSpi(IndexingSpi indexingSpi) { this.indexingSpi = indexingSpi; @@ -1699,6 +1746,7 @@ public class IgniteConfiguration { * Sets address resolver for addresses mapping determination. * * @param addrRslvr Address resolver. + * @return {@code this} for chaining. */ public IgniteConfiguration setAddressResolver(AddressResolver addrRslvr) { this.addrRslvr = addrRslvr; @@ -1710,6 +1758,7 @@ public class IgniteConfiguration { * Sets task classes and resources sharing mode. * * @param deployMode Task classes and resources sharing mode. + * @return {@code this} for chaining. */ public IgniteConfiguration setDeploymentMode(DeploymentMode deployMode) { this.deployMode = deployMode; @@ -1732,6 +1781,7 @@ public class IgniteConfiguration { * missed resources caching. * * @param p2pMissedCacheSize Size of missed resources cache. + * @return {@code this} for chaining. */ public IgniteConfiguration setPeerClassLoadingMissedResourcesCacheSize(int p2pMissedCacheSize) { this.p2pMissedCacheSize = p2pMissedCacheSize; @@ -1785,6 +1835,7 @@ public class IgniteConfiguration { * Sets client mode flag. * * @param clientMode Client mode flag. + * @return {@code this} for chaining. */ public IgniteConfiguration setClientMode(boolean clientMode) { this.clientMode = clientMode; @@ -1820,6 +1871,7 @@ public class IgniteConfiguration { * * @param cacheSanityCheckEnabled {@code True} if cache sanity check is enabled. * @see #isCacheSanityCheckEnabled() + * @return {@code this} for chaining. */ public IgniteConfiguration setCacheSanityCheckEnabled(boolean cacheSanityCheckEnabled) { this.cacheSanityCheckEnabled = cacheSanityCheckEnabled; @@ -1849,6 +1901,7 @@ public class IgniteConfiguration { * Note, that either the include event types or the exclude event types can be established. * * @param inclEvtTypes Include event types. + * @return {@code this} for chaining. */ public IgniteConfiguration setIncludeEventTypes(int... inclEvtTypes) { this.inclEvtTypes = inclEvtTypes; @@ -1861,6 +1914,7 @@ public class IgniteConfiguration { * override all default local bind settings within Ignite or any of its SPIs. * * @param locHost Local IP address or host to bind to. + * @return {@code this} for chaining. */ public IgniteConfiguration setLocalHost(String locHost) { this.locHost = locHost; @@ -1901,6 +1955,7 @@ public class IgniteConfiguration { * Sets time server port base. * * @param timeSrvPortBase Time server port base. + * @return {@code this} for chaining. */ public IgniteConfiguration setTimeServerPortBase(int timeSrvPortBase) { this.timeSrvPortBase = timeSrvPortBase; @@ -1921,6 +1976,7 @@ public class IgniteConfiguration { * Sets time server port range. * * @param timeSrvPortRange Time server port range. + * @return {@code this} for chaining. */ public IgniteConfiguration setTimeServerPortRange(int timeSrvPortRange) { this.timeSrvPortRange = timeSrvPortRange; @@ -1946,6 +2002,7 @@ public class IgniteConfiguration { * See {@link #getIncludeProperties()} for more info. * * @param includeProps Array of system or environment property names to include into node attributes. + * @return {@code this} for chaining. */ public IgniteConfiguration setIncludeProperties(String... includeProps) { this.includeProps = includeProps; @@ -1974,6 +2031,7 @@ public class IgniteConfiguration { * If not provided, then default value {@link #DFLT_METRICS_LOG_FREQ} is used. * * @param metricsLogFreq Frequency of metrics log print out. + * @return {@code this} for chaining. */ public IgniteConfiguration setMetricsLogFrequency(long metricsLogFreq) { this.metricsLogFreq = metricsLogFreq; @@ -1994,6 +2052,7 @@ public class IgniteConfiguration { * Sets IGFS (Ignite In-Memory File System) configurations. * * @param igfsCfg IGFS configurations. + * @return {@code this} for chaining. */ public IgniteConfiguration setFileSystemConfiguration(FileSystemConfiguration... igfsCfg) { this.igfsCfg = igfsCfg; @@ -2014,6 +2073,7 @@ public class IgniteConfiguration { * Sets hadoop configuration. * * @param hadoopCfg Hadoop configuration. + * @return {@code this} for chaining. */ public IgniteConfiguration setHadoopConfiguration(HadoopConfiguration hadoopCfg) { this.hadoopCfg = hadoopCfg; @@ -2030,6 +2090,7 @@ public class IgniteConfiguration { /** * @param connectorCfg Connector configuration. + * @return {@code this} for chaining. */ public IgniteConfiguration setConnectorConfiguration(ConnectorConfiguration connectorCfg) { this.connectorCfg = connectorCfg; @@ -2050,6 +2111,7 @@ public class IgniteConfiguration { * Sets configurations for services to be deployed on the grid. * * @param svcCfgs Configurations for services to be deployed on the grid. + * @return {@code this} for chaining. */ public IgniteConfiguration setServiceConfiguration(ServiceConfiguration... svcCfgs) { this.svcCfgs = svcCfgs; @@ -2073,6 +2135,7 @@ public class IgniteConfiguration { * Each listener is mapped to array of event types. * * @param lsnrs Pre-configured event listeners map. + * @return {@code this} for chaining. */ public IgniteConfiguration setLocalEventListeners(Map, int[]> lsnrs) { this.lsnrs = lsnrs; @@ -2095,6 +2158,7 @@ public class IgniteConfiguration { * * @param warmupClos Warmup closure to execute. * @see #getWarmupClosure() + * @return {@code this} for chaining. */ public IgniteConfiguration setWarmupClosure(IgniteInClosure warmupClos) { this.warmupClos = warmupClos; @@ -2115,6 +2179,7 @@ public class IgniteConfiguration { * Sets transactions configuration. * * @param txCfg Transactions configuration. + * @return {@code this} for chaining. */ public IgniteConfiguration setTransactionConfiguration(TransactionConfiguration txCfg) { this.txCfg = txCfg; @@ -2131,6 +2196,7 @@ public class IgniteConfiguration { /** * @param pluginCfgs Plugin configurations. + * @return {@code this} for chaining. */ public IgniteConfiguration setPluginConfigurations(PluginConfiguration... pluginCfgs) { this.pluginCfgs = pluginCfgs; @@ -2147,6 +2213,7 @@ public class IgniteConfiguration { /** * @param atomicCfg Atomic data structures configuration. + * @return {@code this} for chaining. */ public IgniteConfiguration setAtomicConfiguration(AtomicConfiguration atomicCfg) { this.atomicCfg = atomicCfg; @@ -2160,6 +2227,7 @@ public class IgniteConfiguration { * {@link ExpiryPolicy ExpiryPolicys}). * * @param classLdr Class loader. + * @return {@code this} for chaining. */ public IgniteConfiguration setClassLoader(ClassLoader classLdr) { this.classLdr = classLdr;