http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/cache/query/TextQuery.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/query/TextQuery.java b/modules/core/src/main/java/org/apache/ignite/cache/query/TextQuery.java index 0bb4c63..4eba432 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/query/TextQuery.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/query/TextQuery.java @@ -17,11 +17,11 @@ package org.apache.ignite.cache.query; -import org.apache.ignite.*; -import org.apache.ignite.internal.processors.query.*; -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.typedef.internal.A; +import org.apache.ignite.internal.util.typedef.internal.S; /** * Query for Lucene based fulltext search. @@ -128,4 +128,4 @@ public final class TextQuery<K, V> extends Query<Cache.Entry<K, V>> { @Override public String toString() { return S.toString(TextQuery.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/annotations/QueryGroupIndex.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/query/annotations/QueryGroupIndex.java b/modules/core/src/main/java/org/apache/ignite/cache/query/annotations/QueryGroupIndex.java index 9c756c4..b1fefae 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/query/annotations/QueryGroupIndex.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/query/annotations/QueryGroupIndex.java @@ -17,7 +17,10 @@ package org.apache.ignite.cache.query.annotations; -import java.lang.annotation.*; +import java.lang.annotation.ElementType; +import java.lang.annotation.Retention; +import java.lang.annotation.RetentionPolicy; +import java.lang.annotation.Target; /** * Describes group index. @@ -46,4 +49,4 @@ public @interface QueryGroupIndex { */ QueryGroupIndex[] value(); } -} +} \ 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/annotations/QuerySqlField.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/query/annotations/QuerySqlField.java b/modules/core/src/main/java/org/apache/ignite/cache/query/annotations/QuerySqlField.java index db35671..48402b5 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/query/annotations/QuerySqlField.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/query/annotations/QuerySqlField.java @@ -17,9 +17,12 @@ package org.apache.ignite.cache.query.annotations; -import org.apache.ignite.internal.processors.cache.query.*; - -import java.lang.annotation.*; +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 org.apache.ignite.internal.processors.cache.query.CacheQuery; /** * Annotates fields for SQL queries. All fields that will be involved in SQL clauses must have @@ -122,4 +125,4 @@ public @interface QuerySqlField { */ boolean descending() default 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/query/annotations/QuerySqlFunction.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/query/annotations/QuerySqlFunction.java b/modules/core/src/main/java/org/apache/ignite/cache/query/annotations/QuerySqlFunction.java index 7d292d3..92837ec 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/query/annotations/QuerySqlFunction.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/query/annotations/QuerySqlFunction.java @@ -17,7 +17,11 @@ package org.apache.ignite.cache.query.annotations; -import java.lang.annotation.*; +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; /** * Annotates public static methods in classes to be used in SQL queries as custom functions. @@ -64,4 +68,4 @@ public @interface QuerySqlFunction { * @return {@code true} If function is deterministic, {@code false} otherwise. */ boolean deterministic() default 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/query/annotations/QueryTextField.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/query/annotations/QueryTextField.java b/modules/core/src/main/java/org/apache/ignite/cache/query/annotations/QueryTextField.java index 280ebc3..55809b6 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/query/annotations/QueryTextField.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/query/annotations/QueryTextField.java @@ -17,9 +17,12 @@ package org.apache.ignite.cache.query.annotations; -import org.apache.ignite.internal.processors.cache.query.*; - -import java.lang.annotation.*; +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 org.apache.ignite.internal.processors.cache.query.CacheQuery; /** * Annotation for fields or getters to be indexed for full text @@ -32,4 +35,4 @@ import java.lang.annotation.*; @Target({ElementType.METHOD, ElementType.FIELD, ElementType.TYPE}) public @interface QueryTextField { // 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/store/CacheLoadOnlyStoreAdapter.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/store/CacheLoadOnlyStoreAdapter.java b/modules/core/src/main/java/org/apache/ignite/cache/store/CacheLoadOnlyStoreAdapter.java index a0cbe65..7494e37 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/store/CacheLoadOnlyStoreAdapter.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/store/CacheLoadOnlyStoreAdapter.java @@ -17,18 +17,28 @@ package org.apache.ignite.cache.store; -import org.apache.ignite.*; -import org.apache.ignite.internal.util.typedef.internal.*; -import org.apache.ignite.lang.*; -import org.apache.ignite.resources.*; -import org.jetbrains.annotations.*; - -import javax.cache.*; -import javax.cache.integration.*; -import java.util.*; -import java.util.concurrent.*; - -import static java.util.concurrent.TimeUnit.*; +import java.util.ArrayList; +import java.util.Collection; +import java.util.Collections; +import java.util.Iterator; +import java.util.Map; +import java.util.concurrent.ArrayBlockingQueue; +import java.util.concurrent.ExecutorService; +import java.util.concurrent.RejectedExecutionException; +import java.util.concurrent.RejectedExecutionHandler; +import java.util.concurrent.ThreadPoolExecutor; +import javax.cache.Cache; +import javax.cache.integration.CacheLoaderException; +import org.apache.ignite.IgniteCache; +import org.apache.ignite.IgniteLogger; +import org.apache.ignite.internal.util.typedef.internal.U; +import org.apache.ignite.lang.IgniteBiInClosure; +import org.apache.ignite.lang.IgniteBiPredicate; +import org.apache.ignite.lang.IgniteBiTuple; +import org.apache.ignite.resources.LoggerResource; +import org.jetbrains.annotations.Nullable; + +import static java.util.concurrent.TimeUnit.MILLISECONDS; /** * This adapter designed to support stores with bulk loading from stream-like source. @@ -320,4 +330,4 @@ public abstract class CacheLoadOnlyStoreAdapter<K, V, I> implements CacheStore<K } } } -} +} \ 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/store/CacheStore.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/store/CacheStore.java b/modules/core/src/main/java/org/apache/ignite/cache/store/CacheStore.java index 5bfdda1..7d84c34 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/store/CacheStore.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/store/CacheStore.java @@ -17,13 +17,17 @@ package org.apache.ignite.cache.store; -import org.apache.ignite.cache.store.jdbc.*; -import org.apache.ignite.lang.*; -import org.apache.ignite.transactions.*; -import org.jetbrains.annotations.*; - -import javax.cache.integration.*; -import java.util.*; +import java.util.Collection; +import javax.cache.integration.CacheLoader; +import javax.cache.integration.CacheLoaderException; +import javax.cache.integration.CacheWriter; +import javax.cache.integration.CacheWriterException; +import org.apache.ignite.cache.store.jdbc.CacheJdbcBlobStore; +import org.apache.ignite.lang.IgniteBiInClosure; +import org.apache.ignite.lang.IgniteBiPredicate; +import org.apache.ignite.transactions.Transaction; +import org.apache.ignite.transactions.TransactionState; +import org.jetbrains.annotations.Nullable; /** * API for cache persistent storage for read-through and write-through behavior. @@ -98,4 +102,4 @@ public interface CacheStore<K, V> extends CacheLoader<K, V>, CacheWriter<K, V> { */ @Deprecated public void sessionEnd(boolean commit) throws CacheWriterException; -} +} \ 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/store/CacheStoreAdapter.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/store/CacheStoreAdapter.java b/modules/core/src/main/java/org/apache/ignite/cache/store/CacheStoreAdapter.java index f7adf2c..eaf5225 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/store/CacheStoreAdapter.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/store/CacheStoreAdapter.java @@ -17,10 +17,12 @@ package org.apache.ignite.cache.store; -import org.apache.ignite.lang.*; - -import javax.cache.*; -import java.util.*; +import java.util.Collection; +import java.util.HashMap; +import java.util.Map; +import javax.cache.Cache; +import org.apache.ignite.lang.IgniteBiInClosure; +import org.apache.ignite.lang.IgniteBiPredicate; /** * Cache storage convenience adapter. It provides default implementation for bulk operations, such @@ -91,4 +93,4 @@ public abstract class CacheStoreAdapter<K, V> implements CacheStore<K, V> { @Override public void sessionEnd(boolean commit) { // 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/store/CacheStoreSession.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/store/CacheStoreSession.java b/modules/core/src/main/java/org/apache/ignite/cache/store/CacheStoreSession.java index 329e994..4ddd8f1 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/store/CacheStoreSession.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/store/CacheStoreSession.java @@ -17,11 +17,10 @@ package org.apache.ignite.cache.store; -import org.apache.ignite.resources.*; -import org.apache.ignite.transactions.*; -import org.jetbrains.annotations.*; - -import java.util.*; +import java.util.Map; +import org.apache.ignite.resources.CacheStoreSessionResource; +import org.apache.ignite.transactions.Transaction; +import org.jetbrains.annotations.Nullable; /** * Session for the cache store operations. The main purpose of cache store session @@ -89,4 +88,4 @@ public interface CacheStoreSession { * @return Cache name for the current store operation. */ public String cacheName(); -} +} \ 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/store/CacheStoreSessionListener.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/store/CacheStoreSessionListener.java b/modules/core/src/main/java/org/apache/ignite/cache/store/CacheStoreSessionListener.java index 1543bf9..8215756 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/store/CacheStoreSessionListener.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/store/CacheStoreSessionListener.java @@ -17,11 +17,11 @@ package org.apache.ignite.cache.store; -import org.apache.ignite.cache.store.jdbc.*; -import org.apache.ignite.configuration.*; - -import javax.cache.configuration.*; -import javax.sql.*; +import javax.cache.configuration.Factory; +import javax.sql.DataSource; +import org.apache.ignite.cache.store.jdbc.CacheJdbcStoreSessionListener; +import org.apache.ignite.configuration.CacheConfiguration; +import org.apache.ignite.configuration.IgniteConfiguration; /** * Cache store session listener that allows to implement callbacks @@ -130,4 +130,4 @@ public interface CacheStoreSessionListener { * should commit, {@code false} for rollback. */ public void onSessionEnd(CacheStoreSession ses, boolean commit); -} +} \ 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/store/jdbc/CacheAbstractJdbcStore.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/CacheAbstractJdbcStore.java b/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/CacheAbstractJdbcStore.java index b2be8c7..6e27b9a 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/CacheAbstractJdbcStore.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/CacheAbstractJdbcStore.java @@ -17,30 +17,63 @@ package org.apache.ignite.cache.store.jdbc; -import org.apache.ignite.*; -import org.apache.ignite.cache.*; -import org.apache.ignite.cache.store.*; -import org.apache.ignite.cache.store.jdbc.dialect.*; -import org.apache.ignite.configuration.*; -import org.apache.ignite.internal.util.tostring.*; -import org.apache.ignite.internal.util.typedef.*; -import org.apache.ignite.internal.util.typedef.internal.*; -import org.apache.ignite.lang.*; -import org.apache.ignite.lifecycle.*; -import org.apache.ignite.resources.*; -import org.apache.ignite.transactions.*; -import org.jetbrains.annotations.*; - -import javax.cache.*; -import javax.cache.integration.*; -import javax.sql.*; -import java.nio.*; -import java.sql.*; -import java.util.*; -import java.util.concurrent.*; -import java.util.concurrent.locks.*; - -import static java.sql.Statement.*; +import java.nio.ByteBuffer; +import java.sql.BatchUpdateException; +import java.sql.Connection; +import java.sql.PreparedStatement; +import java.sql.ResultSet; +import java.sql.ResultSetMetaData; +import java.sql.SQLException; +import java.sql.Statement; +import java.sql.Types; +import java.util.ArrayList; +import java.util.Collection; +import java.util.Collections; +import java.util.HashMap; +import java.util.Map; +import java.util.UUID; +import java.util.concurrent.Callable; +import java.util.concurrent.ExecutorService; +import java.util.concurrent.Executors; +import java.util.concurrent.Future; +import java.util.concurrent.locks.Lock; +import java.util.concurrent.locks.ReentrantLock; +import javax.cache.Cache; +import javax.cache.CacheException; +import javax.cache.integration.CacheLoaderException; +import javax.cache.integration.CacheWriterException; +import javax.sql.DataSource; +import org.apache.ignite.Ignite; +import org.apache.ignite.IgniteCheckedException; +import org.apache.ignite.IgniteException; +import org.apache.ignite.IgniteLogger; +import org.apache.ignite.cache.CacheTypeFieldMetadata; +import org.apache.ignite.cache.CacheTypeMetadata; +import org.apache.ignite.cache.store.CacheStore; +import org.apache.ignite.cache.store.CacheStoreSession; +import org.apache.ignite.cache.store.jdbc.dialect.BasicJdbcDialect; +import org.apache.ignite.cache.store.jdbc.dialect.DB2Dialect; +import org.apache.ignite.cache.store.jdbc.dialect.H2Dialect; +import org.apache.ignite.cache.store.jdbc.dialect.JdbcDialect; +import org.apache.ignite.cache.store.jdbc.dialect.MySQLDialect; +import org.apache.ignite.cache.store.jdbc.dialect.OracleDialect; +import org.apache.ignite.cache.store.jdbc.dialect.SQLServerDialect; +import org.apache.ignite.configuration.CacheConfiguration; +import org.apache.ignite.internal.util.tostring.GridToStringExclude; +import org.apache.ignite.internal.util.typedef.C1; +import org.apache.ignite.internal.util.typedef.F; +import org.apache.ignite.internal.util.typedef.internal.U; +import org.apache.ignite.lang.IgniteBiInClosure; +import org.apache.ignite.lang.IgnitePredicate; +import org.apache.ignite.lifecycle.LifecycleAware; +import org.apache.ignite.resources.CacheStoreSessionResource; +import org.apache.ignite.resources.IgniteInstanceResource; +import org.apache.ignite.resources.LoggerResource; +import org.apache.ignite.transactions.Transaction; +import org.jetbrains.annotations.Nullable; + +import static java.sql.Statement.EXECUTE_FAILED; +import static java.sql.Statement.SUCCESS_NO_INFO; /** * Implementation of {@link CacheStore} backed by JDBC. @@ -1788,4 +1821,4 @@ public abstract class CacheAbstractJdbcStore<K, V> implements CacheStore<K, V>, } } } -} +} \ 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/store/jdbc/CacheJdbcBlobStore.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/CacheJdbcBlobStore.java b/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/CacheJdbcBlobStore.java index e01c879..147f6c9 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/CacheJdbcBlobStore.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/CacheJdbcBlobStore.java @@ -17,27 +17,40 @@ package org.apache.ignite.cache.store.jdbc; -import org.apache.ignite.*; -import org.apache.ignite.cache.store.*; -import org.apache.ignite.configuration.*; -import org.apache.ignite.internal.*; -import org.apache.ignite.internal.util.tostring.*; -import org.apache.ignite.internal.util.typedef.*; -import org.apache.ignite.internal.util.typedef.internal.*; -import org.apache.ignite.marshaller.*; -import org.apache.ignite.marshaller.jdk.*; -import org.apache.ignite.resources.*; -import org.apache.ignite.transactions.*; -import org.jetbrains.annotations.*; -import org.jsr166.*; - -import javax.cache.*; -import javax.cache.integration.*; -import javax.sql.*; -import java.sql.*; -import java.util.*; -import java.util.concurrent.*; -import java.util.concurrent.atomic.*; +import java.sql.Connection; +import java.sql.DriverManager; +import java.sql.PreparedStatement; +import java.sql.ResultSet; +import java.sql.SQLException; +import java.sql.Statement; +import java.util.Map; +import java.util.concurrent.CountDownLatch; +import java.util.concurrent.atomic.AtomicBoolean; +import javax.cache.Cache; +import javax.cache.integration.CacheLoaderException; +import javax.cache.integration.CacheWriterException; +import javax.sql.DataSource; +import org.apache.ignite.Ignite; +import org.apache.ignite.IgniteCheckedException; +import org.apache.ignite.IgniteException; +import org.apache.ignite.IgniteLogger; +import org.apache.ignite.cache.store.CacheStore; +import org.apache.ignite.cache.store.CacheStoreAdapter; +import org.apache.ignite.cache.store.CacheStoreSession; +import org.apache.ignite.configuration.CacheConfiguration; +import org.apache.ignite.internal.IgniteInterruptedCheckedException; +import org.apache.ignite.internal.util.tostring.GridToStringExclude; +import org.apache.ignite.internal.util.typedef.F; +import org.apache.ignite.internal.util.typedef.internal.S; +import org.apache.ignite.internal.util.typedef.internal.U; +import org.apache.ignite.marshaller.Marshaller; +import org.apache.ignite.marshaller.jdk.JdkMarshaller; +import org.apache.ignite.resources.CacheStoreSessionResource; +import org.apache.ignite.resources.IgniteInstanceResource; +import org.apache.ignite.resources.LoggerResource; +import org.apache.ignite.transactions.Transaction; +import org.jetbrains.annotations.Nullable; +import org.jsr166.LongAdder8; /** * {@link CacheStore} implementation backed by JDBC. This implementation @@ -580,4 +593,4 @@ public class CacheJdbcBlobStore<K, V> extends CacheStoreAdapter<K, V> { protected CacheStoreSession session() { return ses; } -} +} \ 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/store/jdbc/CacheJdbcBlobStoreFactory.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/CacheJdbcBlobStoreFactory.java b/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/CacheJdbcBlobStoreFactory.java index cf493a0..0625945 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/CacheJdbcBlobStoreFactory.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/CacheJdbcBlobStoreFactory.java @@ -17,16 +17,16 @@ package org.apache.ignite.cache.store.jdbc; -import org.apache.ignite.*; -import org.apache.ignite.configuration.*; -import org.apache.ignite.internal.*; -import org.apache.ignite.internal.util.spring.*; -import org.apache.ignite.internal.util.tostring.*; -import org.apache.ignite.internal.util.typedef.internal.*; -import org.apache.ignite.resources.*; - -import javax.cache.configuration.*; -import javax.sql.*; +import javax.cache.configuration.Factory; +import javax.sql.DataSource; +import org.apache.ignite.IgniteCheckedException; +import org.apache.ignite.IgniteException; +import org.apache.ignite.configuration.CacheConfiguration; +import org.apache.ignite.internal.IgniteComponentType; +import org.apache.ignite.internal.util.spring.IgniteSpringHelper; +import org.apache.ignite.internal.util.tostring.GridToStringExclude; +import org.apache.ignite.internal.util.typedef.internal.S; +import org.apache.ignite.resources.SpringApplicationContextResource; /** * {@link Factory} implementation for {@link CacheJdbcBlobStore}. @@ -287,4 +287,4 @@ public class CacheJdbcBlobStoreFactory<K, V> implements Factory<CacheJdbcBlobSto @Override public String toString() { return S.toString(CacheJdbcBlobStoreFactory.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/store/jdbc/CacheJdbcPojoStore.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/CacheJdbcPojoStore.java b/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/CacheJdbcPojoStore.java index 1ff170e..d78ea48 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/CacheJdbcPojoStore.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/CacheJdbcPojoStore.java @@ -17,18 +17,23 @@ package org.apache.ignite.cache.store.jdbc; -import org.apache.ignite.cache.*; -import org.apache.ignite.cache.store.*; -import org.apache.ignite.configuration.*; -import org.apache.ignite.internal.util.typedef.*; -import org.apache.ignite.internal.util.typedef.internal.*; -import org.jetbrains.annotations.*; - -import javax.cache.*; -import javax.cache.integration.*; -import java.lang.reflect.*; -import java.sql.*; -import java.util.*; +import java.lang.reflect.Constructor; +import java.lang.reflect.Method; +import java.sql.ResultSet; +import java.sql.SQLException; +import java.util.Collection; +import java.util.Collections; +import java.util.HashMap; +import java.util.Map; +import javax.cache.CacheException; +import javax.cache.integration.CacheLoaderException; +import org.apache.ignite.cache.CacheTypeFieldMetadata; +import org.apache.ignite.cache.CacheTypeMetadata; +import org.apache.ignite.cache.store.CacheStore; +import org.apache.ignite.configuration.CacheConfiguration; +import org.apache.ignite.internal.util.typedef.F; +import org.apache.ignite.internal.util.typedef.internal.U; +import org.jetbrains.annotations.Nullable; /** * Implementation of {@link CacheStore} backed by JDBC and POJO via reflection. @@ -238,4 +243,4 @@ public class CacheJdbcPojoStore<K, V> extends CacheAbstractJdbcStore<K, V> { throw new CacheException("Failed to find class: " + type, 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/store/jdbc/CacheJdbcPojoStoreFactory.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/CacheJdbcPojoStoreFactory.java b/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/CacheJdbcPojoStoreFactory.java index 5449433..bf7c9e7 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/CacheJdbcPojoStoreFactory.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/CacheJdbcPojoStoreFactory.java @@ -17,16 +17,15 @@ package org.apache.ignite.cache.store.jdbc; -import org.apache.ignite.*; -import org.apache.ignite.cache.store.jdbc.dialect.*; -import org.apache.ignite.configuration.*; -import org.apache.ignite.internal.*; -import org.apache.ignite.internal.util.spring.*; -import org.apache.ignite.internal.util.typedef.internal.*; -import org.apache.ignite.resources.*; - -import javax.cache.configuration.*; -import javax.sql.*; +import javax.cache.configuration.Factory; +import javax.sql.DataSource; +import org.apache.ignite.IgniteException; +import org.apache.ignite.cache.store.jdbc.dialect.JdbcDialect; +import org.apache.ignite.configuration.CacheConfiguration; +import org.apache.ignite.internal.IgniteComponentType; +import org.apache.ignite.internal.util.spring.IgniteSpringHelper; +import org.apache.ignite.internal.util.typedef.internal.S; +import org.apache.ignite.resources.SpringApplicationContextResource; /** * {@link Factory} implementation for {@link CacheJdbcPojoStore}. @@ -145,4 +144,4 @@ public class CacheJdbcPojoStoreFactory<K, V> implements Factory<CacheJdbcPojoSto @Override public String toString() { return S.toString(CacheJdbcPojoStoreFactory.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/store/jdbc/CacheJdbcStoreSessionListener.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/CacheJdbcStoreSessionListener.java b/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/CacheJdbcStoreSessionListener.java index a20e535..2c70d26 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/CacheJdbcStoreSessionListener.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/CacheJdbcStoreSessionListener.java @@ -17,15 +17,17 @@ package org.apache.ignite.cache.store.jdbc; -import org.apache.ignite.*; -import org.apache.ignite.cache.store.*; -import org.apache.ignite.internal.util.typedef.internal.*; -import org.apache.ignite.lifecycle.*; - -import javax.cache.*; -import javax.cache.integration.*; -import javax.sql.*; -import java.sql.*; +import java.sql.Connection; +import java.sql.SQLException; +import javax.cache.Cache; +import javax.cache.integration.CacheWriterException; +import javax.sql.DataSource; +import org.apache.ignite.IgniteException; +import org.apache.ignite.cache.store.CacheStore; +import org.apache.ignite.cache.store.CacheStoreSession; +import org.apache.ignite.cache.store.CacheStoreSessionListener; +import org.apache.ignite.internal.util.typedef.internal.U; +import org.apache.ignite.lifecycle.LifecycleAware; /** * Cache store session listener based on JDBC connection. @@ -138,4 +140,4 @@ public class CacheJdbcStoreSessionListener implements CacheStoreSessionListener, } } } -} +} \ 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/store/jdbc/dialect/BasicJdbcDialect.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/dialect/BasicJdbcDialect.java b/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/dialect/BasicJdbcDialect.java index b43c7d5..abb59d3 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/dialect/BasicJdbcDialect.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/dialect/BasicJdbcDialect.java @@ -17,10 +17,10 @@ package org.apache.ignite.cache.store.jdbc.dialect; -import org.apache.ignite.internal.util.typedef.*; -import org.apache.ignite.internal.util.typedef.internal.*; - -import java.util.*; +import java.util.Collection; +import org.apache.ignite.internal.util.typedef.C1; +import org.apache.ignite.internal.util.typedef.F; +import org.apache.ignite.internal.util.typedef.internal.SB; /** * Basic implementation of dialect based on JDBC specification. @@ -274,4 +274,4 @@ public class BasicJdbcDialect implements JdbcDialect { public void setMaxParameterCount(int maxParamsCnt) { this.maxParamsCnt = maxParamsCnt; } -} +} \ 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/store/jdbc/dialect/DB2Dialect.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/dialect/DB2Dialect.java b/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/dialect/DB2Dialect.java index 2a08557..2a92bdd 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/dialect/DB2Dialect.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/dialect/DB2Dialect.java @@ -17,9 +17,9 @@ package org.apache.ignite.cache.store.jdbc.dialect; -import org.apache.ignite.internal.util.typedef.*; - -import java.util.*; +import java.util.Collection; +import org.apache.ignite.internal.util.typedef.C1; +import org.apache.ignite.internal.util.typedef.F; /** * A dialect compatible with the IBM DB2 database. @@ -68,4 +68,4 @@ public class DB2Dialect extends BasicJdbcDialect { " INSERT (%s) VALUES (%s)", fullTblName, repeat("?", cols.size(), "", ",", ""), colsLst, match, setCols, colsLst, valuesCols); } -} +} \ 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/store/jdbc/dialect/H2Dialect.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/dialect/H2Dialect.java b/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/dialect/H2Dialect.java index 8091e1a..94d27a9 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/dialect/H2Dialect.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/dialect/H2Dialect.java @@ -17,9 +17,8 @@ package org.apache.ignite.cache.store.jdbc.dialect; -import org.apache.ignite.internal.util.typedef.*; - -import java.util.*; +import java.util.Collection; +import org.apache.ignite.internal.util.typedef.F; /** * A dialect compatible with the H2 database. @@ -41,4 +40,4 @@ public class H2Dialect extends BasicJdbcDialect { return String.format("MERGE INTO %s (%s) KEY (%s) VALUES(%s)", fullTblName, mkString(cols, ","), mkString(keyCols, ","), repeat("?", cols.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/store/jdbc/dialect/JdbcDialect.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/dialect/JdbcDialect.java b/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/dialect/JdbcDialect.java index 32adcc4..38e981f 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/dialect/JdbcDialect.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/dialect/JdbcDialect.java @@ -17,8 +17,8 @@ package org.apache.ignite.cache.store.jdbc.dialect; -import java.io.*; -import java.util.*; +import java.io.Serializable; +import java.util.Collection; /** * Represents a dialect of SQL implemented by a particular RDBMS. @@ -115,4 +115,4 @@ public interface JdbcDialect extends Serializable { * @return Max query parameters count. */ public int getMaxParameterCount(); -} +} \ 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/store/jdbc/dialect/MySQLDialect.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/dialect/MySQLDialect.java b/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/dialect/MySQLDialect.java index def2fe7..f7512a7 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/dialect/MySQLDialect.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/dialect/MySQLDialect.java @@ -17,9 +17,9 @@ package org.apache.ignite.cache.store.jdbc.dialect; -import org.apache.ignite.internal.util.typedef.*; - -import java.util.*; +import java.util.Collection; +import org.apache.ignite.internal.util.typedef.C1; +import org.apache.ignite.internal.util.typedef.F; /** * A dialect compatible with the MySQL database. @@ -48,4 +48,4 @@ public class MySQLDialect extends BasicJdbcDialect { return String.format("INSERT INTO %s (%s) VALUES (%s) ON DUPLICATE KEY UPDATE %s", fullTblName, mkString(cols, ", "), repeat("?", cols.size(), "", ",", ""), updPart); } -} +} \ 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/store/jdbc/dialect/OracleDialect.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/dialect/OracleDialect.java b/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/dialect/OracleDialect.java index e155fb4..b7a0400 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/dialect/OracleDialect.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/dialect/OracleDialect.java @@ -17,9 +17,9 @@ package org.apache.ignite.cache.store.jdbc.dialect; -import org.apache.ignite.internal.util.typedef.*; - -import java.util.*; +import java.util.Collection; +import org.apache.ignite.internal.util.typedef.C1; +import org.apache.ignite.internal.util.typedef.F; /** * A dialect compatible with the Oracle database. @@ -72,4 +72,4 @@ public class OracleDialect extends BasicJdbcDialect { " WHEN NOT MATCHED THEN" + " INSERT (%s) VALUES (%s)", fullTblName, selCols, match, setCols, colsLst, valuesCols); } -} +} \ 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/store/jdbc/dialect/SQLServerDialect.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/dialect/SQLServerDialect.java b/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/dialect/SQLServerDialect.java index 7fdda6b..0082617 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/dialect/SQLServerDialect.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/dialect/SQLServerDialect.java @@ -17,9 +17,9 @@ package org.apache.ignite.cache.store.jdbc.dialect; -import org.apache.ignite.internal.util.typedef.*; - -import java.util.*; +import java.util.Collection; +import org.apache.ignite.internal.util.typedef.C1; +import org.apache.ignite.internal.util.typedef.F; /** * A dialect compatible with the Microsoft SQL Server database. @@ -67,4 +67,4 @@ public class SQLServerDialect extends BasicJdbcDialect { " INSERT (%s) VALUES (%s);", fullTblName, repeat("?", cols.size(), "", ",", ""), colsLst, match, setCols, colsLst, valuesCols); } -} +} \ 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/cluster/ClusterGroup.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cluster/ClusterGroup.java b/modules/core/src/main/java/org/apache/ignite/cluster/ClusterGroup.java index d21e25a..1b972ca 100644 --- a/modules/core/src/main/java/org/apache/ignite/cluster/ClusterGroup.java +++ b/modules/core/src/main/java/org/apache/ignite/cluster/ClusterGroup.java @@ -17,12 +17,15 @@ package org.apache.ignite.cluster; -import org.apache.ignite.*; -import org.apache.ignite.configuration.*; -import org.apache.ignite.lang.*; -import org.jetbrains.annotations.*; - -import java.util.*; +import java.util.Collection; +import java.util.UUID; +import org.apache.ignite.Ignite; +import org.apache.ignite.IgniteCluster; +import org.apache.ignite.IgniteException; +import org.apache.ignite.Ignition; +import org.apache.ignite.configuration.IgniteConfiguration; +import org.apache.ignite.lang.IgnitePredicate; +import org.jetbrains.annotations.Nullable; /** * Defines a cluster group which contains all or a subset of cluster nodes. @@ -290,4 +293,4 @@ public interface ClusterGroup { * @throws IgniteException If this cluster group is empty. */ public ClusterMetrics metrics() throws IgniteException; -} +} \ 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/cluster/ClusterGroupEmptyException.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cluster/ClusterGroupEmptyException.java b/modules/core/src/main/java/org/apache/ignite/cluster/ClusterGroupEmptyException.java index f03e08c..63b2839 100644 --- a/modules/core/src/main/java/org/apache/ignite/cluster/ClusterGroupEmptyException.java +++ b/modules/core/src/main/java/org/apache/ignite/cluster/ClusterGroupEmptyException.java @@ -17,7 +17,7 @@ package org.apache.ignite.cluster; -import org.jetbrains.annotations.*; +import org.jetbrains.annotations.Nullable; /** * This exception defines illegal call on empty cluster group. Thrown by cluster group when operation @@ -52,4 +52,4 @@ public class ClusterGroupEmptyException extends ClusterTopologyException { public ClusterGroupEmptyException(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/cluster/ClusterMetrics.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cluster/ClusterMetrics.java b/modules/core/src/main/java/org/apache/ignite/cluster/ClusterMetrics.java index 98820d2..50c09be 100644 --- a/modules/core/src/main/java/org/apache/ignite/cluster/ClusterMetrics.java +++ b/modules/core/src/main/java/org/apache/ignite/cluster/ClusterMetrics.java @@ -17,8 +17,8 @@ package org.apache.ignite.cluster; -import org.apache.ignite.*; -import org.apache.ignite.configuration.*; +import org.apache.ignite.IgniteCluster; +import org.apache.ignite.configuration.IgniteConfiguration; /** * This class represents runtime information on a cluster. Apart from obvious @@ -684,4 +684,4 @@ public interface ClusterMetrics { * @return Total number of nodes. */ public int getTotalNodes(); -} +} \ 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/cluster/ClusterNode.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cluster/ClusterNode.java b/modules/core/src/main/java/org/apache/ignite/cluster/ClusterNode.java index 62c1deb..bfc395d 100644 --- a/modules/core/src/main/java/org/apache/ignite/cluster/ClusterNode.java +++ b/modules/core/src/main/java/org/apache/ignite/cluster/ClusterNode.java @@ -17,13 +17,17 @@ package org.apache.ignite.cluster; -import org.apache.ignite.*; -import org.apache.ignite.configuration.*; -import org.apache.ignite.lang.*; -import org.apache.ignite.spi.discovery.*; -import org.jetbrains.annotations.*; - -import java.util.*; +import java.util.Collection; +import java.util.List; +import java.util.Map; +import java.util.UUID; +import org.apache.ignite.Ignite; +import org.apache.ignite.IgniteCluster; +import org.apache.ignite.Ignition; +import org.apache.ignite.configuration.IgniteConfiguration; +import org.apache.ignite.lang.IgniteProductVersion; +import org.apache.ignite.spi.discovery.DiscoverySpi; +import org.jetbrains.annotations.Nullable; /** * Interface representing a single cluster node. Use {@link #attribute(String)} or @@ -255,4 +259,4 @@ public interface ClusterNode { * @see DiscoverySpi#isClientMode() */ public boolean isClient(); -} +} \ 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/cluster/ClusterStartNodeResult.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cluster/ClusterStartNodeResult.java b/modules/core/src/main/java/org/apache/ignite/cluster/ClusterStartNodeResult.java index b6c3619..a66d842 100644 --- a/modules/core/src/main/java/org/apache/ignite/cluster/ClusterStartNodeResult.java +++ b/modules/core/src/main/java/org/apache/ignite/cluster/ClusterStartNodeResult.java @@ -17,7 +17,7 @@ package org.apache.ignite.cluster; -import org.jetbrains.annotations.*; +import org.jetbrains.annotations.Nullable; /** * Cluster start node result information. @@ -43,4 +43,4 @@ public interface ClusterStartNodeResult { * @return Error massage. */ @Nullable public String getError(); -} +} \ 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/cluster/ClusterTopologyException.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cluster/ClusterTopologyException.java b/modules/core/src/main/java/org/apache/ignite/cluster/ClusterTopologyException.java index 61bc367..e5abcbc 100644 --- a/modules/core/src/main/java/org/apache/ignite/cluster/ClusterTopologyException.java +++ b/modules/core/src/main/java/org/apache/ignite/cluster/ClusterTopologyException.java @@ -17,9 +17,9 @@ package org.apache.ignite.cluster; -import org.apache.ignite.*; -import org.apache.ignite.lang.*; -import org.jetbrains.annotations.*; +import org.apache.ignite.IgniteException; +import org.apache.ignite.lang.IgniteFuture; +import org.jetbrains.annotations.Nullable; /** * This exception is used to indicate error with the cluster topology (e.g., crashed node, etc.). @@ -64,4 +64,4 @@ public class ClusterTopologyException extends IgniteException { public void retryReadyFuture(IgniteFuture<?> readyFut) { this.readyFut = readyFut; } -} +} \ 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/compute/ComputeExecutionRejectedException.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/compute/ComputeExecutionRejectedException.java b/modules/core/src/main/java/org/apache/ignite/compute/ComputeExecutionRejectedException.java index 4d504bc..0b98e41 100644 --- a/modules/core/src/main/java/org/apache/ignite/compute/ComputeExecutionRejectedException.java +++ b/modules/core/src/main/java/org/apache/ignite/compute/ComputeExecutionRejectedException.java @@ -17,8 +17,8 @@ package org.apache.ignite.compute; -import org.apache.ignite.*; -import org.jetbrains.annotations.*; +import org.apache.ignite.IgniteException; +import org.jetbrains.annotations.Nullable; /** * This exception defines execution rejection. This exception is used to indicate @@ -59,4 +59,4 @@ public class ComputeExecutionRejectedException extends IgniteException { public ComputeExecutionRejectedException(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/compute/ComputeJob.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/compute/ComputeJob.java b/modules/core/src/main/java/org/apache/ignite/compute/ComputeJob.java index ae52912..d8664e8 100644 --- a/modules/core/src/main/java/org/apache/ignite/compute/ComputeJob.java +++ b/modules/core/src/main/java/org/apache/ignite/compute/ComputeJob.java @@ -17,10 +17,10 @@ package org.apache.ignite.compute; -import org.apache.ignite.*; - -import java.io.*; -import java.util.*; +import java.io.Serializable; +import java.util.List; +import org.apache.ignite.IgniteCheckedException; +import org.apache.ignite.IgniteException; /** * Defines executable unit for {@link ComputeTask}. @@ -160,4 +160,4 @@ public interface ComputeJob extends Serializable { * it will be wrapped into {@link IgniteCheckedException}. */ public Object execute() throws IgniteException; -} +} \ 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/compute/ComputeJobAdapter.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/compute/ComputeJobAdapter.java b/modules/core/src/main/java/org/apache/ignite/compute/ComputeJobAdapter.java index 80841ba..43465a6 100644 --- a/modules/core/src/main/java/org/apache/ignite/compute/ComputeJobAdapter.java +++ b/modules/core/src/main/java/org/apache/ignite/compute/ComputeJobAdapter.java @@ -17,10 +17,9 @@ package org.apache.ignite.compute; -import org.apache.ignite.internal.util.typedef.internal.*; -import org.jetbrains.annotations.*; - -import java.util.concurrent.*; +import java.util.concurrent.Callable; +import org.apache.ignite.internal.util.typedef.internal.A; +import org.jetbrains.annotations.Nullable; /** * Convenience adapter for {@link ComputeJob} implementations. It provides the @@ -132,4 +131,4 @@ public abstract class ComputeJobAdapter implements ComputeJob, Callable<Object> @Override public final Object call() { return execute(); } -} +} \ 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/compute/ComputeJobAfterSend.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/compute/ComputeJobAfterSend.java b/modules/core/src/main/java/org/apache/ignite/compute/ComputeJobAfterSend.java index cfba2c4..f81e969 100644 --- a/modules/core/src/main/java/org/apache/ignite/compute/ComputeJobAfterSend.java +++ b/modules/core/src/main/java/org/apache/ignite/compute/ComputeJobAfterSend.java @@ -17,7 +17,11 @@ package org.apache.ignite.compute; -import java.lang.annotation.*; +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; /** * This annotation allows to call a method right after the job has been @@ -44,4 +48,4 @@ import java.lang.annotation.*; @Target({ElementType.METHOD}) public @interface ComputeJobAfterSend { // 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/compute/ComputeJobBeforeFailover.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/compute/ComputeJobBeforeFailover.java b/modules/core/src/main/java/org/apache/ignite/compute/ComputeJobBeforeFailover.java index 3cc5c23..7ae6455 100644 --- a/modules/core/src/main/java/org/apache/ignite/compute/ComputeJobBeforeFailover.java +++ b/modules/core/src/main/java/org/apache/ignite/compute/ComputeJobBeforeFailover.java @@ -17,7 +17,11 @@ package org.apache.ignite.compute; -import java.lang.annotation.*; +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; /** * This annotation allows to call a method right before job is submitted to @@ -45,4 +49,4 @@ import java.lang.annotation.*; @Target({ElementType.METHOD}) public @interface ComputeJobBeforeFailover { // 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/compute/ComputeJobContext.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/compute/ComputeJobContext.java b/modules/core/src/main/java/org/apache/ignite/compute/ComputeJobContext.java index 81fd8e1..086356a 100644 --- a/modules/core/src/main/java/org/apache/ignite/compute/ComputeJobContext.java +++ b/modules/core/src/main/java/org/apache/ignite/compute/ComputeJobContext.java @@ -17,10 +17,10 @@ package org.apache.ignite.compute; -import org.apache.ignite.lang.*; -import org.jetbrains.annotations.*; - -import java.util.*; +import java.util.List; +import java.util.Map; +import org.apache.ignite.lang.IgniteUuid; +import org.jetbrains.annotations.Nullable; /** * Context attached to every job executed on the grid. Note that unlike @@ -94,4 +94,4 @@ public interface ComputeJobContext extends ComputeJobContinuation { * @return All attributes. */ public Map<?, ?> getAttributes(); -} +} \ 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/compute/ComputeJobContinuation.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/compute/ComputeJobContinuation.java b/modules/core/src/main/java/org/apache/ignite/compute/ComputeJobContinuation.java index cd91e2c..b8b362d 100644 --- a/modules/core/src/main/java/org/apache/ignite/compute/ComputeJobContinuation.java +++ b/modules/core/src/main/java/org/apache/ignite/compute/ComputeJobContinuation.java @@ -17,7 +17,7 @@ package org.apache.ignite.compute; -import org.jetbrains.annotations.*; +import org.jetbrains.annotations.Nullable; /** * Defines continuation support for grid job context. @@ -90,4 +90,4 @@ public interface ComputeJobContinuation { * abbreviated as {@code 'call/cc'}, which originated in Scheme programming language. */ public void callcc(); -} +} \ 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/compute/ComputeJobContinuationAdapter.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/compute/ComputeJobContinuationAdapter.java b/modules/core/src/main/java/org/apache/ignite/compute/ComputeJobContinuationAdapter.java index 08bd354..936c9c7 100644 --- a/modules/core/src/main/java/org/apache/ignite/compute/ComputeJobContinuationAdapter.java +++ b/modules/core/src/main/java/org/apache/ignite/compute/ComputeJobContinuationAdapter.java @@ -17,8 +17,8 @@ package org.apache.ignite.compute; -import org.apache.ignite.resources.*; -import org.jetbrains.annotations.*; +import org.apache.ignite.resources.JobContextResource; +import org.jetbrains.annotations.Nullable; /** * Convenience adapter for {@link ComputeJob} implementations. It provides the @@ -128,4 +128,4 @@ public abstract class ComputeJobContinuationAdapter extends ComputeJobAdapter im @Nullable @Override public <T> T holdcc(long timeout) { return jobCtx == null ? null : jobCtx.<T>holdcc(timeout); } -} +} \ 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/compute/ComputeJobFailoverException.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/compute/ComputeJobFailoverException.java b/modules/core/src/main/java/org/apache/ignite/compute/ComputeJobFailoverException.java index 70dfc13..9f2c034 100644 --- a/modules/core/src/main/java/org/apache/ignite/compute/ComputeJobFailoverException.java +++ b/modules/core/src/main/java/org/apache/ignite/compute/ComputeJobFailoverException.java @@ -17,11 +17,11 @@ package org.apache.ignite.compute; -import org.apache.ignite.*; -import org.apache.ignite.lang.*; -import org.jetbrains.annotations.*; - -import java.util.concurrent.*; +import java.util.concurrent.Callable; +import org.apache.ignite.IgniteCompute; +import org.apache.ignite.IgniteException; +import org.apache.ignite.lang.IgniteClosure; +import org.jetbrains.annotations.Nullable; /** * This runtime exception can be thrown from {@link ComputeJob#execute()} method to force @@ -62,4 +62,4 @@ public class ComputeJobFailoverException extends IgniteException { public ComputeJobFailoverException(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/compute/ComputeJobMasterLeaveAware.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/compute/ComputeJobMasterLeaveAware.java b/modules/core/src/main/java/org/apache/ignite/compute/ComputeJobMasterLeaveAware.java index 63583b3..4c89e63 100644 --- a/modules/core/src/main/java/org/apache/ignite/compute/ComputeJobMasterLeaveAware.java +++ b/modules/core/src/main/java/org/apache/ignite/compute/ComputeJobMasterLeaveAware.java @@ -17,7 +17,7 @@ package org.apache.ignite.compute; -import org.apache.ignite.*; +import org.apache.ignite.IgniteException; /** * Annotation for handling master node leave during job execution. @@ -37,4 +37,4 @@ public interface ComputeJobMasterLeaveAware { * @throws IgniteException In case of any exception. */ public void onMasterNodeLeft(ComputeTaskSession ses) throws IgniteException; -} +} \ 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/compute/ComputeJobResult.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/compute/ComputeJobResult.java b/modules/core/src/main/java/org/apache/ignite/compute/ComputeJobResult.java index 6138ad7..3e37279 100644 --- a/modules/core/src/main/java/org/apache/ignite/compute/ComputeJobResult.java +++ b/modules/core/src/main/java/org/apache/ignite/compute/ComputeJobResult.java @@ -17,10 +17,10 @@ package org.apache.ignite.compute; -import org.apache.ignite.*; -import org.apache.ignite.cluster.*; - -import java.util.*; +import java.util.List; +import org.apache.ignite.IgniteException; +import org.apache.ignite.cluster.ClusterNode; +import org.apache.ignite.cluster.ClusterTopologyException; /** * Result of remote job which gets passed into {@link ComputeTask#result(ComputeJobResult, List)} @@ -100,4 +100,4 @@ public interface ComputeJobResult { * @return {@code true} if job received cancellation request and {@code false} otherwise. */ public boolean isCancelled(); -} +} \ 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/compute/ComputeJobResultPolicy.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/compute/ComputeJobResultPolicy.java b/modules/core/src/main/java/org/apache/ignite/compute/ComputeJobResultPolicy.java index 26eb542..74c17e4 100644 --- a/modules/core/src/main/java/org/apache/ignite/compute/ComputeJobResultPolicy.java +++ b/modules/core/src/main/java/org/apache/ignite/compute/ComputeJobResultPolicy.java @@ -17,9 +17,8 @@ package org.apache.ignite.compute; -import org.jetbrains.annotations.*; - -import java.util.*; +import java.util.List; +import org.jetbrains.annotations.Nullable; /** * This enumeration provides different types of actions following the last @@ -53,4 +52,4 @@ public enum ComputeJobResultPolicy { @Nullable public static ComputeJobResultPolicy 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/compute/ComputeJobSibling.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/compute/ComputeJobSibling.java b/modules/core/src/main/java/org/apache/ignite/compute/ComputeJobSibling.java index 1071350..b7e2068 100644 --- a/modules/core/src/main/java/org/apache/ignite/compute/ComputeJobSibling.java +++ b/modules/core/src/main/java/org/apache/ignite/compute/ComputeJobSibling.java @@ -17,10 +17,9 @@ package org.apache.ignite.compute; -import org.apache.ignite.*; -import org.apache.ignite.lang.*; - -import java.util.*; +import java.util.List; +import org.apache.ignite.IgniteException; +import org.apache.ignite.lang.IgniteUuid; /** * Job sibling interface defines a job from the same split. In other words a sibling is a job returned @@ -42,4 +41,4 @@ public interface ComputeJobSibling { * @throws IgniteException If cancellation message could not be sent. */ public void cancel() throws IgniteException; -} +} \ 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/compute/ComputeLoadBalancer.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/compute/ComputeLoadBalancer.java b/modules/core/src/main/java/org/apache/ignite/compute/ComputeLoadBalancer.java index d9f2e21..356e5a6 100644 --- a/modules/core/src/main/java/org/apache/ignite/compute/ComputeLoadBalancer.java +++ b/modules/core/src/main/java/org/apache/ignite/compute/ComputeLoadBalancer.java @@ -17,11 +17,11 @@ package org.apache.ignite.compute; -import org.apache.ignite.*; -import org.apache.ignite.cluster.*; -import org.jetbrains.annotations.*; - -import java.util.*; +import java.util.Collection; +import java.util.List; +import org.apache.ignite.IgniteException; +import org.apache.ignite.cluster.ClusterNode; +import org.jetbrains.annotations.Nullable; /** * Load balancer is used for finding the best balanced node according @@ -112,4 +112,4 @@ public interface ComputeLoadBalancer { */ @Nullable public ClusterNode getBalancedNode(ComputeJob job, @Nullable Collection<ClusterNode> exclNodes) throws IgniteException; -} +} \ 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/compute/ComputeTask.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/compute/ComputeTask.java b/modules/core/src/main/java/org/apache/ignite/compute/ComputeTask.java index 9b870a5..d24bf00 100644 --- a/modules/core/src/main/java/org/apache/ignite/compute/ComputeTask.java +++ b/modules/core/src/main/java/org/apache/ignite/compute/ComputeTask.java @@ -17,12 +17,12 @@ package org.apache.ignite.compute; -import org.apache.ignite.*; -import org.apache.ignite.cluster.*; -import org.jetbrains.annotations.*; - -import java.io.*; -import java.util.*; +import java.io.Serializable; +import java.util.List; +import java.util.Map; +import org.apache.ignite.IgniteException; +import org.apache.ignite.cluster.ClusterNode; +import org.jetbrains.annotations.Nullable; /** * Grid task interface defines a task that can be executed on the grid. Grid task @@ -278,4 +278,4 @@ public interface ComputeTask<T, R> extends Serializable { * be thrown out of {@link ComputeTaskFuture#get()} method. */ @Nullable public R reduce(List<ComputeJobResult> results) throws IgniteException; -} +} \ 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/compute/ComputeTaskAdapter.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/compute/ComputeTaskAdapter.java b/modules/core/src/main/java/org/apache/ignite/compute/ComputeTaskAdapter.java index c2ad198..2de0794 100644 --- a/modules/core/src/main/java/org/apache/ignite/compute/ComputeTaskAdapter.java +++ b/modules/core/src/main/java/org/apache/ignite/compute/ComputeTaskAdapter.java @@ -17,10 +17,9 @@ package org.apache.ignite.compute; -import org.apache.ignite.*; -import org.apache.ignite.cluster.*; - -import java.util.*; +import java.util.List; +import org.apache.ignite.IgniteException; +import org.apache.ignite.cluster.ClusterTopologyException; /** * Convenience adapter for {@link ComputeTask} interface. Here is an example of @@ -106,4 +105,4 @@ public abstract class ComputeTaskAdapter<T, R> implements ComputeTask<T, R> { // Wait for all job responses. return ComputeJobResultPolicy.WAIT; } -} +} \ 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/compute/ComputeTaskCancelledException.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/compute/ComputeTaskCancelledException.java b/modules/core/src/main/java/org/apache/ignite/compute/ComputeTaskCancelledException.java index 965e564..8e5981d 100644 --- a/modules/core/src/main/java/org/apache/ignite/compute/ComputeTaskCancelledException.java +++ b/modules/core/src/main/java/org/apache/ignite/compute/ComputeTaskCancelledException.java @@ -17,8 +17,8 @@ package org.apache.ignite.compute; -import org.apache.ignite.*; -import org.jetbrains.annotations.*; +import org.apache.ignite.IgniteException; +import org.jetbrains.annotations.Nullable; /** * This exception indicates that grid task was cancelled. @@ -55,4 +55,4 @@ public class ComputeTaskCancelledException extends IgniteException { public ComputeTaskCancelledException(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/compute/ComputeTaskContinuousMapper.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/compute/ComputeTaskContinuousMapper.java b/modules/core/src/main/java/org/apache/ignite/compute/ComputeTaskContinuousMapper.java index 3a4cb91..be32be8 100644 --- a/modules/core/src/main/java/org/apache/ignite/compute/ComputeTaskContinuousMapper.java +++ b/modules/core/src/main/java/org/apache/ignite/compute/ComputeTaskContinuousMapper.java @@ -17,10 +17,11 @@ package org.apache.ignite.compute; -import org.apache.ignite.*; -import org.apache.ignite.cluster.*; - -import java.util.*; +import java.util.Collection; +import java.util.List; +import java.util.Map; +import org.apache.ignite.IgniteException; +import org.apache.ignite.cluster.ClusterNode; /** * Defines a mapper that can be used for asynchronous job sending. Useful for @@ -96,4 +97,4 @@ public interface ComputeTaskContinuousMapper { * @throws IgniteException If job can not be processed. */ public void send(Collection<? extends ComputeJob> jobs) throws IgniteException; -} +} \ 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/compute/ComputeTaskFuture.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/compute/ComputeTaskFuture.java b/modules/core/src/main/java/org/apache/ignite/compute/ComputeTaskFuture.java index d5401fa..e30ab90 100644 --- a/modules/core/src/main/java/org/apache/ignite/compute/ComputeTaskFuture.java +++ b/modules/core/src/main/java/org/apache/ignite/compute/ComputeTaskFuture.java @@ -17,10 +17,10 @@ package org.apache.ignite.compute; -import org.apache.ignite.lang.*; - -import java.util.*; -import java.util.concurrent.*; +import java.util.List; +import java.util.concurrent.Future; +import java.util.concurrent.TimeUnit; +import org.apache.ignite.lang.IgniteFuture; /** * This class defines a handler for asynchronous task execution. It's similar in design @@ -49,4 +49,4 @@ public interface ComputeTaskFuture<R> extends IgniteFuture<R> { * @return Task session. */ public ComputeTaskSession getTaskSession(); -} +} \ 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/compute/ComputeTaskMapAsync.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/compute/ComputeTaskMapAsync.java b/modules/core/src/main/java/org/apache/ignite/compute/ComputeTaskMapAsync.java index d0be930..71cf2b6 100644 --- a/modules/core/src/main/java/org/apache/ignite/compute/ComputeTaskMapAsync.java +++ b/modules/core/src/main/java/org/apache/ignite/compute/ComputeTaskMapAsync.java @@ -17,8 +17,12 @@ package org.apache.ignite.compute; -import java.lang.annotation.*; -import java.util.*; +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.List; /** * Annotation for asynchronous task mapping. @@ -34,4 +38,4 @@ import java.util.*; @Target({ElementType.TYPE}) public @interface ComputeTaskMapAsync { // 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/compute/ComputeTaskName.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/compute/ComputeTaskName.java b/modules/core/src/main/java/org/apache/ignite/compute/ComputeTaskName.java index 654118a..7f45155 100644 --- a/modules/core/src/main/java/org/apache/ignite/compute/ComputeTaskName.java +++ b/modules/core/src/main/java/org/apache/ignite/compute/ComputeTaskName.java @@ -17,7 +17,11 @@ package org.apache.ignite.compute; -import java.lang.annotation.*; +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; /** * This annotation allows to assign optional name to grid task. If attached to @@ -32,4 +36,4 @@ public @interface ComputeTaskName { * Optional task name. */ @SuppressWarnings({"JavaDoc"}) String value(); -} +} \ 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/compute/ComputeTaskNoResultCache.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/compute/ComputeTaskNoResultCache.java b/modules/core/src/main/java/org/apache/ignite/compute/ComputeTaskNoResultCache.java index 35f611a..bbd0ff4 100644 --- a/modules/core/src/main/java/org/apache/ignite/compute/ComputeTaskNoResultCache.java +++ b/modules/core/src/main/java/org/apache/ignite/compute/ComputeTaskNoResultCache.java @@ -17,8 +17,12 @@ package org.apache.ignite.compute; -import java.lang.annotation.*; -import java.util.*; +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.List; /** * This annotation disables caching of task results when attached to {@link ComputeTask} class @@ -48,4 +52,4 @@ import java.util.*; @Target({ElementType.TYPE}) public @interface ComputeTaskNoResultCache { // 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/compute/ComputeTaskSession.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/compute/ComputeTaskSession.java b/modules/core/src/main/java/org/apache/ignite/compute/ComputeTaskSession.java index f6452e5..d6ebe15 100644 --- a/modules/core/src/main/java/org/apache/ignite/compute/ComputeTaskSession.java +++ b/modules/core/src/main/java/org/apache/ignite/compute/ComputeTaskSession.java @@ -17,11 +17,14 @@ package org.apache.ignite.compute; -import org.apache.ignite.*; -import org.apache.ignite.lang.*; -import org.jetbrains.annotations.*; - -import java.util.*; +import java.util.Collection; +import java.util.List; +import java.util.Map; +import java.util.UUID; +import org.apache.ignite.IgniteException; +import org.apache.ignite.lang.IgniteFuture; +import org.apache.ignite.lang.IgniteUuid; +import org.jetbrains.annotations.Nullable; /** * Defines a distributed session for particular task execution. @@ -437,4 +440,4 @@ public interface ComputeTaskSession { * @return Future that will be completed when task "<tt>map</tt>" step has completed. */ public IgniteFuture<?> mapFuture(); -} +} \ 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/compute/ComputeTaskSessionAttributeListener.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/compute/ComputeTaskSessionAttributeListener.java b/modules/core/src/main/java/org/apache/ignite/compute/ComputeTaskSessionAttributeListener.java index d0a0866..9e664a8 100644 --- a/modules/core/src/main/java/org/apache/ignite/compute/ComputeTaskSessionAttributeListener.java +++ b/modules/core/src/main/java/org/apache/ignite/compute/ComputeTaskSessionAttributeListener.java @@ -17,7 +17,7 @@ package org.apache.ignite.compute; -import java.util.*; +import java.util.EventListener; /** * This interface defines listener for task session attributes. @@ -30,4 +30,4 @@ public interface ComputeTaskSessionAttributeListener extends EventListener { * @param val Attribute value. */ public void onAttributeSet(Object key, Object 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/compute/ComputeTaskSessionFullSupport.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/compute/ComputeTaskSessionFullSupport.java b/modules/core/src/main/java/org/apache/ignite/compute/ComputeTaskSessionFullSupport.java index 340d65d..e04c312 100644 --- a/modules/core/src/main/java/org/apache/ignite/compute/ComputeTaskSessionFullSupport.java +++ b/modules/core/src/main/java/org/apache/ignite/compute/ComputeTaskSessionFullSupport.java @@ -17,8 +17,12 @@ package org.apache.ignite.compute; -import java.lang.annotation.*; -import java.util.*; +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.Map; /** * Annotation for enabling task session attributes and checkpoints for tasks. @@ -42,4 +46,4 @@ import java.util.*; @Target({ElementType.TYPE}) public @interface ComputeTaskSessionFullSupport { // 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/compute/ComputeTaskSessionScope.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/compute/ComputeTaskSessionScope.java b/modules/core/src/main/java/org/apache/ignite/compute/ComputeTaskSessionScope.java index bc1928b..bb1f142 100644 --- a/modules/core/src/main/java/org/apache/ignite/compute/ComputeTaskSessionScope.java +++ b/modules/core/src/main/java/org/apache/ignite/compute/ComputeTaskSessionScope.java @@ -17,7 +17,7 @@ package org.apache.ignite.compute; -import org.jetbrains.annotations.*; +import org.jetbrains.annotations.Nullable; /** * Defines life-time scopes for checkpoint operations. Such operations include: @@ -56,4 +56,4 @@ public enum ComputeTaskSessionScope { @Nullable public static ComputeTaskSessionScope 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/compute/ComputeTaskSpis.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/compute/ComputeTaskSpis.java b/modules/core/src/main/java/org/apache/ignite/compute/ComputeTaskSpis.java index 32206f5..5edd464 100644 --- a/modules/core/src/main/java/org/apache/ignite/compute/ComputeTaskSpis.java +++ b/modules/core/src/main/java/org/apache/ignite/compute/ComputeTaskSpis.java @@ -17,7 +17,11 @@ package org.apache.ignite.compute; -import java.lang.annotation.*; +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; /** * This annotation allows task to specify what SPIs it wants to use. @@ -52,4 +56,4 @@ public @interface ComputeTaskSpis { * supplying {@link org.apache.ignite.spi.IgniteSpi#getName()} parameter in grid configuration. */ public String checkpointSpi() default ""; -} +} \ 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/compute/ComputeTaskSplitAdapter.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/compute/ComputeTaskSplitAdapter.java b/modules/core/src/main/java/org/apache/ignite/compute/ComputeTaskSplitAdapter.java index 7b3b0d6..0b62519 100644 --- a/modules/core/src/main/java/org/apache/ignite/compute/ComputeTaskSplitAdapter.java +++ b/modules/core/src/main/java/org/apache/ignite/compute/ComputeTaskSplitAdapter.java @@ -17,13 +17,14 @@ package org.apache.ignite.compute; -import org.apache.ignite.*; -import org.apache.ignite.cluster.*; -import org.apache.ignite.internal.util.typedef.*; -import org.apache.ignite.internal.util.typedef.internal.*; -import org.apache.ignite.resources.*; - -import java.util.*; +import java.util.Collection; +import java.util.List; +import java.util.Map; +import org.apache.ignite.IgniteException; +import org.apache.ignite.cluster.ClusterNode; +import org.apache.ignite.internal.util.typedef.F; +import org.apache.ignite.internal.util.typedef.internal.U; +import org.apache.ignite.resources.LoadBalancerResource; /** * This class defines simplified adapter for {@link ComputeTask}. This adapter can be used @@ -119,4 +120,4 @@ public abstract class ComputeTaskSplitAdapter<T, R> extends ComputeTaskAdapter<T return map; } -} +} \ 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/compute/ComputeTaskTimeoutException.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/compute/ComputeTaskTimeoutException.java b/modules/core/src/main/java/org/apache/ignite/compute/ComputeTaskTimeoutException.java index b09f09f..7f01d89 100644 --- a/modules/core/src/main/java/org/apache/ignite/compute/ComputeTaskTimeoutException.java +++ b/modules/core/src/main/java/org/apache/ignite/compute/ComputeTaskTimeoutException.java @@ -17,8 +17,8 @@ package org.apache.ignite.compute; -import org.apache.ignite.*; -import org.jetbrains.annotations.*; +import org.apache.ignite.IgniteException; +import org.jetbrains.annotations.Nullable; /** * This exception indicates that task execution timed out. It is thrown from @@ -58,4 +58,4 @@ public class ComputeTaskTimeoutException extends IgniteException { public ComputeTaskTimeoutException(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/compute/ComputeUserUndeclaredException.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/compute/ComputeUserUndeclaredException.java b/modules/core/src/main/java/org/apache/ignite/compute/ComputeUserUndeclaredException.java index 542762a..f10eae5 100644 --- a/modules/core/src/main/java/org/apache/ignite/compute/ComputeUserUndeclaredException.java +++ b/modules/core/src/main/java/org/apache/ignite/compute/ComputeUserUndeclaredException.java @@ -17,8 +17,8 @@ package org.apache.ignite.compute; -import org.apache.ignite.*; -import org.jetbrains.annotations.*; +import org.apache.ignite.IgniteException; +import org.jetbrains.annotations.Nullable; /** * This exception is thrown when user's code throws undeclared runtime exception. By user code it is @@ -59,4 +59,4 @@ public class ComputeUserUndeclaredException extends IgniteException { public ComputeUserUndeclaredException(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/compute/gridify/Gridify.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/compute/gridify/Gridify.java b/modules/core/src/main/java/org/apache/ignite/compute/gridify/Gridify.java index d394dd1..f7d96e0 100644 --- a/modules/core/src/main/java/org/apache/ignite/compute/gridify/Gridify.java +++ b/modules/core/src/main/java/org/apache/ignite/compute/gridify/Gridify.java @@ -17,11 +17,14 @@ package org.apache.ignite.compute.gridify; -import org.apache.ignite.compute.*; -import org.apache.ignite.compute.gridify.aop.*; - -import java.io.*; -import java.lang.annotation.*; +import java.io.Serializable; +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 org.apache.ignite.compute.ComputeTask; +import org.apache.ignite.compute.gridify.aop.GridifyDefaultTask; /** * {@code Gridify} annotation is the main way to grid-enable existing code. @@ -184,4 +187,4 @@ public @interface Gridify { */ @SuppressWarnings({"JavaDoc"}) String gridName() default ""; -} +} \ 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/compute/gridify/GridifyArgument.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/compute/gridify/GridifyArgument.java b/modules/core/src/main/java/org/apache/ignite/compute/gridify/GridifyArgument.java index 19a5abb..384891e 100644 --- a/modules/core/src/main/java/org/apache/ignite/compute/gridify/GridifyArgument.java +++ b/modules/core/src/main/java/org/apache/ignite/compute/gridify/GridifyArgument.java @@ -17,7 +17,7 @@ package org.apache.ignite.compute.gridify; -import java.io.*; +import java.io.Serializable; /** * Gridify task argument created by the system for task execution. It contains @@ -68,4 +68,4 @@ public interface GridifyArgument extends Serializable { * object creation. */ public Object getTarget(); -} +} \ 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/compute/gridify/GridifyInput.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/compute/gridify/GridifyInput.java b/modules/core/src/main/java/org/apache/ignite/compute/gridify/GridifyInput.java index 3d9ba04..cc935b6 100644 --- a/modules/core/src/main/java/org/apache/ignite/compute/gridify/GridifyInput.java +++ b/modules/core/src/main/java/org/apache/ignite/compute/gridify/GridifyInput.java @@ -17,7 +17,11 @@ package org.apache.ignite.compute.gridify; -import java.lang.annotation.*; +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; /** * This annotation can be applied to method parameter for grid-enabled method. This annotation can be used @@ -42,4 +46,4 @@ import java.lang.annotation.*; @Target({ElementType.PARAMETER}) public @interface GridifyInput { // 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/compute/gridify/GridifyInterceptor.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/compute/gridify/GridifyInterceptor.java b/modules/core/src/main/java/org/apache/ignite/compute/gridify/GridifyInterceptor.java index 015c760..33ec08e 100644 --- a/modules/core/src/main/java/org/apache/ignite/compute/gridify/GridifyInterceptor.java +++ b/modules/core/src/main/java/org/apache/ignite/compute/gridify/GridifyInterceptor.java @@ -17,9 +17,8 @@ package org.apache.ignite.compute.gridify; -import org.apache.ignite.*; - -import java.lang.annotation.*; +import java.lang.annotation.Annotation; +import org.apache.ignite.IgniteCheckedException; /** * This interface defines an interceptor apply for {@link Gridify} annotation. Interceptor @@ -39,4 +38,4 @@ public interface GridifyInterceptor { * @throws IgniteCheckedException Thrown in case of any errors. */ public boolean isGridify(Annotation gridify, GridifyArgument arg) throws IgniteCheckedException; -} +} \ 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/compute/gridify/GridifyNodeFilter.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/compute/gridify/GridifyNodeFilter.java b/modules/core/src/main/java/org/apache/ignite/compute/gridify/GridifyNodeFilter.java index d4654bb..27864a1 100644 --- a/modules/core/src/main/java/org/apache/ignite/compute/gridify/GridifyNodeFilter.java +++ b/modules/core/src/main/java/org/apache/ignite/compute/gridify/GridifyNodeFilter.java @@ -17,13 +17,13 @@ package org.apache.ignite.compute.gridify; -import org.apache.ignite.cluster.*; -import org.apache.ignite.compute.*; -import org.apache.ignite.lang.*; +import org.apache.ignite.cluster.ClusterNode; +import org.apache.ignite.compute.ComputeTaskSession; +import org.apache.ignite.lang.IgniteBiPredicate; /** * Predicate node filter. */ public interface GridifyNodeFilter extends IgniteBiPredicate<ClusterNode, ComputeTaskSession> { // 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/compute/gridify/GridifyRuntimeException.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/compute/gridify/GridifyRuntimeException.java b/modules/core/src/main/java/org/apache/ignite/compute/gridify/GridifyRuntimeException.java index 2f2259e..d138397 100644 --- a/modules/core/src/main/java/org/apache/ignite/compute/gridify/GridifyRuntimeException.java +++ b/modules/core/src/main/java/org/apache/ignite/compute/gridify/GridifyRuntimeException.java @@ -17,7 +17,7 @@ package org.apache.ignite.compute.gridify; -import org.apache.ignite.*; +import org.apache.ignite.IgniteException; /** * This defines gridify exception. This runtime exception gets thrown out of gridified @@ -55,4 +55,4 @@ public class GridifyRuntimeException extends IgniteException { public GridifyRuntimeException(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/compute/gridify/GridifySetToSet.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/compute/gridify/GridifySetToSet.java b/modules/core/src/main/java/org/apache/ignite/compute/gridify/GridifySetToSet.java index f5e4d6f..9b57c43 100644 --- a/modules/core/src/main/java/org/apache/ignite/compute/gridify/GridifySetToSet.java +++ b/modules/core/src/main/java/org/apache/ignite/compute/gridify/GridifySetToSet.java @@ -17,8 +17,12 @@ package org.apache.ignite.compute.gridify; -import java.io.*; -import java.lang.annotation.*; +import java.io.Serializable; +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; /** * {@code GridifySetToSet} annotation allows to grid-enable existing code with specific semantics. @@ -196,4 +200,4 @@ public @interface GridifySetToSet { * Refer to {@link org.apache.ignite.Ignition} for information about named grids. */ String gridName() default ""; -} +} \ No newline at end of file
