modules/core/src/main/java/org/apache/ignite/client/ClientCacheConfiguration.java - ignite - Git at Google

 /*
  * Licensed to the Apache Software Foundation (ASF) under one or more
  * contributor license agreements.  See the NOTICE file distributed with
  * this work for additional information regarding copyright ownership.
  * The ASF licenses this file to You under the Apache License, Version 2.0
  * (the "License"); you may not use this file except in compliance with
  * the License.  You may obtain a copy of the License at
  *
  *      http://www.apache.org/licenses/LICENSE-2.0
  *
  * Unless required by applicable law or agreed to in writing, software
  * distributed under the License is distributed on an "AS IS" BASIS,
  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */

 package org.apache.ignite.client;

 import java.io.Serializable;
 import javax.cache.expiry.ExpiryPolicy;
 import org.apache.ignite.cache.CacheAtomicityMode;
 import org.apache.ignite.cache.CacheKeyConfiguration;
 import org.apache.ignite.cache.CacheMode;
 import org.apache.ignite.cache.CacheRebalanceMode;
 import org.apache.ignite.cache.CacheWriteSynchronizationMode;
 import org.apache.ignite.cache.PartitionLossPolicy;
 import org.apache.ignite.cache.QueryEntity;
 import org.apache.ignite.configuration.CacheConfiguration;
 import org.apache.ignite.configuration.IgniteConfiguration;
 import org.apache.ignite.internal.util.typedef.internal.S;

 /** Cache configuration. */
 public final class ClientCacheConfiguration implements Serializable {
     /** Serial version uid. */
     private static final long serialVersionUID = 0L;

     /** @serial Cache name. */
     private String name;

     /** @serial Atomicity mode. */
     private CacheAtomicityMode atomicityMode = CacheConfiguration.DFLT_CACHE_ATOMICITY_MODE;

     /** @serial Backups. */
     private int backups = CacheConfiguration.DFLT_BACKUPS;

     /** @serial Cache mode. */
     private CacheMode cacheMode = CacheConfiguration.DFLT_CACHE_MODE;

     /** @serial Eager TTL flag. */
     private boolean eagerTtl = CacheConfiguration.DFLT_EAGER_TTL;

     /** @serial Group name. */
     private String grpName = null;

     /** @serial Default lock timeout. */
     private long dfltLockTimeout = CacheConfiguration.DFLT_LOCK_TIMEOUT;

     /** @serial Partition loss policy. */
     private PartitionLossPolicy partLossPlc = CacheConfiguration.DFLT_PARTITION_LOSS_POLICY;

     /** @serial Read from backup. */
     private boolean readFromBackup = CacheConfiguration.DFLT_READ_FROM_BACKUP;

     /** @serial Rebalance batch size. */
     private int rebalanceBatchSize = IgniteConfiguration.DFLT_REBALANCE_BATCH_SIZE;

     /** @serial Rebalance batches prefetch count. */
     private long rebalanceBatchesPrefetchCnt = IgniteConfiguration.DFLT_REBALANCE_BATCHES_PREFETCH_COUNT;

     /** @serial Rebalance delay. */
     private long rebalanceDelay = 0;

     /** @serial Rebalance mode. */
     private CacheRebalanceMode rebalanceMode = CacheConfiguration.DFLT_REBALANCE_MODE;

     /** @serial Rebalance order. */
     private int rebalanceOrder = 0;

     /** @serial Rebalance throttle. */
     private long rebalanceThrottle = IgniteConfiguration.DFLT_REBALANCE_THROTTLE;

     /** @serial @serial Rebalance timeout. */
     private long rebalanceTimeout = IgniteConfiguration.DFLT_REBALANCE_TIMEOUT;

     /** @serial Write synchronization mode. */
     private CacheWriteSynchronizationMode writeSynchronizationMode = CacheWriteSynchronizationMode.PRIMARY_SYNC;

     /** @serial Copy on read. */
     private boolean cpOnRead = CacheConfiguration.DFLT_COPY_ON_READ;

     /** @serial Data region name. */
     private String dataRegionName = null;

     /** @serial Statistics enabled. */
     private boolean statisticsEnabled = false;

     /** @serial Max concurrent async operations. */
     private int maxConcurrentAsyncOperations = CacheConfiguration.DFLT_MAX_CONCURRENT_ASYNC_OPS;

     /** @serial Max query iterators count. */
     private int maxQryIteratorsCnt = CacheConfiguration.DFLT_MAX_QUERY_ITERATOR_CNT;

     /** @serial Onheap cache enabled. */
     private boolean onheapCacheEnabled = false;

     /** @serial Query detail metrics size. */
     private int qryDetailMetricsSize = CacheConfiguration.DFLT_QRY_DETAIL_METRICS_SIZE;

     /** @serial Query parallelism. */
     private int qryParallelism = CacheConfiguration.DFLT_QUERY_PARALLELISM;

     /** @serial Sql escape all. */
     private boolean sqlEscapeAll = false;

     /** @serial Sql index max inline size. */
     private int sqlIdxMaxInlineSize = CacheConfiguration.DFLT_SQL_INDEX_MAX_INLINE_SIZE;

     /** @serial Sql schema. */
     private String sqlSchema = null;

     /** @serial Key config. */
     private CacheKeyConfiguration[] keyCfg = null;

     /** @serial Query entities. */
     private QueryEntity[] qryEntities = null;

     /** @serial Expiry policy. */
     private ExpiryPolicy expiryPlc;

     /** Default constructor. */
     public ClientCacheConfiguration() {
         // No-op.
     }

     /**
      * Creates client cache configuration by coping all configuration properties from the given one.
      *
      * @param ccfg Client cache configuration to copy from.
      */
     public ClientCacheConfiguration(ClientCacheConfiguration ccfg) {
         atomicityMode = ccfg.getAtomicityMode();
         backups = ccfg.getBackups();
         cacheMode = ccfg.getCacheMode();
         cpOnRead = ccfg.isCopyOnRead();
         dataRegionName = ccfg.getDataRegionName();
         dfltLockTimeout = ccfg.getDefaultLockTimeout();
         eagerTtl = ccfg.isEagerTtl();
         expiryPlc = ccfg.getExpiryPolicy();
         grpName = ccfg.getGroupName();
         keyCfg = ccfg.getKeyConfiguration();
         maxConcurrentAsyncOperations = ccfg.getMaxConcurrentAsyncOperations();
         maxQryIteratorsCnt = ccfg.getMaxQueryIteratorsCount();
         name = ccfg.getName();
         onheapCacheEnabled = ccfg.isOnheapCacheEnabled();
         partLossPlc = ccfg.getPartitionLossPolicy();
         qryDetailMetricsSize = ccfg.getQueryDetailMetricsSize();
         qryEntities = ccfg.getQueryEntities();
         qryParallelism = ccfg.getQueryParallelism();
         readFromBackup = ccfg.isReadFromBackup();
         rebalanceBatchSize = ccfg.getRebalanceBatchSize();
         rebalanceBatchesPrefetchCnt = ccfg.getRebalanceBatchesPrefetchCount();
         rebalanceDelay = ccfg.getRebalanceDelay();
         rebalanceMode = ccfg.getRebalanceMode();
         rebalanceOrder = ccfg.getRebalanceOrder();
         rebalanceThrottle = ccfg.getRebalanceThrottle();
         rebalanceTimeout = ccfg.getRebalanceTimeout();
         sqlEscapeAll = ccfg.isSqlEscapeAll();
         sqlIdxMaxInlineSize = ccfg.getSqlIndexMaxInlineSize();
         sqlSchema = ccfg.getSqlSchema();
         statisticsEnabled = ccfg.isStatisticsEnabled();
         writeSynchronizationMode = ccfg.getWriteSynchronizationMode();
     }

     /**
      * @return Cache name.
      */
     public String getName() {
         return name;
     }

     /**
      * @param name New cache name.
      * @return {@code this} for chaining.
      */
     public ClientCacheConfiguration setName(String name) {
         this.name = name;

         return this;
     }

     /**
      * @return Cache atomicity mode.
      */
     public CacheAtomicityMode getAtomicityMode() {
         return atomicityMode;
     }

     /**
      * @param atomicityMode New Atomicity mode.
      * @return {@code this} for chaining.
      */
     public ClientCacheConfiguration setAtomicityMode(CacheAtomicityMode atomicityMode) {
         this.atomicityMode = atomicityMode;

         return this;
     }

     /**
      * @return Number of backups.
      */
     public int getBackups() {
         return backups;
     }

     /**
      * @param backups New number of backups.
      * @return {@code this} for chaining.
      */
     public ClientCacheConfiguration setBackups(int backups) {
         this.backups = backups;

         return this;
     }

     /**
      * @return Cache mode.
      */
     public CacheMode getCacheMode() {
         return cacheMode;
     }

     /**
      * @param cacheMode New cache mode.
      * @return {@code this} for chaining.
      */
     public ClientCacheConfiguration setCacheMode(CacheMode cacheMode) {
         this.cacheMode = cacheMode;

         return this;
     }

     /**
      * Gets flag indicating whether expired cache entries will be eagerly removed from cache.
      * If there is at least one cache configured with this flag set to {@code true}, Ignite
      * will create a single thread to clean up expired entries in background. When flag is
      * set to {@code false}, expired entries will be removed on next entry access.
      *
      * @return Flag indicating whether Ignite will eagerly remove expired entries.
      */
     public boolean isEagerTtl() {
         return eagerTtl;
     }

     /**
      * @param eagerTtl {@code True} if Ignite should eagerly remove expired cache entries.
      * @return {@code this} for chaining.
      */
     public ClientCacheConfiguration setEagerTtl(boolean eagerTtl) {
         this.eagerTtl = eagerTtl;

         return this;
     }

     /**
      * Gets the cache group name.
      * <p>
      * Caches with the same group name share single underlying 'physical' cache (partition set),
      * but are logically isolated. Grouping caches reduces overall overhead, since internal data structures are shared.
      * </p>
      *
      * @return {@code this} for chaining.
      */
     public String getGroupName() {
         return grpName;
     }

     /**
      * @param newVal Group name.
      * @return {@code this} for chaining.
      */
     public ClientCacheConfiguration setGroupName(String newVal) {
         grpName = newVal;

         return this;
     }

     /**
      * @return Default lock acquisition timeout. {@code 0} and means that lock acquisition will never timeout.
      */
     public long getDefaultLockTimeout() {
         return dfltLockTimeout;
     }

     /**
      * @param dfltLockTimeout Default lock timeout.
      * @return {@code this} for chaining.
      */
     public ClientCacheConfiguration setDefaultLockTimeout(long dfltLockTimeout) {
         this.dfltLockTimeout = dfltLockTimeout;

         return this;
     }

     /**
      * @return Partition loss policy. This policy defines how Ignite will react to a situation when all nodes for
      * some partition leave the cluster.
      */
     public PartitionLossPolicy getPartitionLossPolicy() {
         return partLossPlc;
     }

     /**
      * @param newVal Partition loss policy.
      * @return {@code this} for chaining.
      */
     public ClientCacheConfiguration setPartitionLossPolicy(PartitionLossPolicy newVal) {
         partLossPlc = newVal;

         return this;
     }

     /**
      * @return Flag indicating whether data can be read from backup.
      * If {@code false} always get data from primary node (never from backup).
      */
     public boolean isReadFromBackup() {
         return readFromBackup;
     }

     /**
      * @param readFromBackup Read from backup.
      * @return {@code this} for chaining.
      */
     public ClientCacheConfiguration setReadFromBackup(boolean readFromBackup) {
         this.readFromBackup = readFromBackup;

         return this;
     }

     /**
      * @return Size (in number bytes) to be loaded within a single rebalance message.
      * Rebalancing algorithm will split total data set on every node into multiple
      * batches prior to sending data.
      */
     public int getRebalanceBatchSize() {
         return rebalanceBatchSize;
     }

     /**
      * @param rebalanceBatchSize Rebalance batch size.
      * @return {@code this} for chaining.
      */
     public ClientCacheConfiguration setRebalanceBatchSize(int rebalanceBatchSize) {
         this.rebalanceBatchSize = rebalanceBatchSize;

         return this;
     }

     /**
      * 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.
      *
      * @return Number of batches generated by supply node at rebalancing start.
      * Minimum is 1.
      */
     public long getRebalanceBatchesPrefetchCount() {
         return rebalanceBatchesPrefetchCnt;
     }

     /**
      * @param rebalanceBatchesPrefetchCnt Rebalance batches prefetch count.
      * @return {@code this} for chaining.
      */
     public ClientCacheConfiguration setRebalanceBatchesPrefetchCount(long rebalanceBatchesPrefetchCnt) {
         this.rebalanceBatchesPrefetchCnt = rebalanceBatchesPrefetchCnt;

         return this;
     }

     /**
      * @return Delay in milliseconds upon a node joining or leaving topology (or crash) after which rebalancing
      * should be started automatically. Rebalancing should be delayed if you plan to restart nodes
      * after they leave topology, or if you plan to start multiple nodes at once or one after another
      * and don't want to repartition and rebalance until all nodes are started.
      * <p>
      * Default value is {@code 0} which means that repartitioning and rebalancing will start
      * immediately upon node leaving topology. If {@code -1} is returned, then rebalancing
      * will only be started manually.
      * </p>
      */
     public long getRebalanceDelay() {
         return rebalanceDelay;
     }

     /**
      * @param rebalanceDelay Rebalance delay.
      * @return {@code this} for chaining.
      */
     public ClientCacheConfiguration setRebalanceDelay(long rebalanceDelay) {
         this.rebalanceDelay = rebalanceDelay;

         return this;
     }

     /**
      * Gets rebalance mode.
      * @return {@code this} for chaining.
      */
     public CacheRebalanceMode getRebalanceMode() {
         return rebalanceMode;
     }

     /**
      * @param rebalanceMode Rebalance mode.
      * @return {@code this} for chaining.
      */
     public ClientCacheConfiguration setRebalanceMode(CacheRebalanceMode rebalanceMode) {
         this.rebalanceMode = rebalanceMode;

         return this;
     }

     /**
      * @return Cache rebalance order. Rebalance order can be set to non-zero value for caches with
      * {@link CacheRebalanceMode#SYNC SYNC} or {@link CacheRebalanceMode#ASYNC ASYNC} rebalance modes only.
      * <p/>
      * If cache rebalance order is positive, rebalancing for this cache will be started only when rebalancing for
      * all caches with smaller rebalance order will be completed.
      * <p/>
      * Note that cache with order {@code 0} does not participate in ordering. This means that cache with
      * rebalance order {@code 0} will never wait for any other caches. All caches with order {@code 0} will
      * be rebalanced right away concurrently with each other and ordered rebalance processes.
      * <p/>
      * If not set, cache order is 0, i.e. rebalancing is not ordered.
      */
     public int getRebalanceOrder() {
         return rebalanceOrder;
     }

     /**
      * @param rebalanceOrder Rebalance order.
      * @return {@code this} for chaining.
      */
     public ClientCacheConfiguration setRebalanceOrder(int rebalanceOrder) {
         this.rebalanceOrder = rebalanceOrder;

         return this;
     }

     /**
      * @return 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.
      * <p>
      * Default value of {@code 0} means that throttling is disabled.
      * </p>
      */
     public long getRebalanceThrottle() {
         return rebalanceThrottle;
     }

     /**
      * @param newVal Rebalance throttle.
      * @return {@code this} for chaining.
      */
     public ClientCacheConfiguration setRebalanceThrottle(long newVal) {
         rebalanceThrottle = newVal;

         return this;
     }

     /**
      * @return Rebalance timeout (ms).
      */
     public long getRebalanceTimeout() {
         return rebalanceTimeout;
     }

     /**
      * @param newVal Rebalance timeout.
      * @return {@code this} for chaining.
      */
     public ClientCacheConfiguration setRebalanceTimeout(long newVal) {
         rebalanceTimeout = newVal;

         return this;
     }

     /**
      * @return Write synchronization mode. This mode controls whether the main caller should wait for update on other
      * nodes to complete or not.
      */
     public CacheWriteSynchronizationMode getWriteSynchronizationMode() {
         return writeSynchronizationMode;
     }

     /**
      * @param newVal Write synchronization mode.
      * @return {@code this} for chaining.
      */
     public ClientCacheConfiguration setWriteSynchronizationMode(CacheWriteSynchronizationMode newVal) {
         writeSynchronizationMode = newVal;

         return this;
     }

     /**
      * @return Copy on read.
      */
     public boolean isCopyOnRead() {
         return cpOnRead;
     }

     /**
      * @param newVal Copy on read.
      * @return {@code this} for chaining.
      */
     public ClientCacheConfiguration setCopyOnRead(boolean newVal) {
         cpOnRead = newVal;

         return this;
     }

     /**
      * @return Max concurrent async operations.
      */
     public int getMaxConcurrentAsyncOperations() {
         return maxConcurrentAsyncOperations;
     }

     /**
      * @param newVal Max concurrent async operations.
      * @return {@code this} for chaining.
      */
     public ClientCacheConfiguration setMaxConcurrentAsyncOperations(int newVal) {
         maxConcurrentAsyncOperations = newVal;

         return this;
     }

     /**
      * @return Data region name.
      */
     public String getDataRegionName() {
         return dataRegionName;
     }

     /**
      * @param newVal Data region name.
      * @return {@code this} for chaining.
      */
     public ClientCacheConfiguration setDataRegionName(String newVal) {
         dataRegionName = newVal;

         return this;
     }

     /**
      * @return Statistics enabled.
      */
     public boolean isStatisticsEnabled() {
         return statisticsEnabled;
     }

     /**
      * @param newVal Statistics enabled.
      * @return {@code this} for chaining.
      */
     public ClientCacheConfiguration setStatisticsEnabled(boolean newVal) {
         statisticsEnabled = newVal;

         return this;
     }

     /**
      * @return Max query iterators count.
      */
     public int getMaxQueryIteratorsCount() {
         return maxQryIteratorsCnt;
     }

     /**
      * @param newVal Max query iterators count.
      * @return {@code this} for chaining.
      */
     public ClientCacheConfiguration setMaxQueryIteratorsCount(int newVal) {
         maxQryIteratorsCnt = newVal;

         return this;
     }

     /**
      * @return Onheap cache enabled.
      */
     public boolean isOnheapCacheEnabled() {
         return onheapCacheEnabled;
     }

     /**
      * @param newVal Onheap cache enabled.
      * @return {@code this} for chaining.
      */
     public ClientCacheConfiguration setOnheapCacheEnabled(boolean newVal) {
         onheapCacheEnabled = newVal;

         return this;
     }

     /**
      * @return Query detail metrics size.
      */
     public int getQueryDetailMetricsSize() {
         return qryDetailMetricsSize;
     }

     /**
      * @param newVal Query detail metrics size.
      * @return {@code this} for chaining.
      */
     public ClientCacheConfiguration setQueryDetailMetricsSize(int newVal) {
         qryDetailMetricsSize = newVal;

         return this;
     }

     /**
      * @return Query parallelism.
      */
     public int getQueryParallelism() {
         return qryParallelism;
     }

     /**
      * @param newVal Query parallelism.
      * @return {@code this} for chaining.
      */
     public ClientCacheConfiguration setQueryParallelism(int newVal) {
         qryParallelism = newVal;

         return this;
     }

     /**
      * @return Sql escape all.
      */
     public boolean isSqlEscapeAll() {
         return sqlEscapeAll;
     }

     /**
      * @param newVal Sql escape all.
      * @return {@code this} for chaining.
      */
     public ClientCacheConfiguration setSqlEscapeAll(boolean newVal) {
         sqlEscapeAll = newVal;

         return this;
     }

     /**
      * @return Sql index max inline size.
      */
     public int getSqlIndexMaxInlineSize() {
         return sqlIdxMaxInlineSize;
     }

     /**
      * @param newVal Sql index max inline size.
      * @return {@code this} for chaining.
      */
     public ClientCacheConfiguration setSqlIndexMaxInlineSize(int newVal) {
         sqlIdxMaxInlineSize = newVal;

         return this;
     }

     /**
      * @return Sql schema.
      */
     public String getSqlSchema() {
         return sqlSchema;
     }

     /**
      * @param newVal Sql schema.
      * @return {@code this} for chaining.
      */
     public ClientCacheConfiguration setSqlSchema(String newVal) {
         sqlSchema = newVal;

         return this;
     }

     /**
      * @return Cache key configuration.
      */
     public CacheKeyConfiguration[] getKeyConfiguration() {
         return keyCfg;
     }

     /**
      * @param newVal Cache key configuration.
      * @return {@code this} for chaining.
      */
     public ClientCacheConfiguration setKeyConfiguration(CacheKeyConfiguration... newVal) {
         this.keyCfg = newVal;

         return this;
     }

     /**
      * @return Query entities configurations.
      */
     public QueryEntity[] getQueryEntities() {
         return qryEntities;
     }

     /**
      * @param newVal Query entities configurations.
      * @return {@code this} for chaining.
      */
     public ClientCacheConfiguration setQueryEntities(QueryEntity... newVal) {
         qryEntities = newVal;

         return this;
     }

     /**
      * @return Expire policy.
      */
     public ExpiryPolicy getExpiryPolicy() {
         return expiryPlc;
     }

     /**
      * @param expiryPlc Expiry policy.
      * @return {@code this} for chaining.
      */
     public ClientCacheConfiguration setExpiryPolicy(ExpiryPolicy expiryPlc) {
         this.expiryPlc = expiryPlc;

         return this;
     }

     /** {@inheritDoc} */
     @Override public String toString() {
         return S.toString(ClientCacheConfiguration.class, this);
     }
 }
	/*
	* Licensed to the Apache Software Foundation (ASF) under one or more
	* contributor license agreements. See the NOTICE file distributed with
	* this work for additional information regarding copyright ownership.
	* The ASF licenses this file to You under the Apache License, Version 2.0
	* (the "License"); you may not use this file except in compliance with
	* the License. You may obtain a copy of the License at
	*
	* http://www.apache.org/licenses/LICENSE-2.0
	*
	* Unless required by applicable law or agreed to in writing, software
	* distributed under the License is distributed on an "AS IS" BASIS,
	* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
	* See the License for the specific language governing permissions and
	* limitations under the License.
	*/

	package org.apache.ignite.client;

	import java.io.Serializable;
	import javax.cache.expiry.ExpiryPolicy;
	import org.apache.ignite.cache.CacheAtomicityMode;
	import org.apache.ignite.cache.CacheKeyConfiguration;
	import org.apache.ignite.cache.CacheMode;
	import org.apache.ignite.cache.CacheRebalanceMode;
	import org.apache.ignite.cache.CacheWriteSynchronizationMode;
	import org.apache.ignite.cache.PartitionLossPolicy;
	import org.apache.ignite.cache.QueryEntity;
	import org.apache.ignite.configuration.CacheConfiguration;
	import org.apache.ignite.configuration.IgniteConfiguration;
	import org.apache.ignite.internal.util.typedef.internal.S;

	/** Cache configuration. */
	public final class ClientCacheConfiguration implements Serializable {
	/** Serial version uid. */
	private static final long serialVersionUID = 0L;

	/** @serial Cache name. */
	private String name;

	/** @serial Atomicity mode. */
	private CacheAtomicityMode atomicityMode = CacheConfiguration.DFLT_CACHE_ATOMICITY_MODE;

	/** @serial Backups. */
	private int backups = CacheConfiguration.DFLT_BACKUPS;

	/** @serial Cache mode. */
	private CacheMode cacheMode = CacheConfiguration.DFLT_CACHE_MODE;

	/** @serial Eager TTL flag. */
	private boolean eagerTtl = CacheConfiguration.DFLT_EAGER_TTL;

	/** @serial Group name. */
	private String grpName = null;

	/** @serial Default lock timeout. */
	private long dfltLockTimeout = CacheConfiguration.DFLT_LOCK_TIMEOUT;

	/** @serial Partition loss policy. */
	private PartitionLossPolicy partLossPlc = CacheConfiguration.DFLT_PARTITION_LOSS_POLICY;

	/** @serial Read from backup. */
	private boolean readFromBackup = CacheConfiguration.DFLT_READ_FROM_BACKUP;

	/** @serial Rebalance batch size. */
	private int rebalanceBatchSize = IgniteConfiguration.DFLT_REBALANCE_BATCH_SIZE;

	/** @serial Rebalance batches prefetch count. */
	private long rebalanceBatchesPrefetchCnt = IgniteConfiguration.DFLT_REBALANCE_BATCHES_PREFETCH_COUNT;

	/** @serial Rebalance delay. */
	private long rebalanceDelay = 0;

	/** @serial Rebalance mode. */
	private CacheRebalanceMode rebalanceMode = CacheConfiguration.DFLT_REBALANCE_MODE;

	/** @serial Rebalance order. */
	private int rebalanceOrder = 0;

	/** @serial Rebalance throttle. */
	private long rebalanceThrottle = IgniteConfiguration.DFLT_REBALANCE_THROTTLE;

	/** @serial @serial Rebalance timeout. */
	private long rebalanceTimeout = IgniteConfiguration.DFLT_REBALANCE_TIMEOUT;

	/** @serial Write synchronization mode. */
	private CacheWriteSynchronizationMode writeSynchronizationMode = CacheWriteSynchronizationMode.PRIMARY_SYNC;

	/** @serial Copy on read. */
	private boolean cpOnRead = CacheConfiguration.DFLT_COPY_ON_READ;

	/** @serial Data region name. */
	private String dataRegionName = null;

	/** @serial Statistics enabled. */
	private boolean statisticsEnabled = false;

	/** @serial Max concurrent async operations. */
	private int maxConcurrentAsyncOperations = CacheConfiguration.DFLT_MAX_CONCURRENT_ASYNC_OPS;

	/** @serial Max query iterators count. */
	private int maxQryIteratorsCnt = CacheConfiguration.DFLT_MAX_QUERY_ITERATOR_CNT;

	/** @serial Onheap cache enabled. */
	private boolean onheapCacheEnabled = false;

	/** @serial Query detail metrics size. */
	private int qryDetailMetricsSize = CacheConfiguration.DFLT_QRY_DETAIL_METRICS_SIZE;

	/** @serial Query parallelism. */
	private int qryParallelism = CacheConfiguration.DFLT_QUERY_PARALLELISM;

	/** @serial Sql escape all. */
	private boolean sqlEscapeAll = false;

	/** @serial Sql index max inline size. */
	private int sqlIdxMaxInlineSize = CacheConfiguration.DFLT_SQL_INDEX_MAX_INLINE_SIZE;

	/** @serial Sql schema. */
	private String sqlSchema = null;

	/** @serial Key config. */
	private CacheKeyConfiguration[] keyCfg = null;

	/** @serial Query entities. */
	private QueryEntity[] qryEntities = null;

	/** @serial Expiry policy. */
	private ExpiryPolicy expiryPlc;

	/** Default constructor. */
	public ClientCacheConfiguration() {
	// No-op.
	}

	/**
	* Creates client cache configuration by coping all configuration properties from the given one.
	*
	* @param ccfg Client cache configuration to copy from.
	*/
	public ClientCacheConfiguration(ClientCacheConfiguration ccfg) {
	atomicityMode = ccfg.getAtomicityMode();
	backups = ccfg.getBackups();
	cacheMode = ccfg.getCacheMode();
	cpOnRead = ccfg.isCopyOnRead();
	dataRegionName = ccfg.getDataRegionName();
	dfltLockTimeout = ccfg.getDefaultLockTimeout();
	eagerTtl = ccfg.isEagerTtl();
	expiryPlc = ccfg.getExpiryPolicy();
	grpName = ccfg.getGroupName();
	keyCfg = ccfg.getKeyConfiguration();
	maxConcurrentAsyncOperations = ccfg.getMaxConcurrentAsyncOperations();
	maxQryIteratorsCnt = ccfg.getMaxQueryIteratorsCount();
	name = ccfg.getName();
	onheapCacheEnabled = ccfg.isOnheapCacheEnabled();
	partLossPlc = ccfg.getPartitionLossPolicy();
	qryDetailMetricsSize = ccfg.getQueryDetailMetricsSize();
	qryEntities = ccfg.getQueryEntities();
	qryParallelism = ccfg.getQueryParallelism();
	readFromBackup = ccfg.isReadFromBackup();
	rebalanceBatchSize = ccfg.getRebalanceBatchSize();
	rebalanceBatchesPrefetchCnt = ccfg.getRebalanceBatchesPrefetchCount();
	rebalanceDelay = ccfg.getRebalanceDelay();
	rebalanceMode = ccfg.getRebalanceMode();
	rebalanceOrder = ccfg.getRebalanceOrder();
	rebalanceThrottle = ccfg.getRebalanceThrottle();
	rebalanceTimeout = ccfg.getRebalanceTimeout();
	sqlEscapeAll = ccfg.isSqlEscapeAll();
	sqlIdxMaxInlineSize = ccfg.getSqlIndexMaxInlineSize();
	sqlSchema = ccfg.getSqlSchema();
	statisticsEnabled = ccfg.isStatisticsEnabled();
	writeSynchronizationMode = ccfg.getWriteSynchronizationMode();
	}

	/**
	* @return Cache name.
	*/
	public String getName() {
	return name;
	}

	/**
	* @param name New cache name.
	* @return {@code this} for chaining.
	*/
	public ClientCacheConfiguration setName(String name) {
	this.name = name;

	return this;
	}

	/**
	* @return Cache atomicity mode.
	*/
	public CacheAtomicityMode getAtomicityMode() {
	return atomicityMode;
	}

	/**
	* @param atomicityMode New Atomicity mode.
	* @return {@code this} for chaining.
	*/
	public ClientCacheConfiguration setAtomicityMode(CacheAtomicityMode atomicityMode) {
	this.atomicityMode = atomicityMode;

	return this;
	}

	/**
	* @return Number of backups.
	*/
	public int getBackups() {
	return backups;
	}

	/**
	* @param backups New number of backups.
	* @return {@code this} for chaining.
	*/
	public ClientCacheConfiguration setBackups(int backups) {
	this.backups = backups;

	return this;
	}

	/**
	* @return Cache mode.
	*/
	public CacheMode getCacheMode() {
	return cacheMode;
	}

	/**
	* @param cacheMode New cache mode.
	* @return {@code this} for chaining.
	*/
	public ClientCacheConfiguration setCacheMode(CacheMode cacheMode) {
	this.cacheMode = cacheMode;

	return this;
	}

	/**
	* Gets flag indicating whether expired cache entries will be eagerly removed from cache.
	* If there is at least one cache configured with this flag set to {@code true}, Ignite
	* will create a single thread to clean up expired entries in background. When flag is
	* set to {@code false}, expired entries will be removed on next entry access.
	*
	* @return Flag indicating whether Ignite will eagerly remove expired entries.
	*/
	public boolean isEagerTtl() {
	return eagerTtl;
	}

	/**
	* @param eagerTtl {@code True} if Ignite should eagerly remove expired cache entries.
	* @return {@code this} for chaining.
	*/
	public ClientCacheConfiguration setEagerTtl(boolean eagerTtl) {
	this.eagerTtl = eagerTtl;

	return this;
	}

	/**
	* Gets the cache group name.
	* <p>
	* Caches with the same group name share single underlying 'physical' cache (partition set),
	* but are logically isolated. Grouping caches reduces overall overhead, since internal data structures are shared.
	* </p>
	*
	* @return {@code this} for chaining.
	*/
	public String getGroupName() {
	return grpName;
	}

	/**
	* @param newVal Group name.
	* @return {@code this} for chaining.
	*/
	public ClientCacheConfiguration setGroupName(String newVal) {
	grpName = newVal;

	return this;
	}

	/**
	* @return Default lock acquisition timeout. {@code 0} and means that lock acquisition will never timeout.
	*/
	public long getDefaultLockTimeout() {
	return dfltLockTimeout;
	}

	/**
	* @param dfltLockTimeout Default lock timeout.
	* @return {@code this} for chaining.
	*/
	public ClientCacheConfiguration setDefaultLockTimeout(long dfltLockTimeout) {
	this.dfltLockTimeout = dfltLockTimeout;

	return this;
	}

	/**
	* @return Partition loss policy. This policy defines how Ignite will react to a situation when all nodes for
	* some partition leave the cluster.
	*/
	public PartitionLossPolicy getPartitionLossPolicy() {
	return partLossPlc;
	}

	/**
	* @param newVal Partition loss policy.
	* @return {@code this} for chaining.
	*/
	public ClientCacheConfiguration setPartitionLossPolicy(PartitionLossPolicy newVal) {
	partLossPlc = newVal;

	return this;
	}

	/**
	* @return Flag indicating whether data can be read from backup.
	* If {@code false} always get data from primary node (never from backup).
	*/
	public boolean isReadFromBackup() {
	return readFromBackup;
	}

	/**
	* @param readFromBackup Read from backup.
	* @return {@code this} for chaining.
	*/
	public ClientCacheConfiguration setReadFromBackup(boolean readFromBackup) {
	this.readFromBackup = readFromBackup;

	return this;
	}

	/**
	* @return Size (in number bytes) to be loaded within a single rebalance message.
	* Rebalancing algorithm will split total data set on every node into multiple
	* batches prior to sending data.
	*/
	public int getRebalanceBatchSize() {
	return rebalanceBatchSize;
	}

	/**
	* @param rebalanceBatchSize Rebalance batch size.
	* @return {@code this} for chaining.
	*/
	public ClientCacheConfiguration setRebalanceBatchSize(int rebalanceBatchSize) {
	this.rebalanceBatchSize = rebalanceBatchSize;

	return this;
	}

	/**
	* 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.
	*
	* @return Number of batches generated by supply node at rebalancing start.
	* Minimum is 1.
	*/
	public long getRebalanceBatchesPrefetchCount() {
	return rebalanceBatchesPrefetchCnt;
	}

	/**
	* @param rebalanceBatchesPrefetchCnt Rebalance batches prefetch count.
	* @return {@code this} for chaining.
	*/
	public ClientCacheConfiguration setRebalanceBatchesPrefetchCount(long rebalanceBatchesPrefetchCnt) {
	this.rebalanceBatchesPrefetchCnt = rebalanceBatchesPrefetchCnt;

	return this;
	}

	/**
	* @return Delay in milliseconds upon a node joining or leaving topology (or crash) after which rebalancing
	* should be started automatically. Rebalancing should be delayed if you plan to restart nodes
	* after they leave topology, or if you plan to start multiple nodes at once or one after another
	* and don't want to repartition and rebalance until all nodes are started.
	* <p>
	* Default value is {@code 0} which means that repartitioning and rebalancing will start
	* immediately upon node leaving topology. If {@code -1} is returned, then rebalancing
	* will only be started manually.
	* </p>
	*/
	public long getRebalanceDelay() {
	return rebalanceDelay;
	}

	/**
	* @param rebalanceDelay Rebalance delay.
	* @return {@code this} for chaining.
	*/
	public ClientCacheConfiguration setRebalanceDelay(long rebalanceDelay) {
	this.rebalanceDelay = rebalanceDelay;

	return this;
	}

	/**
	* Gets rebalance mode.
	* @return {@code this} for chaining.
	*/
	public CacheRebalanceMode getRebalanceMode() {
	return rebalanceMode;
	}

	/**
	* @param rebalanceMode Rebalance mode.
	* @return {@code this} for chaining.
	*/
	public ClientCacheConfiguration setRebalanceMode(CacheRebalanceMode rebalanceMode) {
	this.rebalanceMode = rebalanceMode;

	return this;
	}

	/**
	* @return Cache rebalance order. Rebalance order can be set to non-zero value for caches with
	* {@link CacheRebalanceMode#SYNC SYNC} or {@link CacheRebalanceMode#ASYNC ASYNC} rebalance modes only.
	* <p/>
	* If cache rebalance order is positive, rebalancing for this cache will be started only when rebalancing for
	* all caches with smaller rebalance order will be completed.
	* <p/>
	* Note that cache with order {@code 0} does not participate in ordering. This means that cache with
	* rebalance order {@code 0} will never wait for any other caches. All caches with order {@code 0} will
	* be rebalanced right away concurrently with each other and ordered rebalance processes.
	* <p/>
	* If not set, cache order is 0, i.e. rebalancing is not ordered.
	*/
	public int getRebalanceOrder() {
	return rebalanceOrder;
	}

	/**
	* @param rebalanceOrder Rebalance order.
	* @return {@code this} for chaining.
	*/
	public ClientCacheConfiguration setRebalanceOrder(int rebalanceOrder) {
	this.rebalanceOrder = rebalanceOrder;

	return this;
	}

	/**
	* @return 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.
	* <p>
	* Default value of {@code 0} means that throttling is disabled.
	* </p>
	*/
	public long getRebalanceThrottle() {
	return rebalanceThrottle;
	}

	/**
	* @param newVal Rebalance throttle.
	* @return {@code this} for chaining.
	*/
	public ClientCacheConfiguration setRebalanceThrottle(long newVal) {
	rebalanceThrottle = newVal;

	return this;
	}

	/**
	* @return Rebalance timeout (ms).
	*/
	public long getRebalanceTimeout() {
	return rebalanceTimeout;
	}

	/**
	* @param newVal Rebalance timeout.
	* @return {@code this} for chaining.
	*/
	public ClientCacheConfiguration setRebalanceTimeout(long newVal) {
	rebalanceTimeout = newVal;

	return this;
	}

	/**
	* @return Write synchronization mode. This mode controls whether the main caller should wait for update on other
	* nodes to complete or not.
	*/
	public CacheWriteSynchronizationMode getWriteSynchronizationMode() {
	return writeSynchronizationMode;
	}

	/**
	* @param newVal Write synchronization mode.
	* @return {@code this} for chaining.
	*/
	public ClientCacheConfiguration setWriteSynchronizationMode(CacheWriteSynchronizationMode newVal) {
	writeSynchronizationMode = newVal;

	return this;
	}

	/**
	* @return Copy on read.
	*/
	public boolean isCopyOnRead() {
	return cpOnRead;
	}

	/**
	* @param newVal Copy on read.
	* @return {@code this} for chaining.
	*/
	public ClientCacheConfiguration setCopyOnRead(boolean newVal) {
	cpOnRead = newVal;

	return this;
	}

	/**
	* @return Max concurrent async operations.
	*/
	public int getMaxConcurrentAsyncOperations() {
	return maxConcurrentAsyncOperations;
	}

	/**
	* @param newVal Max concurrent async operations.
	* @return {@code this} for chaining.
	*/
	public ClientCacheConfiguration setMaxConcurrentAsyncOperations(int newVal) {
	maxConcurrentAsyncOperations = newVal;

	return this;
	}

	/**
	* @return Data region name.
	*/
	public String getDataRegionName() {
	return dataRegionName;
	}

	/**
	* @param newVal Data region name.
	* @return {@code this} for chaining.
	*/
	public ClientCacheConfiguration setDataRegionName(String newVal) {
	dataRegionName = newVal;

	return this;
	}

	/**
	* @return Statistics enabled.
	*/
	public boolean isStatisticsEnabled() {
	return statisticsEnabled;
	}

	/**
	* @param newVal Statistics enabled.
	* @return {@code this} for chaining.
	*/
	public ClientCacheConfiguration setStatisticsEnabled(boolean newVal) {
	statisticsEnabled = newVal;

	return this;
	}

	/**
	* @return Max query iterators count.
	*/
	public int getMaxQueryIteratorsCount() {
	return maxQryIteratorsCnt;
	}

	/**
	* @param newVal Max query iterators count.
	* @return {@code this} for chaining.
	*/
	public ClientCacheConfiguration setMaxQueryIteratorsCount(int newVal) {
	maxQryIteratorsCnt = newVal;

	return this;
	}

	/**
	* @return Onheap cache enabled.
	*/
	public boolean isOnheapCacheEnabled() {
	return onheapCacheEnabled;
	}

	/**
	* @param newVal Onheap cache enabled.
	* @return {@code this} for chaining.
	*/
	public ClientCacheConfiguration setOnheapCacheEnabled(boolean newVal) {
	onheapCacheEnabled = newVal;

	return this;
	}

	/**
	* @return Query detail metrics size.
	*/
	public int getQueryDetailMetricsSize() {
	return qryDetailMetricsSize;
	}

	/**
	* @param newVal Query detail metrics size.
	* @return {@code this} for chaining.
	*/
	public ClientCacheConfiguration setQueryDetailMetricsSize(int newVal) {
	qryDetailMetricsSize = newVal;

	return this;
	}

	/**
	* @return Query parallelism.
	*/
	public int getQueryParallelism() {
	return qryParallelism;
	}

	/**
	* @param newVal Query parallelism.
	* @return {@code this} for chaining.
	*/
	public ClientCacheConfiguration setQueryParallelism(int newVal) {
	qryParallelism = newVal;

	return this;
	}

	/**
	* @return Sql escape all.
	*/
	public boolean isSqlEscapeAll() {
	return sqlEscapeAll;
	}

	/**
	* @param newVal Sql escape all.
	* @return {@code this} for chaining.
	*/
	public ClientCacheConfiguration setSqlEscapeAll(boolean newVal) {
	sqlEscapeAll = newVal;

	return this;
	}

	/**
	* @return Sql index max inline size.
	*/
	public int getSqlIndexMaxInlineSize() {
	return sqlIdxMaxInlineSize;
	}

	/**
	* @param newVal Sql index max inline size.
	* @return {@code this} for chaining.
	*/
	public ClientCacheConfiguration setSqlIndexMaxInlineSize(int newVal) {
	sqlIdxMaxInlineSize = newVal;

	return this;
	}

	/**
	* @return Sql schema.
	*/
	public String getSqlSchema() {
	return sqlSchema;
	}

	/**
	* @param newVal Sql schema.
	* @return {@code this} for chaining.
	*/
	public ClientCacheConfiguration setSqlSchema(String newVal) {
	sqlSchema = newVal;

	return this;
	}

	/**
	* @return Cache key configuration.
	*/
	public CacheKeyConfiguration[] getKeyConfiguration() {
	return keyCfg;
	}

	/**
	* @param newVal Cache key configuration.
	* @return {@code this} for chaining.
	*/
	public ClientCacheConfiguration setKeyConfiguration(CacheKeyConfiguration... newVal) {
	this.keyCfg = newVal;

	return this;
	}

	/**
	* @return Query entities configurations.
	*/
	public QueryEntity[] getQueryEntities() {
	return qryEntities;
	}

	/**
	* @param newVal Query entities configurations.
	* @return {@code this} for chaining.
	*/
	public ClientCacheConfiguration setQueryEntities(QueryEntity... newVal) {
	qryEntities = newVal;

	return this;
	}

	/**
	* @return Expire policy.
	*/
	public ExpiryPolicy getExpiryPolicy() {
	return expiryPlc;
	}

	/**
	* @param expiryPlc Expiry policy.
	* @return {@code this} for chaining.
	*/
	public ClientCacheConfiguration setExpiryPolicy(ExpiryPolicy expiryPlc) {
	this.expiryPlc = expiryPlc;

	return this;
	}

	/** {@inheritDoc} */
	@Override public String toString() {
	return S.toString(ClientCacheConfiguration.class, this);
	}
	}