http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/IgnitePortables.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/IgnitePortables.java b/modules/core/src/main/java/org/apache/ignite/IgnitePortables.java index 6800edc..ee0a4ec 100644 --- a/modules/core/src/main/java/org/apache/ignite/IgnitePortables.java +++ b/modules/core/src/main/java/org/apache/ignite/IgnitePortables.java @@ -17,15 +17,24 @@ package org.apache.ignite; -import org.apache.ignite.internal.processors.cache.*; -import org.apache.ignite.portable.*; -import org.apache.ignite.marshaller.portable.*; - -import org.jetbrains.annotations.*; - -import java.sql.*; -import java.util.*; +import java.sql.Timestamp; +import java.util.ArrayList; +import java.util.Collection; import java.util.Date; +import java.util.HashMap; +import java.util.LinkedList; +import java.util.TreeMap; +import java.util.UUID; +import org.apache.ignite.marshaller.portable.PortableMarshaller; +import org.apache.ignite.portable.PortableBuilder; +import org.apache.ignite.portable.PortableException; +import org.apache.ignite.portable.PortableIdMapper; +import org.apache.ignite.portable.PortableMarshalAware; +import org.apache.ignite.portable.PortableMetadata; +import org.apache.ignite.portable.PortableObject; +import org.apache.ignite.portable.PortableSerializer; +import org.apache.ignite.portable.PortableTypeConfiguration; +import org.jetbrains.annotations.Nullable; /** * Defines portable objects functionality. With portable objects you are able to: @@ -359,4 +368,3 @@ public interface IgnitePortables { */ public Collection<PortableMetadata> metadata() throws PortableException; } -
http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/IgniteQueue.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/IgniteQueue.java b/modules/core/src/main/java/org/apache/ignite/IgniteQueue.java index 3c32ed9..370916b 100644 --- a/modules/core/src/main/java/org/apache/ignite/IgniteQueue.java +++ b/modules/core/src/main/java/org/apache/ignite/IgniteQueue.java @@ -17,9 +17,11 @@ package org.apache.ignite; -import java.io.*; -import java.util.*; -import java.util.concurrent.*; +import java.io.Closeable; +import java.util.Collection; +import java.util.Iterator; +import java.util.concurrent.BlockingQueue; +import java.util.concurrent.TimeUnit; /** * This interface provides a rich API for working with distributed queues based on In-Memory Data Grid. @@ -179,4 +181,4 @@ public interface IgniteQueue<T> extends BlockingQueue<T>, Closeable { * @return {@code true} if queue was removed from cache {@code false} otherwise. */ public boolean removed(); -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/IgniteScheduler.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/IgniteScheduler.java b/modules/core/src/main/java/org/apache/ignite/IgniteScheduler.java index 0cd0a0b..b0ea960 100644 --- a/modules/core/src/main/java/org/apache/ignite/IgniteScheduler.java +++ b/modules/core/src/main/java/org/apache/ignite/IgniteScheduler.java @@ -17,11 +17,12 @@ package org.apache.ignite; -import org.apache.ignite.lang.*; -import org.apache.ignite.scheduler.*; -import org.jetbrains.annotations.*; - -import java.util.concurrent.*; +import java.util.concurrent.Callable; +import org.apache.ignite.lang.IgniteFuture; +import org.apache.ignite.lang.IgniteOutClosure; +import org.apache.ignite.lang.IgniteRunnable; +import org.apache.ignite.scheduler.SchedulerFuture; +import org.jetbrains.annotations.Nullable; /** * Provides functionality for scheduling jobs locally using UNIX cron-based syntax. @@ -95,4 +96,4 @@ public interface IgniteScheduler { * @return Scheduled execution future. */ public <R> SchedulerFuture<R> scheduleLocal(Callable<R> c, String ptrn); -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/IgniteServices.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/IgniteServices.java b/modules/core/src/main/java/org/apache/ignite/IgniteServices.java index 7d1ca7c..08577c5 100644 --- a/modules/core/src/main/java/org/apache/ignite/IgniteServices.java +++ b/modules/core/src/main/java/org/apache/ignite/IgniteServices.java @@ -17,14 +17,16 @@ package org.apache.ignite; -import org.apache.ignite.cluster.*; -import org.apache.ignite.configuration.*; -import org.apache.ignite.lang.*; -import org.apache.ignite.resources.*; -import org.apache.ignite.services.*; -import org.jetbrains.annotations.*; - -import java.util.*; +import java.util.Collection; +import org.apache.ignite.cluster.ClusterGroup; +import org.apache.ignite.configuration.IgniteConfiguration; +import org.apache.ignite.lang.IgniteAsyncSupport; +import org.apache.ignite.lang.IgniteAsyncSupported; +import org.apache.ignite.resources.IgniteInstanceResource; +import org.apache.ignite.services.Service; +import org.apache.ignite.services.ServiceConfiguration; +import org.apache.ignite.services.ServiceDescriptor; +import org.jetbrains.annotations.Nullable; /** * Defines functionality necessary to deploy distributed services on the grid. @@ -350,4 +352,4 @@ public interface IgniteServices extends IgniteAsyncSupport { /** {@inheritDoc} */ @Override public IgniteServices withAsync(); -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/IgniteSet.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/IgniteSet.java b/modules/core/src/main/java/org/apache/ignite/IgniteSet.java index 6063fe0..649a370 100644 --- a/modules/core/src/main/java/org/apache/ignite/IgniteSet.java +++ b/modules/core/src/main/java/org/apache/ignite/IgniteSet.java @@ -17,8 +17,10 @@ package org.apache.ignite; -import java.io.*; -import java.util.*; +import java.io.Closeable; +import java.util.Collection; +import java.util.Iterator; +import java.util.Set; /** * Set implementation based on on In-Memory Data Grid. @@ -101,4 +103,4 @@ public interface IgniteSet<T> extends Set<T>, Closeable { * @return {@code True} if set was removed from cache {@code false} otherwise. */ public boolean removed(); -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/IgniteState.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/IgniteState.java b/modules/core/src/main/java/org/apache/ignite/IgniteState.java index 1b8b193..e3c04c9 100644 --- a/modules/core/src/main/java/org/apache/ignite/IgniteState.java +++ b/modules/core/src/main/java/org/apache/ignite/IgniteState.java @@ -17,8 +17,8 @@ package org.apache.ignite; -import org.apache.ignite.plugin.segmentation.*; -import org.jetbrains.annotations.*; +import org.apache.ignite.plugin.segmentation.SegmentationPolicy; +import org.jetbrains.annotations.Nullable; /** * Possible states of {@link org.apache.ignite.Ignition}. You can register a listener for @@ -57,4 +57,4 @@ public enum IgniteState { @Nullable public static IgniteState fromOrdinal(byte ord) { return ord >= 0 && ord < VALS.length ? VALS[ord] : null; } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/IgniteSystemProperties.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/IgniteSystemProperties.java b/modules/core/src/main/java/org/apache/ignite/IgniteSystemProperties.java index 7c808df..546a33d 100644 --- a/modules/core/src/main/java/org/apache/ignite/IgniteSystemProperties.java +++ b/modules/core/src/main/java/org/apache/ignite/IgniteSystemProperties.java @@ -17,11 +17,10 @@ package org.apache.ignite; -import org.jetbrains.annotations.*; - -import javax.net.ssl.*; -import java.lang.management.*; -import java.util.*; +import java.lang.management.RuntimeMXBean; +import java.util.Properties; +import javax.net.ssl.HostnameVerifier; +import org.jetbrains.annotations.Nullable; /** * Contains constants for all system properties and environmental variables in Ignite. @@ -518,4 +517,4 @@ public final class IgniteSystemProperties { public static Properties snapshot() { return (Properties)System.getProperties().clone(); } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/IgniteTransactions.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/IgniteTransactions.java b/modules/core/src/main/java/org/apache/ignite/IgniteTransactions.java index 29696c1..bb88d4a 100644 --- a/modules/core/src/main/java/org/apache/ignite/IgniteTransactions.java +++ b/modules/core/src/main/java/org/apache/ignite/IgniteTransactions.java @@ -17,9 +17,13 @@ package org.apache.ignite; -import org.apache.ignite.cache.*; -import org.apache.ignite.configuration.*; -import org.apache.ignite.transactions.*; +import org.apache.ignite.cache.CacheAtomicityMode; +import org.apache.ignite.cache.CacheMode; +import org.apache.ignite.configuration.CacheConfiguration; +import org.apache.ignite.transactions.Transaction; +import org.apache.ignite.transactions.TransactionConcurrency; +import org.apache.ignite.transactions.TransactionIsolation; +import org.apache.ignite.transactions.TransactionMetrics; /** * Transactions facade provides ACID-compliant semantic when working with caches. You can @@ -103,4 +107,4 @@ public interface IgniteTransactions { * Resets transaction metrics. */ public void resetMetrics(); -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/Ignition.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/Ignition.java b/modules/core/src/main/java/org/apache/ignite/Ignition.java index d5d59a5..2c06881 100644 --- a/modules/core/src/main/java/org/apache/ignite/Ignition.java +++ b/modules/core/src/main/java/org/apache/ignite/Ignition.java @@ -17,16 +17,16 @@ package org.apache.ignite; -import org.apache.ignite.configuration.*; -import org.apache.ignite.internal.*; -import org.apache.ignite.internal.util.typedef.internal.*; -import org.apache.ignite.spi.discovery.*; -import org.apache.ignite.spi.discovery.tcp.*; -import org.jetbrains.annotations.*; - -import java.io.*; -import java.net.*; -import java.util.*; +import java.io.InputStream; +import java.net.URL; +import java.util.List; +import java.util.UUID; +import org.apache.ignite.configuration.IgniteConfiguration; +import org.apache.ignite.internal.IgnitionEx; +import org.apache.ignite.internal.util.typedef.internal.U; +import org.apache.ignite.spi.discovery.DiscoverySpi; +import org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi; +import org.jetbrains.annotations.Nullable; /** * This class defines a factory for the main Ignite API. It controls Grid life cycle @@ -540,4 +540,4 @@ public class Ignition { public static boolean removeListener(IgnitionListener lsnr) { return IgnitionEx.removeListener(lsnr); } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/IgnitionListener.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/IgnitionListener.java b/modules/core/src/main/java/org/apache/ignite/IgnitionListener.java index 09281cc..0a709fb 100644 --- a/modules/core/src/main/java/org/apache/ignite/IgnitionListener.java +++ b/modules/core/src/main/java/org/apache/ignite/IgnitionListener.java @@ -17,9 +17,8 @@ package org.apache.ignite; -import org.jetbrains.annotations.*; - -import java.util.*; +import java.util.EventListener; +import org.jetbrains.annotations.Nullable; /** * Listener for gird state change notifications. Use @@ -34,4 +33,4 @@ public interface IgnitionListener extends EventListener { * @param state New state. */ public void onStateChange(@Nullable String name, IgniteState state); -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/cache/CacheAtomicUpdateTimeoutException.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/CacheAtomicUpdateTimeoutException.java b/modules/core/src/main/java/org/apache/ignite/cache/CacheAtomicUpdateTimeoutException.java index 0ae9d76..a192bda 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/CacheAtomicUpdateTimeoutException.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/CacheAtomicUpdateTimeoutException.java @@ -17,7 +17,7 @@ package org.apache.ignite.cache; -import javax.cache.*; +import javax.cache.CacheException; /** * Exception thrown when atomic operation timeout occurs. @@ -44,4 +44,4 @@ public class CacheAtomicUpdateTimeoutException extends CacheException { public CacheAtomicUpdateTimeoutException(String msg, Throwable cause) { super(msg, cause); } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/cache/CacheAtomicWriteOrderMode.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/CacheAtomicWriteOrderMode.java b/modules/core/src/main/java/org/apache/ignite/cache/CacheAtomicWriteOrderMode.java index 0771ae9..38b4556 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/CacheAtomicWriteOrderMode.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/CacheAtomicWriteOrderMode.java @@ -17,7 +17,7 @@ package org.apache.ignite.cache; -import org.jetbrains.annotations.*; +import org.jetbrains.annotations.Nullable; /** * Cache write ordering mode. This enumeration is taken into account only in {@link CacheAtomicityMode#ATOMIC} @@ -61,4 +61,4 @@ public enum CacheAtomicWriteOrderMode { @Nullable public static CacheAtomicWriteOrderMode fromOrdinal(byte ord) { return ord >= 0 && ord < VALS.length ? VALS[ord] : null; } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/cache/CacheAtomicityMode.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/CacheAtomicityMode.java b/modules/core/src/main/java/org/apache/ignite/cache/CacheAtomicityMode.java index 5b3cfd4..9e0f81e 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/CacheAtomicityMode.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/CacheAtomicityMode.java @@ -17,8 +17,8 @@ package org.apache.ignite.cache; -import org.apache.ignite.transactions.*; -import org.jetbrains.annotations.*; +import org.apache.ignite.transactions.Transaction; +import org.jetbrains.annotations.Nullable; /** * Cache atomicity mode controls whether cache should maintain fully transactional semantics @@ -76,4 +76,4 @@ public enum CacheAtomicityMode { @Nullable public static CacheAtomicityMode fromOrdinal(int ord) { return ord >= 0 && ord < VALS.length ? VALS[ord] : null; } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/cache/CacheEntry.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/CacheEntry.java b/modules/core/src/main/java/org/apache/ignite/cache/CacheEntry.java index a6a2aa3..d92f9fb 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/CacheEntry.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/CacheEntry.java @@ -17,11 +17,10 @@ package org.apache.ignite.cache; -import org.apache.ignite.*; - -import javax.cache.*; -import javax.cache.processor.*; -import java.util.*; +import java.util.Set; +import javax.cache.Cache; +import javax.cache.processor.EntryProcessor; +import org.apache.ignite.IgniteCache; /** * Cache entry that extends {@link javax.cache.Cache.Entry} by providing additional entry related information. @@ -91,4 +90,4 @@ public interface CacheEntry<K, V> extends Cache.Entry<K, V> { * @return Time in milliseconds. */ public long updateTime(); -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/cache/CacheEntryEventSerializableFilter.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/CacheEntryEventSerializableFilter.java b/modules/core/src/main/java/org/apache/ignite/cache/CacheEntryEventSerializableFilter.java index f7c6bfb..e37eb9a 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/CacheEntryEventSerializableFilter.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/CacheEntryEventSerializableFilter.java @@ -17,12 +17,12 @@ package org.apache.ignite.cache; -import javax.cache.event.*; -import java.io.*; +import java.io.Serializable; +import javax.cache.event.CacheEntryEventFilter; /** * This filter adds {@link Serializable} interface to {@link javax.cache.event.CacheEntryEventFilter} object. */ public interface CacheEntryEventSerializableFilter<K, V> extends CacheEntryEventFilter<K, V>, Serializable { // No-op. -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/cache/CacheEntryProcessor.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/CacheEntryProcessor.java b/modules/core/src/main/java/org/apache/ignite/cache/CacheEntryProcessor.java index 5969586..3057165 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/CacheEntryProcessor.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/CacheEntryProcessor.java @@ -17,12 +17,12 @@ package org.apache.ignite.cache; -import javax.cache.processor.*; -import java.io.*; +import java.io.Serializable; +import javax.cache.processor.EntryProcessor; /** * This processor adds {@link Serializable} interface to {@link EntryProcessor} object. */ public interface CacheEntryProcessor<K, V, T> extends EntryProcessor<K, V, T>, Serializable { // No-op. -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/cache/CacheExistsException.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/CacheExistsException.java b/modules/core/src/main/java/org/apache/ignite/cache/CacheExistsException.java index 113f329..6c60a3c 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/CacheExistsException.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/CacheExistsException.java @@ -17,9 +17,8 @@ package org.apache.ignite.cache; -import org.jetbrains.annotations.*; - -import javax.cache.*; +import javax.cache.CacheException; +import org.jetbrains.annotations.Nullable; /** * Exception thrown when cache must be created but it already exists. @@ -49,4 +48,4 @@ public class CacheExistsException extends CacheException { public CacheExistsException(String msg, @Nullable Throwable cause) { super(msg, cause); } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/cache/CacheInterceptor.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/CacheInterceptor.java b/modules/core/src/main/java/org/apache/ignite/cache/CacheInterceptor.java index 5fc628d..436db6b 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/CacheInterceptor.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/CacheInterceptor.java @@ -17,13 +17,12 @@ package org.apache.ignite.cache; -import org.apache.ignite.*; -import org.apache.ignite.configuration.*; -import org.apache.ignite.lang.*; -import org.jetbrains.annotations.*; - -import javax.cache.*; -import java.io.*; +import java.io.Serializable; +import javax.cache.Cache; +import org.apache.ignite.IgniteCache; +import org.apache.ignite.configuration.CacheConfiguration; +import org.apache.ignite.lang.IgniteBiTuple; +import org.jetbrains.annotations.Nullable; /** * Cache interceptor. Cache interceptor can be used for getting callbacks before @@ -121,4 +120,4 @@ public interface CacheInterceptor<K, V> extends Serializable { * entry is a copy. */ public void onAfterRemove(Cache.Entry<K, V> entry); -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/cache/CacheInterceptorAdapter.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/CacheInterceptorAdapter.java b/modules/core/src/main/java/org/apache/ignite/cache/CacheInterceptorAdapter.java index 3419055..00e1cf9 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/CacheInterceptorAdapter.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/CacheInterceptorAdapter.java @@ -17,10 +17,9 @@ package org.apache.ignite.cache; -import org.apache.ignite.lang.*; -import org.jetbrains.annotations.*; - -import javax.cache.*; +import javax.cache.Cache; +import org.apache.ignite.lang.IgniteBiTuple; +import org.jetbrains.annotations.Nullable; /** * Cache interceptor convenience adapter. It provides no-op implementations for all @@ -54,4 +53,4 @@ public class CacheInterceptorAdapter<K, V> implements CacheInterceptor<K, V> { @Override public void onAfterRemove(Cache.Entry<K, V> entry) { // No-op. } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/cache/CacheManager.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/CacheManager.java b/modules/core/src/main/java/org/apache/ignite/cache/CacheManager.java index bc6df76..12254bf 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/CacheManager.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/CacheManager.java @@ -17,25 +17,40 @@ package org.apache.ignite.cache; -import org.apache.ignite.*; -import org.apache.ignite.configuration.*; -import org.apache.ignite.internal.*; -import org.apache.ignite.internal.mxbean.*; -import org.apache.ignite.internal.processors.cache.*; -import org.apache.ignite.internal.util.typedef.internal.*; -import org.apache.ignite.spi.discovery.tcp.*; -import org.apache.ignite.spi.discovery.tcp.ipfinder.vm.*; -import org.jetbrains.annotations.*; - -import javax.cache.*; -import javax.cache.configuration.*; -import javax.cache.management.*; -import javax.management.*; -import java.net.*; -import java.util.*; -import java.util.concurrent.atomic.*; - -import static org.apache.ignite.IgniteSystemProperties.*; +import java.net.MalformedURLException; +import java.net.URI; +import java.util.ArrayList; +import java.util.Collection; +import java.util.Collections; +import java.util.Properties; +import java.util.Set; +import java.util.concurrent.atomic.AtomicInteger; +import javax.cache.Cache; +import javax.cache.CacheException; +import javax.cache.configuration.CompleteConfiguration; +import javax.cache.configuration.Configuration; +import javax.cache.management.CacheMXBean; +import javax.cache.management.CacheStatisticsMXBean; +import javax.management.MBeanServer; +import javax.management.MalformedObjectNameException; +import javax.management.ObjectName; +import org.apache.ignite.IgniteCache; +import org.apache.ignite.IgniteCheckedException; +import org.apache.ignite.configuration.CacheConfiguration; +import org.apache.ignite.configuration.IgniteConfiguration; +import org.apache.ignite.internal.GridKernalGateway; +import org.apache.ignite.internal.GridKernalState; +import org.apache.ignite.internal.IgniteKernal; +import org.apache.ignite.internal.IgnitionEx; +import org.apache.ignite.internal.mxbean.IgniteStandardMXBean; +import org.apache.ignite.internal.processors.cache.IgniteCacheProxy; +import org.apache.ignite.internal.util.typedef.internal.CU; +import org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi; +import org.apache.ignite.spi.discovery.tcp.ipfinder.vm.TcpDiscoveryVmIpFinder; +import org.jetbrains.annotations.Nullable; + +import static org.apache.ignite.IgniteSystemProperties.IGNITE_JCACHE_DEFAULT_ISOLATED; +import static org.apache.ignite.IgniteSystemProperties.getBoolean; /** * Implementation of JSR-107 {@link CacheManager}. @@ -423,4 +438,4 @@ public class CacheManager implements javax.cache.CacheManager { throw new IllegalArgumentException(); } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/cache/CacheMemoryMode.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/CacheMemoryMode.java b/modules/core/src/main/java/org/apache/ignite/cache/CacheMemoryMode.java index 7a67fa5..a596824 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/CacheMemoryMode.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/CacheMemoryMode.java @@ -17,7 +17,7 @@ package org.apache.ignite.cache; -import org.apache.ignite.cache.eviction.*; +import org.apache.ignite.cache.eviction.EvictionPolicy; /** * Defines set of memory modes. Memory modes help control whether cache entries are @@ -58,4 +58,4 @@ public enum CacheMemoryMode { * to configured {@link EvictionPolicy}. */ OFFHEAP_VALUES, -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/cache/CacheMetrics.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/CacheMetrics.java b/modules/core/src/main/java/org/apache/ignite/cache/CacheMetrics.java index 799aace..669c427 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/CacheMetrics.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/CacheMetrics.java @@ -17,10 +17,10 @@ package org.apache.ignite.cache; -import org.apache.ignite.*; - -import javax.cache.*; -import javax.cache.integration.*; +import javax.cache.Cache; +import javax.cache.integration.CacheLoader; +import javax.cache.integration.CacheWriter; +import org.apache.ignite.IgniteCache; /** * Cache metrics used to obtain statistics on cache itself. @@ -591,4 +591,4 @@ public interface CacheMetrics { * @see CacheWriter */ public boolean isWriteThrough(); -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/cache/CacheMode.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/CacheMode.java b/modules/core/src/main/java/org/apache/ignite/cache/CacheMode.java index 56d31fb..e75fa0c 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/CacheMode.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/CacheMode.java @@ -17,9 +17,9 @@ package org.apache.ignite.cache; -import org.apache.ignite.cache.affinity.*; -import org.apache.ignite.configuration.*; -import org.jetbrains.annotations.*; +import org.apache.ignite.cache.affinity.AffinityFunction; +import org.apache.ignite.configuration.NearCacheConfiguration; +import org.jetbrains.annotations.Nullable; /** * Enumeration of all supported caching modes. Cache mode is specified in {@link org.apache.ignite.configuration.CacheConfiguration} @@ -72,4 +72,4 @@ public enum CacheMode { @Nullable public static CacheMode fromOrdinal(int ord) { return ord >= 0 && ord < VALS.length ? VALS[ord] : null; } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/cache/CachePartialUpdateException.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/CachePartialUpdateException.java b/modules/core/src/main/java/org/apache/ignite/cache/CachePartialUpdateException.java index 50b26a8..f306fb5 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/CachePartialUpdateException.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/CachePartialUpdateException.java @@ -17,10 +17,9 @@ package org.apache.ignite.cache; -import org.apache.ignite.internal.processors.cache.*; - -import javax.cache.*; -import java.util.*; +import java.util.Collection; +import javax.cache.CacheException; +import org.apache.ignite.internal.processors.cache.CachePartialUpdateCheckedException; /** * Exception thrown from non-transactional cache in case when update succeeded only partially. @@ -44,4 +43,4 @@ public class CachePartialUpdateException extends CacheException { public <K> Collection<K> failedKeys() { return ((CachePartialUpdateCheckedException)getCause()).failedKeys(); } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/cache/CachePeekMode.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/CachePeekMode.java b/modules/core/src/main/java/org/apache/ignite/cache/CachePeekMode.java index ea7037e..495202c 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/CachePeekMode.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/CachePeekMode.java @@ -17,8 +17,8 @@ package org.apache.ignite.cache; -import org.apache.ignite.*; -import org.jetbrains.annotations.*; +import org.apache.ignite.IgniteCache; +import org.jetbrains.annotations.Nullable; /** * Enumeration of all supported cache peek modes. Peek modes can be passed @@ -81,4 +81,4 @@ public enum CachePeekMode { @Nullable public static CachePeekMode fromOrdinal(byte ord) { return ord >= 0 && ord < VALS.length ? VALS[ord] : null; } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/cache/CacheRebalanceMode.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/CacheRebalanceMode.java b/modules/core/src/main/java/org/apache/ignite/cache/CacheRebalanceMode.java index 79d22f9..86692e8 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/CacheRebalanceMode.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/CacheRebalanceMode.java @@ -17,8 +17,8 @@ package org.apache.ignite.cache; -import org.apache.ignite.cache.affinity.*; -import org.jetbrains.annotations.*; +import org.apache.ignite.cache.affinity.AffinityFunction; +import org.jetbrains.annotations.Nullable; /** * Cache rebalance mode. When rebalancing is enabled (i.e. has value other than {@link #NONE}), distributed caches @@ -65,4 +65,4 @@ public enum CacheRebalanceMode { @Nullable public static CacheRebalanceMode fromOrdinal(int ord) { return ord >= 0 && ord < VALS.length ? VALS[ord] : null; } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/cache/CacheServerNotFoundException.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/CacheServerNotFoundException.java b/modules/core/src/main/java/org/apache/ignite/cache/CacheServerNotFoundException.java index f5ccac7..1975070 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/CacheServerNotFoundException.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/CacheServerNotFoundException.java @@ -16,7 +16,7 @@ */ package org.apache.ignite.cache; -import javax.cache.*; +import javax.cache.CacheException; /** * Exception thrown when all data nodes left the grid. @@ -46,4 +46,4 @@ public class CacheServerNotFoundException extends CacheException { public CacheServerNotFoundException(Throwable cause) { super(cause); } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/cache/CacheTypeFieldMetadata.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/CacheTypeFieldMetadata.java b/modules/core/src/main/java/org/apache/ignite/cache/CacheTypeFieldMetadata.java index 7e6af7c..1ec2408 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/CacheTypeFieldMetadata.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/CacheTypeFieldMetadata.java @@ -17,9 +17,8 @@ package org.apache.ignite.cache; -import org.apache.ignite.internal.util.typedef.internal.*; - -import java.io.*; +import java.io.Serializable; +import org.apache.ignite.internal.util.typedef.internal.S; /** * Type field metadata. @@ -147,4 +146,4 @@ public class CacheTypeFieldMetadata implements Serializable { @Override public String toString() { return S.toString(CacheTypeFieldMetadata.class, this); } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/cache/CacheTypeMetadata.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/CacheTypeMetadata.java b/modules/core/src/main/java/org/apache/ignite/cache/CacheTypeMetadata.java index 93ce9dd..95a138d 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/CacheTypeMetadata.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/CacheTypeMetadata.java @@ -17,13 +17,16 @@ package org.apache.ignite.cache; -import org.apache.ignite.cache.store.jdbc.*; -import org.apache.ignite.internal.util.tostring.*; -import org.apache.ignite.internal.util.typedef.internal.*; -import org.apache.ignite.lang.*; - -import java.io.*; -import java.util.*; +import java.io.Serializable; +import java.util.ArrayList; +import java.util.Collection; +import java.util.LinkedHashMap; +import java.util.LinkedHashSet; +import java.util.Map; +import org.apache.ignite.cache.store.jdbc.CacheJdbcPojoStore; +import org.apache.ignite.internal.util.tostring.GridToStringInclude; +import org.apache.ignite.internal.util.typedef.internal.S; +import org.apache.ignite.lang.IgniteBiTuple; /** * Cache type metadata need for configuration of indexes or automatic persistence. @@ -338,4 +341,4 @@ public class CacheTypeMetadata implements Serializable { @Override public String toString() { return S.toString(CacheTypeMetadata.class, this); } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/cache/CacheWriteSynchronizationMode.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/CacheWriteSynchronizationMode.java b/modules/core/src/main/java/org/apache/ignite/cache/CacheWriteSynchronizationMode.java index d44e65e..cdb12c3 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/CacheWriteSynchronizationMode.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/CacheWriteSynchronizationMode.java @@ -17,8 +17,8 @@ package org.apache.ignite.cache; -import org.apache.ignite.transactions.*; -import org.jetbrains.annotations.*; +import org.apache.ignite.transactions.Transaction; +import org.jetbrains.annotations.Nullable; /** * Mode indicating how Ignite should wait for write replies from other nodes. Default @@ -66,4 +66,4 @@ public enum CacheWriteSynchronizationMode { @Nullable public static CacheWriteSynchronizationMode fromOrdinal(int ord) { return ord >= 0 && ord < VALS.length ? VALS[ord] : null; } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/cache/CachingProvider.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/CachingProvider.java b/modules/core/src/main/java/org/apache/ignite/cache/CachingProvider.java index 47d892f..ddd0c04 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/CachingProvider.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/CachingProvider.java @@ -17,16 +17,24 @@ package org.apache.ignite.cache; -import org.apache.ignite.*; -import org.apache.ignite.internal.*; -import org.apache.ignite.internal.util.future.*; -import org.apache.ignite.internal.util.typedef.internal.*; -import org.jetbrains.annotations.*; - -import javax.cache.*; -import javax.cache.configuration.*; -import java.net.*; -import java.util.*; +import java.net.URI; +import java.net.URISyntaxException; +import java.net.URL; +import java.util.ArrayList; +import java.util.Collection; +import java.util.HashMap; +import java.util.Map; +import java.util.Properties; +import java.util.WeakHashMap; +import javax.cache.CacheException; +import javax.cache.configuration.OptionalFeature; +import org.apache.ignite.Ignite; +import org.apache.ignite.IgniteCheckedException; +import org.apache.ignite.internal.IgnitionEx; +import org.apache.ignite.internal.util.future.GridFutureAdapter; +import org.apache.ignite.internal.util.typedef.internal.CU; +import org.apache.ignite.internal.util.typedef.internal.U; +import org.jetbrains.annotations.Nullable; /** * Implementation of JSR-107 {@link javax.cache.spi.CachingProvider}. @@ -280,4 +288,4 @@ public class CachingProvider implements javax.cache.spi.CachingProvider { @Override public boolean isSupported(OptionalFeature optionalFeature) { return false; } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/cache/affinity/Affinity.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/affinity/Affinity.java b/modules/core/src/main/java/org/apache/ignite/cache/affinity/Affinity.java index 5efc58b..28dc0ec 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/affinity/Affinity.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/affinity/Affinity.java @@ -17,10 +17,10 @@ package org.apache.ignite.cache.affinity; -import org.apache.ignite.cluster.*; -import org.jetbrains.annotations.*; - -import java.util.*; +import java.util.Collection; +import java.util.Map; +import org.apache.ignite.cluster.ClusterNode; +import org.jetbrains.annotations.Nullable; /** * Provides affinity information to detect which node is primary and which nodes are @@ -216,4 +216,4 @@ public interface Affinity<K> { * always first. */ public Collection<ClusterNode> mapPartitionToPrimaryAndBackups(int part); -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/cache/affinity/AffinityCentralizedFunction.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/affinity/AffinityCentralizedFunction.java b/modules/core/src/main/java/org/apache/ignite/cache/affinity/AffinityCentralizedFunction.java index 7e76aa8..14f3e57 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/affinity/AffinityCentralizedFunction.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/affinity/AffinityCentralizedFunction.java @@ -17,7 +17,10 @@ package org.apache.ignite.cache.affinity; -import java.lang.annotation.*; +import java.lang.annotation.ElementType; +import java.lang.annotation.Retention; +import java.lang.annotation.RetentionPolicy; +import java.lang.annotation.Target; /** * Annotation marker which identifies affinity function that must be calculated on one centralized node @@ -28,4 +31,4 @@ import java.lang.annotation.*; @Target(ElementType.TYPE) public @interface AffinityCentralizedFunction { -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/cache/affinity/AffinityFunction.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/affinity/AffinityFunction.java b/modules/core/src/main/java/org/apache/ignite/cache/affinity/AffinityFunction.java index 3278502..cd12ab3 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/affinity/AffinityFunction.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/affinity/AffinityFunction.java @@ -17,10 +17,10 @@ package org.apache.ignite.cache.affinity; -import org.apache.ignite.cluster.*; - -import java.io.*; -import java.util.*; +import java.io.Serializable; +import java.util.List; +import java.util.UUID; +import org.apache.ignite.cluster.ClusterNode; /** * Cache key affinity which maps keys to nodes. This interface is utilized for @@ -107,4 +107,4 @@ public interface AffinityFunction extends Serializable { * @param nodeId ID of node to remove. */ public void removeNode(UUID nodeId); -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/cache/affinity/AffinityFunctionContext.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/affinity/AffinityFunctionContext.java b/modules/core/src/main/java/org/apache/ignite/cache/affinity/AffinityFunctionContext.java index 9d22833..fd071cb 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/affinity/AffinityFunctionContext.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/affinity/AffinityFunctionContext.java @@ -17,12 +17,11 @@ package org.apache.ignite.cache.affinity; -import org.apache.ignite.cluster.*; -import org.apache.ignite.events.*; -import org.apache.ignite.internal.processors.affinity.*; -import org.jetbrains.annotations.*; - -import java.util.*; +import java.util.List; +import org.apache.ignite.cluster.ClusterNode; +import org.apache.ignite.events.DiscoveryEvent; +import org.apache.ignite.internal.processors.affinity.AffinityTopologyVersion; +import org.jetbrains.annotations.Nullable; /** * Affinity function context. This context is passed to {@link AffinityFunction} for @@ -69,4 +68,4 @@ public interface AffinityFunctionContext { * not available. */ @Nullable public DiscoveryEvent discoveryEvent(); -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/cache/affinity/AffinityKey.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/affinity/AffinityKey.java b/modules/core/src/main/java/org/apache/ignite/cache/affinity/AffinityKey.java index 4e840f9..ee6321c 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/affinity/AffinityKey.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/affinity/AffinityKey.java @@ -17,11 +17,14 @@ package org.apache.ignite.cache.affinity; -import org.apache.ignite.internal.processors.cache.*; -import org.apache.ignite.internal.util.tostring.*; -import org.apache.ignite.internal.util.typedef.internal.*; - -import java.io.*; +import java.io.Externalizable; +import java.io.IOException; +import java.io.ObjectInput; +import java.io.ObjectOutput; +import org.apache.ignite.internal.processors.cache.GridCacheDefaultAffinityKeyMapper; +import org.apache.ignite.internal.util.tostring.GridToStringInclude; +import org.apache.ignite.internal.util.typedef.internal.A; +import org.apache.ignite.internal.util.typedef.internal.S; /** * Optional wrapper for cache keys to provide support @@ -186,4 +189,4 @@ public class AffinityKey<K> implements Externalizable { @Override public String toString() { return S.toString(AffinityKey.class, this); } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/cache/affinity/AffinityKeyMapped.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/affinity/AffinityKeyMapped.java b/modules/core/src/main/java/org/apache/ignite/cache/affinity/AffinityKeyMapped.java index 4464972..dd42d5c 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/affinity/AffinityKeyMapped.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/affinity/AffinityKeyMapped.java @@ -17,8 +17,12 @@ package org.apache.ignite.cache.affinity; -import java.lang.annotation.*; -import java.util.concurrent.*; +import java.lang.annotation.Documented; +import java.lang.annotation.ElementType; +import java.lang.annotation.Retention; +import java.lang.annotation.RetentionPolicy; +import java.lang.annotation.Target; +import java.util.concurrent.Callable; /** * Optional annotation to specify custom key-to-node affinity. Affinity key is a key @@ -107,4 +111,4 @@ import java.util.concurrent.*; @Target({ElementType.FIELD, ElementType.METHOD}) public @interface AffinityKeyMapped { // No-op. -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/cache/affinity/AffinityKeyMapper.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/affinity/AffinityKeyMapper.java b/modules/core/src/main/java/org/apache/ignite/cache/affinity/AffinityKeyMapper.java index 69835c8..4e2c624 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/affinity/AffinityKeyMapper.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/affinity/AffinityKeyMapper.java @@ -17,7 +17,7 @@ package org.apache.ignite.cache.affinity; -import java.io.*; +import java.io.Serializable; /** * Affinity mapper which maps cache key to an affinity key. Affinity key is a key which will be @@ -59,4 +59,4 @@ public interface AffinityKeyMapper extends Serializable { * has no initialization logic, leave this method empty. */ public void reset(); -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/cache/affinity/AffinityNodeAddressHashResolver.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/affinity/AffinityNodeAddressHashResolver.java b/modules/core/src/main/java/org/apache/ignite/cache/affinity/AffinityNodeAddressHashResolver.java index 533174f..4ff54ff 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/affinity/AffinityNodeAddressHashResolver.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/affinity/AffinityNodeAddressHashResolver.java @@ -17,11 +17,10 @@ package org.apache.ignite.cache.affinity; -import org.apache.ignite.cluster.*; -import org.apache.ignite.configuration.*; -import org.apache.ignite.internal.util.typedef.internal.*; - -import java.io.*; +import java.io.Serializable; +import org.apache.ignite.cluster.ClusterNode; +import org.apache.ignite.configuration.IgniteConfiguration; +import org.apache.ignite.internal.util.typedef.internal.S; /** * Node hash resolver which uses {@link ClusterNode#consistentId()} as alternate hash value. @@ -42,4 +41,4 @@ public class AffinityNodeAddressHashResolver implements AffinityNodeHashResolver @Override public String toString() { return S.toString(AffinityNodeAddressHashResolver.class, this); } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/cache/affinity/AffinityNodeHashResolver.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/affinity/AffinityNodeHashResolver.java b/modules/core/src/main/java/org/apache/ignite/cache/affinity/AffinityNodeHashResolver.java index f990951..c879da6 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/affinity/AffinityNodeHashResolver.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/affinity/AffinityNodeHashResolver.java @@ -17,10 +17,9 @@ package org.apache.ignite.cache.affinity; -import org.apache.ignite.cluster.*; -import org.apache.ignite.configuration.*; - -import java.io.*; +import java.io.Serializable; +import org.apache.ignite.cluster.ClusterNode; +import org.apache.ignite.configuration.IgniteConfiguration; /** * Resolver which is used to provide node hash value for affinity function. @@ -45,4 +44,4 @@ public interface AffinityNodeHashResolver extends Serializable { */ @Deprecated public Object resolve(ClusterNode node); -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/cache/affinity/AffinityNodeIdHashResolver.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/affinity/AffinityNodeIdHashResolver.java b/modules/core/src/main/java/org/apache/ignite/cache/affinity/AffinityNodeIdHashResolver.java index 2580c69..a204a6d 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/affinity/AffinityNodeIdHashResolver.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/affinity/AffinityNodeIdHashResolver.java @@ -17,11 +17,10 @@ package org.apache.ignite.cache.affinity; -import org.apache.ignite.cluster.*; -import org.apache.ignite.configuration.*; -import org.apache.ignite.internal.util.typedef.internal.*; - -import java.io.*; +import java.io.Serializable; +import org.apache.ignite.cluster.ClusterNode; +import org.apache.ignite.configuration.IgniteConfiguration; +import org.apache.ignite.internal.util.typedef.internal.S; /** * Node hash resolver which uses generated node ID as node hash value. As new node ID is generated @@ -43,4 +42,4 @@ public class AffinityNodeIdHashResolver implements AffinityNodeHashResolver { @Override public String toString() { return S.toString(AffinityNodeIdHashResolver.class, this); } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/cache/affinity/AffinityUuid.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/affinity/AffinityUuid.java b/modules/core/src/main/java/org/apache/ignite/cache/affinity/AffinityUuid.java index 79ed803..bbf74f5 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/affinity/AffinityUuid.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/affinity/AffinityUuid.java @@ -17,8 +17,8 @@ package org.apache.ignite.cache.affinity; -import org.apache.ignite.internal.util.typedef.internal.*; -import org.apache.ignite.lang.*; +import org.apache.ignite.internal.util.typedef.internal.S; +import org.apache.ignite.lang.IgniteUuid; /** * Guaranteed unique affinity-based key. @@ -47,4 +47,4 @@ public class AffinityUuid extends AffinityKey<IgniteUuid> { @Override public String toString() { return S.toString(AffinityUuid.class, this); } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/cache/affinity/fair/FairAffinityFunction.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/affinity/fair/FairAffinityFunction.java b/modules/core/src/main/java/org/apache/ignite/cache/affinity/fair/FairAffinityFunction.java index 14a4f53..cc04875 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/affinity/fair/FairAffinityFunction.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/affinity/fair/FairAffinityFunction.java @@ -17,15 +17,29 @@ package org.apache.ignite.cache.affinity.fair; -import org.apache.ignite.cache.affinity.*; -import org.apache.ignite.cluster.*; -import org.apache.ignite.configuration.*; -import org.apache.ignite.events.*; -import org.apache.ignite.internal.util.typedef.*; -import org.apache.ignite.internal.util.typedef.internal.*; - -import java.io.*; -import java.util.*; +import java.io.Serializable; +import java.util.ArrayList; +import java.util.Collection; +import java.util.Collections; +import java.util.Comparator; +import java.util.HashMap; +import java.util.Iterator; +import java.util.LinkedHashMap; +import java.util.LinkedList; +import java.util.List; +import java.util.Map; +import java.util.Queue; +import java.util.RandomAccess; +import java.util.UUID; +import org.apache.ignite.cache.affinity.AffinityCentralizedFunction; +import org.apache.ignite.cache.affinity.AffinityFunction; +import org.apache.ignite.cache.affinity.AffinityFunctionContext; +import org.apache.ignite.cluster.ClusterNode; +import org.apache.ignite.configuration.CacheConfiguration; +import org.apache.ignite.events.DiscoveryEvent; +import org.apache.ignite.events.EventType; +import org.apache.ignite.internal.util.typedef.F; +import org.apache.ignite.internal.util.typedef.internal.U; /** * Fair affinity function which tries to ensure that all nodes get equal number of partitions with @@ -775,4 +789,4 @@ public class FairAffinityFunction implements AffinityFunction { return "PartSet [nodeId=" + node.id() + ", size=" + parts.size() + ", parts=" + parts + ']'; } } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/cache/affinity/rendezvous/RendezvousAffinityFunction.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/affinity/rendezvous/RendezvousAffinityFunction.java b/modules/core/src/main/java/org/apache/ignite/cache/affinity/rendezvous/RendezvousAffinityFunction.java index 6736c4e..fd07eb9 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/affinity/rendezvous/RendezvousAffinityFunction.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/affinity/rendezvous/RendezvousAffinityFunction.java @@ -17,20 +17,39 @@ package org.apache.ignite.cache.affinity.rendezvous; -import org.apache.ignite.*; -import org.apache.ignite.cache.affinity.*; -import org.apache.ignite.cluster.*; -import org.apache.ignite.configuration.*; -import org.apache.ignite.internal.*; -import org.apache.ignite.internal.util.typedef.*; -import org.apache.ignite.internal.util.typedef.internal.*; -import org.apache.ignite.lang.*; -import org.apache.ignite.resources.*; -import org.jetbrains.annotations.*; - -import java.io.*; -import java.security.*; -import java.util.*; +import java.io.ByteArrayOutputStream; +import java.io.Externalizable; +import java.io.IOException; +import java.io.ObjectInput; +import java.io.ObjectOutput; +import java.io.Serializable; +import java.security.MessageDigest; +import java.security.NoSuchAlgorithmException; +import java.util.ArrayList; +import java.util.Collection; +import java.util.Collections; +import java.util.Comparator; +import java.util.HashMap; +import java.util.HashSet; +import java.util.List; +import java.util.Map; +import java.util.UUID; +import org.apache.ignite.Ignite; +import org.apache.ignite.IgniteCheckedException; +import org.apache.ignite.IgniteException; +import org.apache.ignite.cache.affinity.AffinityFunction; +import org.apache.ignite.cache.affinity.AffinityFunctionContext; +import org.apache.ignite.cache.affinity.AffinityNodeHashResolver; +import org.apache.ignite.cluster.ClusterNode; +import org.apache.ignite.configuration.IgniteConfiguration; +import org.apache.ignite.internal.IgniteNodeAttributes; +import org.apache.ignite.internal.util.typedef.F; +import org.apache.ignite.internal.util.typedef.internal.A; +import org.apache.ignite.internal.util.typedef.internal.U; +import org.apache.ignite.lang.IgniteBiPredicate; +import org.apache.ignite.lang.IgniteBiTuple; +import org.apache.ignite.resources.IgniteInstanceResource; +import org.jetbrains.annotations.Nullable; /** * Affinity function for partitioned cache based on Highest Random Weight algorithm. @@ -515,4 +534,4 @@ public class RendezvousAffinityFunction implements AffinityFunction, Externaliza o1.get2().id().compareTo(o2.get2().id()); } } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/cache/eviction/EvictableEntry.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/eviction/EvictableEntry.java b/modules/core/src/main/java/org/apache/ignite/cache/eviction/EvictableEntry.java index 9f1889a..fbe82c3 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/eviction/EvictableEntry.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/eviction/EvictableEntry.java @@ -17,9 +17,8 @@ package org.apache.ignite.cache.eviction; -import org.jetbrains.annotations.*; - -import javax.cache.*; +import javax.cache.Cache; +import org.jetbrains.annotations.Nullable; /** * Evictable cache entry passed into {@link EvictionPolicy}. @@ -100,4 +99,4 @@ public interface EvictableEntry<K, V> extends Cache.Entry<K, V> { * @return {@code True} if value was removed, {@code false} otherwise. */ public <T> boolean removeMeta(T val); -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/cache/eviction/EvictionFilter.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/eviction/EvictionFilter.java b/modules/core/src/main/java/org/apache/ignite/cache/eviction/EvictionFilter.java index 2b6ead1..a9b2d55 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/eviction/EvictionFilter.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/eviction/EvictionFilter.java @@ -17,11 +17,10 @@ package org.apache.ignite.cache.eviction; +import java.io.Serializable; +import javax.cache.Cache; import org.apache.ignite.configuration.CacheConfiguration; -import javax.cache.*; -import java.io.*; - /** * Eviction filter to specify which entries should not be evicted. Not applicable when * calling explicit evict via {@link EvictableEntry#evict()}. @@ -40,4 +39,4 @@ public interface EvictionFilter<K, V> extends Serializable { * @return {@code True} if it is allowed to evict this entry. */ public boolean evictAllowed(Cache.Entry<K, V> entry); -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/cache/eviction/EvictionPolicy.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/eviction/EvictionPolicy.java b/modules/core/src/main/java/org/apache/ignite/cache/eviction/EvictionPolicy.java index 07c269d..a77514a 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/eviction/EvictionPolicy.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/eviction/EvictionPolicy.java @@ -17,10 +17,10 @@ package org.apache.ignite.cache.eviction; -import org.apache.ignite.cache.eviction.fifo.*; -import org.apache.ignite.cache.eviction.lru.*; -import org.apache.ignite.cache.eviction.random.*; -import org.apache.ignite.cache.eviction.sorted.*; +import org.apache.ignite.cache.eviction.fifo.FifoEvictionPolicy; +import org.apache.ignite.cache.eviction.lru.LruEvictionPolicy; +import org.apache.ignite.cache.eviction.random.RandomEvictionPolicy; +import org.apache.ignite.cache.eviction.sorted.SortedEvictionPolicy; /** * Pluggable cache eviction policy. Usually, implementations will internally order @@ -53,4 +53,4 @@ public interface EvictionPolicy<K, V> { * @param entry Accessed entry. */ public void onEntryAccessed(boolean rmv, EvictableEntry<K, V> entry); -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/cache/eviction/fifo/FifoEvictionPolicy.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/eviction/fifo/FifoEvictionPolicy.java b/modules/core/src/main/java/org/apache/ignite/cache/eviction/fifo/FifoEvictionPolicy.java index 1e06ffd..4d1c3f1 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/eviction/fifo/FifoEvictionPolicy.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/eviction/fifo/FifoEvictionPolicy.java @@ -17,16 +17,21 @@ package org.apache.ignite.cache.eviction.fifo; -import org.apache.ignite.cache.eviction.*; -import org.apache.ignite.internal.util.typedef.internal.*; - -import org.jsr166.*; -import org.jsr166.ConcurrentLinkedDeque8.*; - -import java.io.*; -import java.util.*; - -import static org.apache.ignite.configuration.CacheConfiguration.*; +import java.io.Externalizable; +import java.io.IOException; +import java.io.ObjectInput; +import java.io.ObjectOutput; +import java.util.Collection; +import java.util.Collections; +import org.apache.ignite.cache.eviction.EvictableEntry; +import org.apache.ignite.cache.eviction.EvictionPolicy; +import org.apache.ignite.internal.util.typedef.internal.A; +import org.apache.ignite.internal.util.typedef.internal.S; +import org.jsr166.ConcurrentLinkedDeque8; +import org.jsr166.ConcurrentLinkedDeque8.Node; +import org.jsr166.LongAdder8; + +import static org.apache.ignite.configuration.CacheConfiguration.DFLT_CACHE_SIZE; /** * Eviction policy based on {@code First In First Out (FIFO)} algorithm and supports batch eviction. @@ -301,4 +306,4 @@ public class FifoEvictionPolicy<K, V> implements EvictionPolicy<K, V>, FifoEvict @Override public String toString() { return S.toString(FifoEvictionPolicy.class, this); } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/cache/eviction/fifo/FifoEvictionPolicyMBean.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/eviction/fifo/FifoEvictionPolicyMBean.java b/modules/core/src/main/java/org/apache/ignite/cache/eviction/fifo/FifoEvictionPolicyMBean.java index 793aa66..2615bbf 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/eviction/fifo/FifoEvictionPolicyMBean.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/eviction/fifo/FifoEvictionPolicyMBean.java @@ -17,7 +17,7 @@ package org.apache.ignite.cache.eviction.fifo; -import org.apache.ignite.mxbean.*; +import org.apache.ignite.mxbean.MXBeanDescription; /** * MBean for {@code FIFO} eviction policy. @@ -85,4 +85,4 @@ public interface FifoEvictionPolicyMBean { */ @MXBeanDescription("Current FIFO queue size in bytes.") public long getCurrentMemorySize(); -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/cache/eviction/igfs/IgfsEvictionFilter.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/eviction/igfs/IgfsEvictionFilter.java b/modules/core/src/main/java/org/apache/ignite/cache/eviction/igfs/IgfsEvictionFilter.java index 97d1dd1..a6c9f59 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/eviction/igfs/IgfsEvictionFilter.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/eviction/igfs/IgfsEvictionFilter.java @@ -17,10 +17,9 @@ package org.apache.ignite.cache.eviction.igfs; -import org.apache.ignite.cache.eviction.*; -import org.apache.ignite.internal.processors.igfs.*; - -import javax.cache.*; +import javax.cache.Cache; +import org.apache.ignite.cache.eviction.EvictionFilter; +import org.apache.ignite.internal.processors.igfs.IgfsBlockKey; /** * IGFS eviction filter which will not evict blocks of particular files. @@ -35,4 +34,4 @@ public class IgfsEvictionFilter implements EvictionFilter { return !(key instanceof IgfsBlockKey && ((IgfsBlockKey)key).evictExclude()); } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/cache/eviction/igfs/IgfsPerBlockLruEvictionPolicy.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/eviction/igfs/IgfsPerBlockLruEvictionPolicy.java b/modules/core/src/main/java/org/apache/ignite/cache/eviction/igfs/IgfsPerBlockLruEvictionPolicy.java index f4d95df..a82d541 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/eviction/igfs/IgfsPerBlockLruEvictionPolicy.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/eviction/igfs/IgfsPerBlockLruEvictionPolicy.java @@ -17,19 +17,26 @@ package org.apache.ignite.cache.eviction.igfs; -import org.apache.ignite.*; -import org.apache.ignite.cache.eviction.*; -import org.apache.ignite.igfs.*; -import org.apache.ignite.internal.processors.cache.*; -import org.apache.ignite.internal.processors.igfs.*; -import org.jsr166.*; -import org.jsr166.ConcurrentLinkedDeque8.*; -import org.jetbrains.annotations.*; - -import java.io.*; -import java.util.*; -import java.util.concurrent.atomic.*; -import java.util.regex.*; +import java.io.Externalizable; +import java.io.IOException; +import java.io.ObjectInput; +import java.io.ObjectOutput; +import java.util.Collection; +import java.util.Collections; +import java.util.HashSet; +import java.util.concurrent.atomic.AtomicBoolean; +import java.util.regex.Pattern; +import java.util.regex.PatternSyntaxException; +import org.apache.ignite.IgniteCheckedException; +import org.apache.ignite.cache.eviction.EvictableEntry; +import org.apache.ignite.cache.eviction.EvictionPolicy; +import org.apache.ignite.igfs.IgfsPath; +import org.apache.ignite.internal.processors.cache.CacheEvictableEntryImpl; +import org.apache.ignite.internal.processors.igfs.IgfsBlockKey; +import org.jetbrains.annotations.Nullable; +import org.jsr166.ConcurrentLinkedDeque8; +import org.jsr166.ConcurrentLinkedDeque8.Node; +import org.jsr166.LongAdder8; /** * IGFS eviction policy which evicts particular blocks. @@ -374,4 +381,4 @@ public class IgfsPerBlockLruEvictionPolicy implements EvictionPolicy<IgfsBlockKe return size; } } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/cache/eviction/igfs/IgfsPerBlockLruEvictionPolicyMXBean.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/eviction/igfs/IgfsPerBlockLruEvictionPolicyMXBean.java b/modules/core/src/main/java/org/apache/ignite/cache/eviction/igfs/IgfsPerBlockLruEvictionPolicyMXBean.java index 76e1016..c14572a 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/eviction/igfs/IgfsPerBlockLruEvictionPolicyMXBean.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/eviction/igfs/IgfsPerBlockLruEvictionPolicyMXBean.java @@ -17,10 +17,9 @@ package org.apache.ignite.cache.eviction.igfs; -import org.apache.ignite.mxbean.*; -import org.jetbrains.annotations.*; - -import java.util.*; +import java.util.Collection; +import org.apache.ignite.mxbean.MXBeanDescription; +import org.jetbrains.annotations.Nullable; /** * MBean for {@code IGFS per-block LRU} eviction policy. @@ -90,4 +89,4 @@ public interface IgfsPerBlockLruEvictionPolicyMXBean { */ @MXBeanDescription("Current amount of blocks.") public int getCurrentBlocks(); -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/cache/eviction/lru/LruEvictionPolicy.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/eviction/lru/LruEvictionPolicy.java b/modules/core/src/main/java/org/apache/ignite/cache/eviction/lru/LruEvictionPolicy.java index ba6f88a..f321764 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/eviction/lru/LruEvictionPolicy.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/eviction/lru/LruEvictionPolicy.java @@ -17,16 +17,21 @@ package org.apache.ignite.cache.eviction.lru; -import org.apache.ignite.cache.eviction.*; -import org.apache.ignite.internal.util.typedef.internal.*; - -import org.jsr166.*; -import org.jsr166.ConcurrentLinkedDeque8.*; - -import java.io.*; -import java.util.*; - -import static org.apache.ignite.configuration.CacheConfiguration.*; +import java.io.Externalizable; +import java.io.IOException; +import java.io.ObjectInput; +import java.io.ObjectOutput; +import java.util.Collection; +import java.util.Collections; +import org.apache.ignite.cache.eviction.EvictableEntry; +import org.apache.ignite.cache.eviction.EvictionPolicy; +import org.apache.ignite.internal.util.typedef.internal.A; +import org.apache.ignite.internal.util.typedef.internal.S; +import org.jsr166.ConcurrentLinkedDeque8; +import org.jsr166.ConcurrentLinkedDeque8.Node; +import org.jsr166.LongAdder8; + +import static org.apache.ignite.configuration.CacheConfiguration.DFLT_CACHE_SIZE; /** * Eviction policy based on {@code Least Recently Used (LRU)} algorithm and supports batch eviction. @@ -292,4 +297,4 @@ public class LruEvictionPolicy<K, V> implements EvictionPolicy<K, V>, LruEvictio @Override public String toString() { return S.toString(LruEvictionPolicy.class, this, "size", queue.sizex()); } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/cache/eviction/lru/LruEvictionPolicyMBean.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/eviction/lru/LruEvictionPolicyMBean.java b/modules/core/src/main/java/org/apache/ignite/cache/eviction/lru/LruEvictionPolicyMBean.java index e17c057..6a3d060 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/eviction/lru/LruEvictionPolicyMBean.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/eviction/lru/LruEvictionPolicyMBean.java @@ -17,7 +17,7 @@ package org.apache.ignite.cache.eviction.lru; -import org.apache.ignite.mxbean.*; +import org.apache.ignite.mxbean.MXBeanDescription; /** * MBean for {@code LRU} eviction policy. @@ -85,4 +85,4 @@ public interface LruEvictionPolicyMBean { */ @MXBeanDescription("Current queue size in bytes.") public long getCurrentMemorySize(); -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/cache/eviction/random/RandomEvictionPolicy.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/eviction/random/RandomEvictionPolicy.java b/modules/core/src/main/java/org/apache/ignite/cache/eviction/random/RandomEvictionPolicy.java index 00a912f..bf04d92 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/eviction/random/RandomEvictionPolicy.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/eviction/random/RandomEvictionPolicy.java @@ -17,15 +17,19 @@ package org.apache.ignite.cache.eviction.random; -import org.apache.ignite.*; -import org.apache.ignite.cache.*; -import org.apache.ignite.cache.eviction.*; -import org.apache.ignite.internal.util.typedef.internal.*; - -import javax.cache.*; -import java.io.*; - -import static org.apache.ignite.configuration.CacheConfiguration.*; +import java.io.Externalizable; +import java.io.IOException; +import java.io.ObjectInput; +import java.io.ObjectOutput; +import javax.cache.Cache; +import org.apache.ignite.IgniteCache; +import org.apache.ignite.cache.CachePeekMode; +import org.apache.ignite.cache.eviction.EvictableEntry; +import org.apache.ignite.cache.eviction.EvictionPolicy; +import org.apache.ignite.internal.util.typedef.internal.A; +import org.apache.ignite.internal.util.typedef.internal.S; + +import static org.apache.ignite.configuration.CacheConfiguration.DFLT_CACHE_SIZE; /** * Cache eviction policy which will select random cache entry for eviction if cache @@ -113,4 +117,4 @@ public class RandomEvictionPolicy<K, V> implements EvictionPolicy<K, V>, RandomE @Override public String toString() { return S.toString(RandomEvictionPolicy.class, this); } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/cache/eviction/random/RandomEvictionPolicyMBean.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/eviction/random/RandomEvictionPolicyMBean.java b/modules/core/src/main/java/org/apache/ignite/cache/eviction/random/RandomEvictionPolicyMBean.java index ec7fb87..3193483 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/eviction/random/RandomEvictionPolicyMBean.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/eviction/random/RandomEvictionPolicyMBean.java @@ -17,7 +17,7 @@ package org.apache.ignite.cache.eviction.random; -import org.apache.ignite.mxbean.*; +import org.apache.ignite.mxbean.MXBeanDescription; /** * MBean for {@code random} eviction policy. @@ -39,4 +39,4 @@ public interface RandomEvictionPolicyMBean { */ @MXBeanDescription("Sets maximum allowed cache size.") public void setMaxSize(int max); -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/cache/eviction/sorted/SortedEvictionPolicy.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/eviction/sorted/SortedEvictionPolicy.java b/modules/core/src/main/java/org/apache/ignite/cache/eviction/sorted/SortedEvictionPolicy.java index d99b3b0..6189552 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/eviction/sorted/SortedEvictionPolicy.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/eviction/sorted/SortedEvictionPolicy.java @@ -17,19 +17,27 @@ package org.apache.ignite.cache.eviction.sorted; -import org.apache.ignite.cache.eviction.*; -import org.apache.ignite.internal.util.*; -import org.apache.ignite.internal.util.typedef.internal.*; - -import org.jetbrains.annotations.*; -import org.jsr166.*; - -import java.io.*; -import java.util.*; -import java.util.concurrent.atomic.*; - -import static java.lang.Math.*; -import static org.apache.ignite.configuration.CacheConfiguration.*; +import java.io.Externalizable; +import java.io.IOException; +import java.io.ObjectInput; +import java.io.ObjectOutput; +import java.io.Serializable; +import java.util.Collection; +import java.util.Collections; +import java.util.Comparator; +import java.util.LinkedHashSet; +import java.util.Objects; +import java.util.Set; +import java.util.concurrent.atomic.AtomicLong; +import org.apache.ignite.cache.eviction.EvictableEntry; +import org.apache.ignite.cache.eviction.EvictionPolicy; +import org.apache.ignite.internal.util.GridConcurrentSkipListSet; +import org.apache.ignite.internal.util.typedef.internal.A; +import org.jetbrains.annotations.Nullable; +import org.jsr166.LongAdder8; + +import static java.lang.Math.abs; +import static org.apache.ignite.configuration.CacheConfiguration.DFLT_CACHE_SIZE; /** * Cache eviction policy which will select the minimum cache entry for eviction. @@ -508,4 +516,4 @@ public class SortedEvictionPolicy<K, V> implements EvictionPolicy<K, V>, SortedE return e; } } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/cache/eviction/sorted/SortedEvictionPolicyMBean.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/eviction/sorted/SortedEvictionPolicyMBean.java b/modules/core/src/main/java/org/apache/ignite/cache/eviction/sorted/SortedEvictionPolicyMBean.java index 7283453..b0a1823 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/eviction/sorted/SortedEvictionPolicyMBean.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/eviction/sorted/SortedEvictionPolicyMBean.java @@ -17,7 +17,7 @@ package org.apache.ignite.cache.eviction.sorted; -import org.apache.ignite.mxbean.*; +import org.apache.ignite.mxbean.MXBeanDescription; /** * MBean for sorted eviction policy. @@ -85,4 +85,4 @@ public interface SortedEvictionPolicyMBean { */ @MXBeanDescription("Current sorted entries set size in bytes.") public long getCurrentMemorySize(); -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/cache/query/ContinuousQuery.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/query/ContinuousQuery.java b/modules/core/src/main/java/org/apache/ignite/cache/query/ContinuousQuery.java index 8ffb8cb..df1bad3 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/query/ContinuousQuery.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/query/ContinuousQuery.java @@ -17,11 +17,10 @@ package org.apache.ignite.cache.query; -import org.apache.ignite.*; -import org.apache.ignite.cache.*; - -import javax.cache.*; -import javax.cache.event.*; +import javax.cache.Cache; +import javax.cache.event.CacheEntryUpdatedListener; +import org.apache.ignite.IgniteCache; +import org.apache.ignite.cache.CacheEntryEventSerializableFilter; /** * API for configuring continuous cache queries. @@ -281,4 +280,4 @@ public final class ContinuousQuery<K, V> extends Query<Cache.Entry<K, V>> { public boolean isAutoUnsubscribe() { return autoUnsubscribe; } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/cache/query/Query.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/query/Query.java b/modules/core/src/main/java/org/apache/ignite/cache/query/Query.java index ad464c4..71161e7 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/query/Query.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/query/Query.java @@ -17,10 +17,9 @@ package org.apache.ignite.cache.query; -import org.apache.ignite.*; -import org.apache.ignite.internal.util.typedef.internal.*; - -import java.io.*; +import java.io.Serializable; +import org.apache.ignite.IgniteCache; +import org.apache.ignite.internal.util.typedef.internal.S; /** * Base class for all Ignite cache queries. @@ -98,4 +97,4 @@ public abstract class Query<R> implements Serializable { @Override public String toString() { return S.toString(Query.class, this); } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/cache/query/QueryCursor.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/query/QueryCursor.java b/modules/core/src/main/java/org/apache/ignite/cache/query/QueryCursor.java index b0c896a..84b6862 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/query/QueryCursor.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/query/QueryCursor.java @@ -17,7 +17,7 @@ package org.apache.ignite.cache.query; -import java.util.*; +import java.util.List; /** * Query result cursor. Implements {@link Iterable} only for convenience, e.g. {@link #iterator()} @@ -42,4 +42,4 @@ public interface QueryCursor<T> extends Iterable<T>, AutoCloseable { * Closes all resources related to this cursor. */ @Override public void close(); -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/cache/query/QueryMetrics.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/query/QueryMetrics.java b/modules/core/src/main/java/org/apache/ignite/cache/query/QueryMetrics.java index ef8fc49..e376561 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/query/QueryMetrics.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/query/QueryMetrics.java @@ -17,7 +17,7 @@ package org.apache.ignite.cache.query; -import org.apache.ignite.internal.processors.cache.query.*; +import org.apache.ignite.internal.processors.cache.query.CacheQuery; /** * Cache query metrics used to obtain statistics on query. Metrics for particular query @@ -59,4 +59,4 @@ public interface QueryMetrics { * @return Total number of times a query execution failed. */ public int fails(); -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/cache/query/ScanQuery.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/query/ScanQuery.java b/modules/core/src/main/java/org/apache/ignite/cache/query/ScanQuery.java index 6e02ff9..c7fa3d2 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/query/ScanQuery.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/query/ScanQuery.java @@ -17,12 +17,11 @@ package org.apache.ignite.cache.query; -import org.apache.ignite.*; -import org.apache.ignite.internal.util.typedef.internal.*; -import org.apache.ignite.lang.*; -import org.jetbrains.annotations.*; - -import javax.cache.*; +import javax.cache.Cache; +import org.apache.ignite.IgniteCache; +import org.apache.ignite.internal.util.typedef.internal.S; +import org.apache.ignite.lang.IgniteBiPredicate; +import org.jetbrains.annotations.Nullable; /** * Scan query over cache entries. Will accept all the entries if no predicate was set. @@ -133,4 +132,4 @@ public final class ScanQuery<K, V> extends Query<Cache.Entry<K, V>> { @Override public String toString() { return S.toString(ScanQuery.class, this); } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/cache/query/SpiQuery.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/query/SpiQuery.java b/modules/core/src/main/java/org/apache/ignite/cache/query/SpiQuery.java index 71b9d23..0c11437 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/query/SpiQuery.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/query/SpiQuery.java @@ -17,12 +17,11 @@ package org.apache.ignite.cache.query; -import org.apache.ignite.*; -import org.apache.ignite.internal.util.tostring.*; -import org.apache.ignite.internal.util.typedef.internal.*; -import org.apache.ignite.spi.indexing.*; - -import javax.cache.*; +import javax.cache.Cache; +import org.apache.ignite.IgniteCache; +import org.apache.ignite.internal.util.tostring.GridToStringInclude; +import org.apache.ignite.internal.util.typedef.internal.S; +import org.apache.ignite.spi.indexing.IndexingSpi; /** * Query to be used by {@link IndexingSpi} implementations. @@ -72,4 +71,4 @@ public final class SpiQuery<K, V> extends Query<Cache.Entry<K, V>> { @Override public String toString() { return S.toString(SpiQuery.class, this); } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/cache/query/SqlFieldsQuery.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/query/SqlFieldsQuery.java b/modules/core/src/main/java/org/apache/ignite/cache/query/SqlFieldsQuery.java index 04131e2..b2dd181 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/query/SqlFieldsQuery.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/query/SqlFieldsQuery.java @@ -17,11 +17,11 @@ package org.apache.ignite.cache.query; -import org.apache.ignite.*; -import org.apache.ignite.internal.util.tostring.*; -import org.apache.ignite.internal.util.typedef.internal.*; - -import java.util.*; +import java.util.List; +import org.apache.ignite.IgniteCache; +import org.apache.ignite.internal.util.tostring.GridToStringInclude; +import org.apache.ignite.internal.util.typedef.internal.A; +import org.apache.ignite.internal.util.typedef.internal.S; /** * SQL Fields query. This query can return specific fields of data based @@ -155,4 +155,4 @@ public final class SqlFieldsQuery extends Query<List<?>> { @Override public String toString() { return S.toString(SqlFieldsQuery.class, this); } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/cache/query/SqlQuery.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/query/SqlQuery.java b/modules/core/src/main/java/org/apache/ignite/cache/query/SqlQuery.java index 64a8d4c..be3b390 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/query/SqlQuery.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/query/SqlQuery.java @@ -17,12 +17,12 @@ package org.apache.ignite.cache.query; -import org.apache.ignite.*; -import org.apache.ignite.internal.processors.query.*; -import org.apache.ignite.internal.util.tostring.*; -import org.apache.ignite.internal.util.typedef.internal.*; - -import javax.cache.*; +import javax.cache.Cache; +import org.apache.ignite.IgniteCache; +import org.apache.ignite.internal.processors.query.GridQueryProcessor; +import org.apache.ignite.internal.util.tostring.GridToStringInclude; +import org.apache.ignite.internal.util.typedef.internal.A; +import org.apache.ignite.internal.util.typedef.internal.S; /** * SQL Query. @@ -151,4 +151,4 @@ public final class SqlQuery<K, V> extends Query<Cache.Entry<K, V>> { @Override public String toString() { return S.toString(SqlQuery.class, this); } -} +} \ No newline at end of file
