http://git-wip-us.apache.org/repos/asf/ignite/blob/8f52344b/modules/core/src/main/java/org/apache/ignite/internal/processors/datastructures/GridCacheQueueAdapter.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/datastructures/GridCacheQueueAdapter.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/datastructures/GridCacheQueueAdapter.java index e42c00b..6505624 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/datastructures/GridCacheQueueAdapter.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/datastructures/GridCacheQueueAdapter.java @@ -406,7 +406,7 @@ public abstract class GridCacheQueueAdapter<T> extends AbstractCollection<T> imp } /** {@inheritDoc} */ - public void affinityRun(IgniteRunnable job) { + @Override public void affinityRun(IgniteRunnable job) { if (!collocated) throw new IgniteException("Failed to execute affinityRun() for non-collocated queue: " + name() + ". This operation is supported only for collocated queues."); @@ -415,7 +415,7 @@ public abstract class GridCacheQueueAdapter<T> extends AbstractCollection<T> imp } /** {@inheritDoc} */ - public <R> R affinityCall(IgniteCallable<R> job) { + @Override public <R> R affinityCall(IgniteCallable<R> job) { if (!collocated) throw new IgniteException("Failed to execute affinityCall() for non-collocated queue: " + name() + ". This operation is supported only for collocated queues.");
http://git-wip-us.apache.org/repos/asf/ignite/blob/8f52344b/modules/core/src/main/java/org/apache/ignite/internal/processors/hadoop/HadoopFileBlock.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/hadoop/HadoopFileBlock.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/hadoop/HadoopFileBlock.java index 351abce..978bf20 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/hadoop/HadoopFileBlock.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/hadoop/HadoopFileBlock.java @@ -159,7 +159,7 @@ public class HadoopFileBlock extends HadoopInputSplit { } /** {@inheritDoc} */ - public String toString() { + @Override public String toString() { return S.toString(HadoopFileBlock.class, this, "hosts", Arrays.toString(hosts)); } } \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/8f52344b/modules/core/src/main/java/org/apache/ignite/internal/processors/hadoop/HadoopJobEx.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/hadoop/HadoopJobEx.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/hadoop/HadoopJobEx.java index ba78af9..46606da 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/hadoop/HadoopJobEx.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/hadoop/HadoopJobEx.java @@ -47,7 +47,7 @@ public abstract class HadoopJobEx implements HadoopJob { * * @return Input splits. */ - abstract public Collection<HadoopInputSplit> input(); + @Override abstract public Collection<HadoopInputSplit> input(); /** * Returns context for task execution. http://git-wip-us.apache.org/repos/asf/ignite/blob/8f52344b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsDirectoryInfo.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsDirectoryInfo.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsDirectoryInfo.java index 269098b..26979e5 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsDirectoryInfo.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsDirectoryInfo.java @@ -62,7 +62,7 @@ public class IgfsDirectoryInfo extends IgfsEntryInfo implements Binarylizable { * @param len New length. * @return Updated file info. */ - public IgfsEntryInfo length(long len) { + @Override public IgfsEntryInfo length(long len) { throw new UnsupportedOperationException("length"); } @@ -107,47 +107,47 @@ public class IgfsDirectoryInfo extends IgfsEntryInfo implements Binarylizable { } /** {@inheritDoc} */ - protected IgfsDirectoryInfo copy() { + @Override protected IgfsDirectoryInfo copy() { return new IgfsDirectoryInfo(id, listing, props, accessTime, modificationTime); } /** {@inheritDoc} */ - public boolean isFile() { + @Override public boolean isFile() { return false; } /** {@inheritDoc} */ - public long length() { + @Override public long length() { return 0; } /** {@inheritDoc} */ - public int blockSize() { + @Override public int blockSize() { return 0; } /** {@inheritDoc} */ - public long blocksCount() { + @Override public long blocksCount() { return 0; } /** {@inheritDoc} */ - public Map<String, IgfsListingEntry> listing() { + @Override public Map<String, IgfsListingEntry> listing() { return listing != null ? listing : Collections.<String, IgfsListingEntry>emptyMap(); } /** {@inheritDoc} */ - public boolean hasChildren() { + @Override public boolean hasChildren() { return !F.isEmpty(listing); } /** {@inheritDoc} */ - public boolean hasChild(String name) { + @Override public boolean hasChild(String name) { return listing != null && listing.containsKey(name); } /** {@inheritDoc} */ - public boolean hasChild(String name, IgniteUuid expId) { + @Override public boolean hasChild(String name, IgniteUuid expId) { if (listing != null) { IgfsListingEntry entry = listing.get(name); @@ -159,22 +159,22 @@ public class IgfsDirectoryInfo extends IgfsEntryInfo implements Binarylizable { } /** {@inheritDoc} */ - @Nullable public IgniteUuid affinityKey() { + @Override @Nullable public IgniteUuid affinityKey() { return null; } /** {@inheritDoc} */ - public IgfsFileMap fileMap() { + @Override public IgfsFileMap fileMap() { return null; } /** {@inheritDoc} */ - @Nullable public IgniteUuid lockId() { + @Override @Nullable public IgniteUuid lockId() { return null; } /** {@inheritDoc} */ - public boolean evictExclude() { + @Override public boolean evictExclude() { return true; } http://git-wip-us.apache.org/repos/asf/ignite/blob/8f52344b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsFileInfo.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsFileInfo.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsFileInfo.java index 337f281..3db3c87 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsFileInfo.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsFileInfo.java @@ -152,62 +152,62 @@ public final class IgfsFileInfo extends IgfsEntryInfo implements Binarylizable { } /** {@inheritDoc} */ - public boolean isFile() { + @Override public boolean isFile() { return true; } /** {@inheritDoc} */ - public long length() { + @Override public long length() { return len; } /** {@inheritDoc} */ - public int blockSize() { + @Override public int blockSize() { return blockSize; } /** {@inheritDoc} */ - public long blocksCount() { + @Override public long blocksCount() { return (len + blockSize() - 1) / blockSize(); } /** {@inheritDoc} */ - public Map<String, IgfsListingEntry> listing() { + @Override public Map<String, IgfsListingEntry> listing() { return Collections.emptyMap(); } /** {@inheritDoc} */ - public boolean hasChildren() { + @Override public boolean hasChildren() { return false; } /** {@inheritDoc} */ - public boolean hasChild(String name) { + @Override public boolean hasChild(String name) { return false; } /** {@inheritDoc} */ - public boolean hasChild(String name, IgniteUuid expId) { + @Override public boolean hasChild(String name, IgniteUuid expId) { return false; } /** {@inheritDoc} */ - @Nullable public IgniteUuid affinityKey() { + @Override @Nullable public IgniteUuid affinityKey() { return affKey; } /** {@inheritDoc} */ - public IgfsFileMap fileMap() { + @Override public IgfsFileMap fileMap() { return fileMap; } /** {@inheritDoc} */ - @Nullable public IgniteUuid lockId() { + @Override @Nullable public IgniteUuid lockId() { return lockId; } /** {@inheritDoc} */ - public boolean evictExclude() { + @Override public boolean evictExclude() { return evictExclude; } http://git-wip-us.apache.org/repos/asf/ignite/blob/8f52344b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsFileWorkerBatch.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsFileWorkerBatch.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsFileWorkerBatch.java index 17875a2..ee809e0 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsFileWorkerBatch.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsFileWorkerBatch.java @@ -128,7 +128,7 @@ public abstract class IgfsFileWorkerBatch implements Runnable { /** * Process the batch. */ - @SuppressWarnings("unchecked") + @Override @SuppressWarnings("unchecked") public void run() { Throwable err = null; http://git-wip-us.apache.org/repos/asf/ignite/blob/8f52344b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/data/IgfsDataPutProcessor.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/data/IgfsDataPutProcessor.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/data/IgfsDataPutProcessor.java index 2029d4e..4e4a6da 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/data/IgfsDataPutProcessor.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/data/IgfsDataPutProcessor.java @@ -62,7 +62,7 @@ public class IgfsDataPutProcessor implements EntryProcessor<IgfsBlockKey, byte[] } /** {@inheritDoc} */ - public Void process(MutableEntry<IgfsBlockKey, byte[]> entry, Object... args) + @Override public Void process(MutableEntry<IgfsBlockKey, byte[]> entry, Object... args) throws EntryProcessorException { byte[] curVal = entry.getValue(); http://git-wip-us.apache.org/repos/asf/ignite/blob/8f52344b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/client/cache/ClientCacheRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/client/cache/ClientCacheRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/client/cache/ClientCacheRequest.java index 9e2d1f1..9e39b56 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/client/cache/ClientCacheRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/client/cache/ClientCacheRequest.java @@ -123,7 +123,7 @@ class ClientCacheRequest extends ClientRequest { } /** {@inheritDoc} */ - protected void authorize(ClientConnectionContext ctx, SecurityPermission perm) { + @Override protected void authorize(ClientConnectionContext ctx, SecurityPermission perm) { SecurityContext secCtx = ctx.securityContext(); if (secCtx != null) { http://git-wip-us.apache.org/repos/asf/ignite/blob/8f52344b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/memory/PlatformOutputStreamImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/memory/PlatformOutputStreamImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/memory/PlatformOutputStreamImpl.java index 884e718..5d01ae9 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/memory/PlatformOutputStreamImpl.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/memory/PlatformOutputStreamImpl.java @@ -336,7 +336,7 @@ public class PlatformOutputStreamImpl implements PlatformOutputStream { } /** {@inheritDoc} */ - public int capacity() { + @Override public int capacity() { return cap; } } \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/8f52344b/modules/core/src/main/java/org/apache/ignite/internal/processors/query/QueryEntityEx.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/query/QueryEntityEx.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/query/QueryEntityEx.java index a697882..f94e651 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/query/QueryEntityEx.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/query/QueryEntityEx.java @@ -63,7 +63,7 @@ public class QueryEntityEx extends QueryEntity { } /** {@inheritDoc} */ - public QueryEntity setNotNullFields(@Nullable Set<String> notNullFields) { + @Override public QueryEntity setNotNullFields(@Nullable Set<String> notNullFields) { this.notNullFields = notNullFields; return this; http://git-wip-us.apache.org/repos/asf/ignite/blob/8f52344b/modules/core/src/main/java/org/apache/ignite/internal/processors/query/schema/SchemaOperationWorker.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/query/schema/SchemaOperationWorker.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/query/schema/SchemaOperationWorker.java index 0bf4d22..3741a5d 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/query/schema/SchemaOperationWorker.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/query/schema/SchemaOperationWorker.java @@ -177,7 +177,7 @@ public class SchemaOperationWorker extends GridWorker { /** * Cancel operation. */ - public void cancel() { + @Override public void cancel() { if (cancelToken.cancel()) super.cancel(); } http://git-wip-us.apache.org/repos/asf/ignite/blob/8f52344b/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/client/message/GridClientNodeMetricsBean.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/client/message/GridClientNodeMetricsBean.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/client/message/GridClientNodeMetricsBean.java index 4138c24..829728b 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/client/message/GridClientNodeMetricsBean.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/client/message/GridClientNodeMetricsBean.java @@ -1231,12 +1231,12 @@ public class GridClientNodeMetricsBean implements Externalizable { } /** {@inheritDoc} */ - public int hashCode() { + @Override public int hashCode() { return System.identityHashCode(this); } /** {@inheritDoc} */ - public boolean equals(Object obj) { + @Override public boolean equals(Object obj) { if (this == obj) return true; http://git-wip-us.apache.org/repos/asf/ignite/blob/8f52344b/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/protocols/tcp/GridTcpRestParser.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/protocols/tcp/GridTcpRestParser.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/protocols/tcp/GridTcpRestParser.java index 65eb3c3..21fdc37 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/protocols/tcp/GridTcpRestParser.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/protocols/tcp/GridTcpRestParser.java @@ -851,7 +851,7 @@ public class GridTcpRestParser implements GridNioParser { } /** {@inheritDoc} */ - public String toString() { + @Override public String toString() { return S.toString(GridTcpRestParser.class, this); } http://git-wip-us.apache.org/repos/asf/ignite/blob/8f52344b/modules/core/src/main/java/org/apache/ignite/internal/processors/service/GridServiceProcessor.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/service/GridServiceProcessor.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/service/GridServiceProcessor.java index fce7053..2dc7e31 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/service/GridServiceProcessor.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/service/GridServiceProcessor.java @@ -1949,7 +1949,7 @@ public class GridServiceProcessor extends GridProcessorAdapter implements Ignite @Override public void onTimeout() { depExe.execute(new Runnable() { - public void run() { + @Override public void run() { onReassignmentFailed(topVer, retries); } }); http://git-wip-us.apache.org/repos/asf/ignite/blob/8f52344b/modules/core/src/main/java/org/apache/ignite/internal/sql/SqlLexer.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/sql/SqlLexer.java b/modules/core/src/main/java/org/apache/ignite/internal/sql/SqlLexer.java index d091fc4..361bd43 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/sql/SqlLexer.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/sql/SqlLexer.java @@ -210,29 +210,29 @@ public class SqlLexer implements SqlLexerToken { } /** {@inheritDoc} */ - public String sql() { + @Override public String sql() { return sql; } /** {@inheritDoc} */ - public String token() { + @Override public String token() { return token; } /** {@inheritDoc} */ - public char tokenFirstChar() { + @Override public char tokenFirstChar() { assert tokenTyp != SqlLexerTokenType.EOF; return token.charAt(0); } /** {@inheritDoc} */ - public int tokenPosition() { + @Override public int tokenPosition() { return tokenPos; } /** {@inheritDoc} */ - public SqlLexerTokenType tokenType() { + @Override public SqlLexerTokenType tokenType() { return tokenTyp; } http://git-wip-us.apache.org/repos/asf/ignite/blob/8f52344b/modules/core/src/main/java/org/apache/ignite/internal/sql/SqlLexerLookAheadToken.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/sql/SqlLexerLookAheadToken.java b/modules/core/src/main/java/org/apache/ignite/internal/sql/SqlLexerLookAheadToken.java index e697473..de5b63e 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/sql/SqlLexerLookAheadToken.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/sql/SqlLexerLookAheadToken.java @@ -49,7 +49,7 @@ public class SqlLexerLookAheadToken implements SqlLexerToken { } /** {@inheritDoc} */ - public String sql() { + @Override public String sql() { return sql; } http://git-wip-us.apache.org/repos/asf/ignite/blob/8f52344b/modules/core/src/main/java/org/apache/ignite/internal/util/GridConcurrentSkipListSet.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/GridConcurrentSkipListSet.java b/modules/core/src/main/java/org/apache/ignite/internal/util/GridConcurrentSkipListSet.java index a7a0ddc..5c1f95e 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/GridConcurrentSkipListSet.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/GridConcurrentSkipListSet.java @@ -164,7 +164,7 @@ public class GridConcurrentSkipListSet<E> extends GridSerializableSet<E> impleme } /** {@inheritDoc} */ - public boolean equals(Object o) { + @Override public boolean equals(Object o) { // Override AbstractSet version to avoid calling size() if (o == this) return true; http://git-wip-us.apache.org/repos/asf/ignite/blob/8f52344b/modules/core/src/main/java/org/apache/ignite/internal/util/GridStringBuilder.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/GridStringBuilder.java b/modules/core/src/main/java/org/apache/ignite/internal/util/GridStringBuilder.java index 410f278..2d4a076 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/GridStringBuilder.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/GridStringBuilder.java @@ -482,7 +482,7 @@ public class GridStringBuilder implements Serializable { } /** {@inheritDoc} */ - public String toString() { + @Override public String toString() { return impl.toString(); } } \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/8f52344b/modules/core/src/main/java/org/apache/ignite/internal/util/IgniteExceptionRegistry.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/IgniteExceptionRegistry.java b/modules/core/src/main/java/org/apache/ignite/internal/util/IgniteExceptionRegistry.java index 03eaaea..0ae7b19 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/IgniteExceptionRegistry.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/IgniteExceptionRegistry.java @@ -241,7 +241,7 @@ public class IgniteExceptionRegistry { } /** {@inheritDoc} */ - public String toString() { + @Override public String toString() { return S.toString(ExceptionInfo.class, this); } } http://git-wip-us.apache.org/repos/asf/ignite/blob/8f52344b/modules/core/src/main/java/org/apache/ignite/internal/util/StripedExecutor.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/StripedExecutor.java b/modules/core/src/main/java/org/apache/ignite/internal/util/StripedExecutor.java index 904b8d1..d89124f 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/StripedExecutor.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/StripedExecutor.java @@ -667,7 +667,7 @@ public class StripedExecutor implements ExecutorService { } /** {@inheritDoc} */ - void execute(Runnable cmd) { + @Override void execute(Runnable cmd) { queue.add(cmd); if (parked) @@ -739,7 +739,7 @@ public class StripedExecutor implements ExecutorService { } /** {@inheritDoc} */ - void execute(Runnable cmd) { + @Override void execute(Runnable cmd) { queue.add(cmd); } @@ -796,7 +796,7 @@ public class StripedExecutor implements ExecutorService { } /** {@inheritDoc} */ - void execute(Runnable cmd) { + @Override void execute(Runnable cmd) { queue.add(cmd); } http://git-wip-us.apache.org/repos/asf/ignite/blob/8f52344b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/gridfunc/ContainsPredicate.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/gridfunc/ContainsPredicate.java b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/gridfunc/ContainsPredicate.java index e3d613a..c5ca76b 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/gridfunc/ContainsPredicate.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/gridfunc/ContainsPredicate.java @@ -49,7 +49,7 @@ public class ContainsPredicate<T> implements IgnitePredicate<T> { } /** {@inheritDoc} */ - public String toString() { + @Override public String toString() { return S.toString(ContainsPredicate.class, this); } } http://git-wip-us.apache.org/repos/asf/ignite/blob/8f52344b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/gridfunc/NotContainsPredicate.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/gridfunc/NotContainsPredicate.java b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/gridfunc/NotContainsPredicate.java index 5f8ba9a..9bacd9a 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/gridfunc/NotContainsPredicate.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/gridfunc/NotContainsPredicate.java @@ -48,7 +48,7 @@ public class NotContainsPredicate<T> implements IgnitePredicate<T> { } /** {@inheritDoc} */ - public String toString() { + @Override public String toString() { return S.toString(NotContainsPredicate.class, this); } } http://git-wip-us.apache.org/repos/asf/ignite/blob/8f52344b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioFilterAdapter.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioFilterAdapter.java b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioFilterAdapter.java index 4ede4b7..05f4ec6 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioFilterAdapter.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioFilterAdapter.java @@ -47,7 +47,7 @@ public abstract class GridNioFilterAdapter implements GridNioFilter { } /** {@inheritDoc} */ - public String toString() { + @Override public String toString() { return name; } http://git-wip-us.apache.org/repos/asf/ignite/blob/8f52344b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioFilterChain.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioFilterChain.java b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioFilterChain.java index ec59020..a57b546 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioFilterChain.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioFilterChain.java @@ -77,7 +77,7 @@ public class GridNioFilterChain<T> extends GridNioFilterAdapter { } /** {@inheritDoc} */ - public String toString() { + @Override public String toString() { if (str == null) { StringBuilder res = new StringBuilder("FilterChain[filters=["); http://git-wip-us.apache.org/repos/asf/ignite/blob/8f52344b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioServer.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioServer.java b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioServer.java index 85332f4..9678ae7 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioServer.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioServer.java @@ -1875,7 +1875,7 @@ public class GridNioServer<T> { * * @param req Change request. */ - public void offer(SessionChangeRequest req) { + @Override public void offer(SessionChangeRequest req) { changeReqs.offer(req); if (select) @@ -2190,7 +2190,7 @@ public class GridNioServer<T> { /** * @param ses Session. */ - public final void registerWrite(GridSelectorNioSessionImpl ses) { + @Override public final void registerWrite(GridSelectorNioSessionImpl ses) { SelectionKey key = ses.key(); if (key.isValid()) { @@ -3337,17 +3337,17 @@ public class GridNioServer<T> { } /** {@inheritDoc} */ - public NioOperation operation() { + @Override public NioOperation operation() { return op; } /** {@inheritDoc} */ - public Object message() { + @Override public Object message() { return msg; } /** {@inheritDoc} */ - public void resetSession(GridNioSession ses) { + @Override public void resetSession(GridNioSession ses) { assert msg instanceof Message : msg; this.ses = (GridSelectorNioSessionImpl)ses; @@ -3361,7 +3361,7 @@ public class GridNioServer<T> { } /** {@inheritDoc} */ - public GridSelectorNioSessionImpl session() { + @Override public GridSelectorNioSessionImpl session() { return ses; } http://git-wip-us.apache.org/repos/asf/ignite/blob/8f52344b/modules/core/src/main/java/org/apache/ignite/internal/util/offheap/unsafe/GridUnsafePartitionedMap.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/offheap/unsafe/GridUnsafePartitionedMap.java b/modules/core/src/main/java/org/apache/ignite/internal/util/offheap/unsafe/GridUnsafePartitionedMap.java index 4cba7fd..42b2769 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/offheap/unsafe/GridUnsafePartitionedMap.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/offheap/unsafe/GridUnsafePartitionedMap.java @@ -291,7 +291,7 @@ public class GridUnsafePartitionedMap implements GridOffHeapPartitionedMap { /** {@inheritDoc} */ @Override public GridCloseableIterator<IgniteBiTuple<byte[], byte[]>> iterator() { return new PartitionedMapCloseableIterator<IgniteBiTuple<byte[], byte[]>>() { - protected void advance() throws IgniteCheckedException { + @Override protected void advance() throws IgniteCheckedException { curIt = null; while (p < parts) { @@ -313,7 +313,7 @@ public class GridUnsafePartitionedMap implements GridOffHeapPartitionedMap { assert c != null; return new PartitionedMapCloseableIterator<T>() { - protected void advance() throws IgniteCheckedException { + @Override protected void advance() throws IgniteCheckedException { curIt = null; while (p < parts) { http://git-wip-us.apache.org/repos/asf/ignite/blob/8f52344b/modules/core/src/main/java/org/apache/ignite/internal/visor/node/VisorSuppressedError.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/visor/node/VisorSuppressedError.java b/modules/core/src/main/java/org/apache/ignite/internal/visor/node/VisorSuppressedError.java index 2ffaabd..e971341 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/visor/node/VisorSuppressedError.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/visor/node/VisorSuppressedError.java @@ -141,7 +141,7 @@ public class VisorSuppressedError extends VisorDataTransferObject { } /** {@inheritDoc} */ - public String toString() { + @Override public String toString() { return S.toString(VisorSuppressedError.class, this); } } http://git-wip-us.apache.org/repos/asf/ignite/blob/8f52344b/modules/core/src/main/java/org/apache/ignite/lang/IgniteProductVersion.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/lang/IgniteProductVersion.java b/modules/core/src/main/java/org/apache/ignite/lang/IgniteProductVersion.java index 457ec55..eef134a 100644 --- a/modules/core/src/main/java/org/apache/ignite/lang/IgniteProductVersion.java +++ b/modules/core/src/main/java/org/apache/ignite/lang/IgniteProductVersion.java @@ -258,7 +258,7 @@ public class IgniteProductVersion implements Comparable<IgniteProductVersion>, E } /** {@inheritDoc} */ - public String toString() { + @Override public String toString() { String revTsStr = new SimpleDateFormat("yyyyMMdd").format(new Date(revTs * 1000)); String hash = U.byteArray2HexString(revHash).toLowerCase(); http://git-wip-us.apache.org/repos/asf/ignite/blob/8f52344b/modules/core/src/main/java/org/apache/ignite/mxbean/CacheMetricsMXBean.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/mxbean/CacheMetricsMXBean.java b/modules/core/src/main/java/org/apache/ignite/mxbean/CacheMetricsMXBean.java index 16bdede..74991bb 100644 --- a/modules/core/src/main/java/org/apache/ignite/mxbean/CacheMetricsMXBean.java +++ b/modules/core/src/main/java/org/apache/ignite/mxbean/CacheMetricsMXBean.java @@ -28,271 +28,271 @@ import org.apache.ignite.cache.CacheMetrics; @MXBeanDescription("MBean that provides access to cache descriptor.") public interface CacheMetricsMXBean extends CacheStatisticsMXBean, CacheMXBean, CacheMetrics { /** {@inheritDoc} */ - @MXBeanDescription("Clear statistics.") + @Override @MXBeanDescription("Clear statistics.") public void clear(); /** {@inheritDoc} */ - @MXBeanDescription("Number of hits.") + @Override @MXBeanDescription("Number of hits.") public long getCacheHits(); /** {@inheritDoc} */ - @MXBeanDescription("Percentage of successful hits.") + @Override @MXBeanDescription("Percentage of successful hits.") public float getCacheHitPercentage(); /** {@inheritDoc} */ - @MXBeanDescription("Number of misses.") + @Override @MXBeanDescription("Number of misses.") public long getCacheMisses(); /** {@inheritDoc} */ - @MXBeanDescription("Percentage of accesses that failed to find anything.") + @Override @MXBeanDescription("Percentage of accesses that failed to find anything.") public float getCacheMissPercentage(); /** {@inheritDoc} */ - @MXBeanDescription("Number of gets.") + @Override @MXBeanDescription("Number of gets.") public long getCacheGets(); /** {@inheritDoc} */ - @MXBeanDescription("Number of puts.") + @Override @MXBeanDescription("Number of puts.") public long getCachePuts(); /** {@inheritDoc} */ - @MXBeanDescription("Number of removals.") + @Override @MXBeanDescription("Number of removals.") public long getCacheRemovals(); /** {@inheritDoc} */ - @MXBeanDescription("Number of eviction entries.") + @Override @MXBeanDescription("Number of eviction entries.") public long getCacheEvictions(); /** {@inheritDoc} */ - @MXBeanDescription("Average time to execute get.") + @Override @MXBeanDescription("Average time to execute get.") public float getAverageGetTime(); /** {@inheritDoc} */ - @MXBeanDescription("Average time to execute put.") + @Override @MXBeanDescription("Average time to execute put.") public float getAveragePutTime(); /** {@inheritDoc} */ - @MXBeanDescription("Average time to execute remove.") + @Override @MXBeanDescription("Average time to execute remove.") public float getAverageRemoveTime(); /** {@inheritDoc} */ - @MXBeanDescription("Average time to commit transaction.") + @Override @MXBeanDescription("Average time to commit transaction.") public float getAverageTxCommitTime(); /** {@inheritDoc} */ - @MXBeanDescription("Average time to rollback transaction.") + @Override @MXBeanDescription("Average time to rollback transaction.") public float getAverageTxRollbackTime(); /** {@inheritDoc} */ - @MXBeanDescription("Number of transaction commits.") + @Override @MXBeanDescription("Number of transaction commits.") public long getCacheTxCommits(); /** {@inheritDoc} */ - @MXBeanDescription("Number of transaction rollback.") + @Override @MXBeanDescription("Number of transaction rollback.") public long getCacheTxRollbacks(); /** {@inheritDoc} */ - @MXBeanDescription("Cache name.") + @Override @MXBeanDescription("Cache name.") public String name(); /** {@inheritDoc} */ - @MXBeanDescription("Number of gets from off-heap memory.") + @Override @MXBeanDescription("Number of gets from off-heap memory.") public long getOffHeapGets(); /** {@inheritDoc} */ - @MXBeanDescription("Number of puts to off-heap memory.") + @Override @MXBeanDescription("Number of puts to off-heap memory.") public long getOffHeapPuts(); /** {@inheritDoc} */ - @MXBeanDescription("Number of removed entries from off-heap memory.") + @Override @MXBeanDescription("Number of removed entries from off-heap memory.") public long getOffHeapRemovals(); /** {@inheritDoc} */ - @MXBeanDescription("Number of evictions from off-heap memory.") + @Override @MXBeanDescription("Number of evictions from off-heap memory.") public long getOffHeapEvictions(); /** {@inheritDoc} */ - @MXBeanDescription("Number of hits on off-heap memory.") + @Override @MXBeanDescription("Number of hits on off-heap memory.") public long getOffHeapHits(); /** {@inheritDoc} */ - @MXBeanDescription("Percentage of hits on off-heap memory.") + @Override @MXBeanDescription("Percentage of hits on off-heap memory.") public float getOffHeapHitPercentage(); /** {@inheritDoc} */ - @MXBeanDescription("Number of misses on off-heap memory.") + @Override @MXBeanDescription("Number of misses on off-heap memory.") public long getOffHeapMisses(); /** {@inheritDoc} */ - @MXBeanDescription("Percentage of misses on off-heap memory.") + @Override @MXBeanDescription("Percentage of misses on off-heap memory.") public float getOffHeapMissPercentage(); /** {@inheritDoc} */ - @MXBeanDescription("Number of entries stored in off-heap memory.") + @Override @MXBeanDescription("Number of entries stored in off-heap memory.") public long getOffHeapEntriesCount(); /** {@inheritDoc} */ - @MXBeanDescription("Number of entries in heap memory.") + @Override @MXBeanDescription("Number of entries in heap memory.") public long getHeapEntriesCount(); /** {@inheritDoc} */ - @MXBeanDescription("Number of primary entries stored in off-heap memory.") + @Override @MXBeanDescription("Number of primary entries stored in off-heap memory.") public long getOffHeapPrimaryEntriesCount(); /** {@inheritDoc} */ - @MXBeanDescription("Number of backup stored in off-heap memory.") + @Override @MXBeanDescription("Number of backup stored in off-heap memory.") public long getOffHeapBackupEntriesCount(); /** {@inheritDoc} */ - @MXBeanDescription("Memory size allocated in off-heap.") + @Override @MXBeanDescription("Memory size allocated in off-heap.") public long getOffHeapAllocatedSize(); /** {@inheritDoc} */ - @MXBeanDescription("Number of non-null values in the cache.") + @Override @MXBeanDescription("Number of non-null values in the cache.") public int getSize(); /** {@inheritDoc} */ - @MXBeanDescription("Number of non-null values in the cache as a long value.") + @Override @MXBeanDescription("Number of non-null values in the cache as a long value.") public long getCacheSize(); /** {@inheritDoc} */ - @MXBeanDescription("Number of keys in the cache (possibly with null values).") + @Override @MXBeanDescription("Number of keys in the cache (possibly with null values).") public int getKeySize(); /** {@inheritDoc} */ - @MXBeanDescription("True if cache is empty.") + @Override @MXBeanDescription("True if cache is empty.") public boolean isEmpty(); /** {@inheritDoc} */ - @MXBeanDescription("Current size of evict queue.") + @Override @MXBeanDescription("Current size of evict queue.") public int getDhtEvictQueueCurrentSize(); /** {@inheritDoc} */ - @MXBeanDescription("Transaction per-thread map size.") + @Override @MXBeanDescription("Transaction per-thread map size.") public int getTxThreadMapSize(); /** {@inheritDoc} */ - @MXBeanDescription("Transaction per-Xid map size.") + @Override @MXBeanDescription("Transaction per-Xid map size.") public int getTxXidMapSize(); /** {@inheritDoc} */ - @MXBeanDescription("Transaction committed queue size.") + @Override @MXBeanDescription("Transaction committed queue size.") public int getTxCommitQueueSize(); /** {@inheritDoc} */ - @MXBeanDescription("Transaction prepared queue size.") + @Override @MXBeanDescription("Transaction prepared queue size.") public int getTxPrepareQueueSize(); /** {@inheritDoc} */ - @MXBeanDescription("Transaction start version counts map size.") + @Override @MXBeanDescription("Transaction start version counts map size.") public int getTxStartVersionCountsSize(); /** {@inheritDoc} */ - @MXBeanDescription("Transaction committed ID map size.") + @Override @MXBeanDescription("Transaction committed ID map size.") public int getTxCommittedVersionsSize(); /** {@inheritDoc} */ - @MXBeanDescription("Transaction rolled back ID map size.") + @Override @MXBeanDescription("Transaction rolled back ID map size.") public int getTxRolledbackVersionsSize(); /** {@inheritDoc} */ - @MXBeanDescription("Transaction DHT per-thread map size.") + @Override @MXBeanDescription("Transaction DHT per-thread map size.") public int getTxDhtThreadMapSize(); /** {@inheritDoc} */ - @MXBeanDescription("Transaction DHT per-Xid map size.") + @Override @MXBeanDescription("Transaction DHT per-Xid map size.") public int getTxDhtXidMapSize(); /** {@inheritDoc} */ - @MXBeanDescription("Transaction DHT committed queue size.") + @Override @MXBeanDescription("Transaction DHT committed queue size.") public int getTxDhtCommitQueueSize(); /** {@inheritDoc} */ - @MXBeanDescription("Transaction DHT prepared queue size.") + @Override @MXBeanDescription("Transaction DHT prepared queue size.") public int getTxDhtPrepareQueueSize(); /** {@inheritDoc} */ - @MXBeanDescription("Transaction DHT start version counts map size.") + @Override @MXBeanDescription("Transaction DHT start version counts map size.") public int getTxDhtStartVersionCountsSize(); /** {@inheritDoc} */ - @MXBeanDescription("Transaction DHT committed ID map size.") + @Override @MXBeanDescription("Transaction DHT committed ID map size.") public int getTxDhtCommittedVersionsSize(); /** {@inheritDoc} */ - @MXBeanDescription("Transaction DHT rolled back ID map size.") + @Override @MXBeanDescription("Transaction DHT rolled back ID map size.") public int getTxDhtRolledbackVersionsSize(); /** {@inheritDoc} */ - @MXBeanDescription("True if write-behind is enabled for this cache.") + @Override @MXBeanDescription("True if write-behind is enabled for this cache.") public boolean isWriteBehindEnabled(); /** {@inheritDoc} */ - @MXBeanDescription("Size of internal buffer that triggers flush procedure.") + @Override @MXBeanDescription("Size of internal buffer that triggers flush procedure.") public int getWriteBehindFlushSize(); /** {@inheritDoc} */ - @MXBeanDescription("Count of flush threads.") + @Override @MXBeanDescription("Count of flush threads.") public int getWriteBehindFlushThreadCount(); /** {@inheritDoc} */ - @MXBeanDescription("Flush frequency interval in milliseconds.") + @Override @MXBeanDescription("Flush frequency interval in milliseconds.") public long getWriteBehindFlushFrequency(); /** {@inheritDoc} */ - @MXBeanDescription("Maximum size of batch for similar operations.") + @Override @MXBeanDescription("Maximum size of batch for similar operations.") public int getWriteBehindStoreBatchSize(); /** {@inheritDoc} */ - @MXBeanDescription("Count of cache overflow events since write-behind cache has started.") + @Override @MXBeanDescription("Count of cache overflow events since write-behind cache has started.") public int getWriteBehindTotalCriticalOverflowCount(); /** {@inheritDoc} */ - @MXBeanDescription("Count of cache overflow events since write-behind cache has started.") + @Override @MXBeanDescription("Count of cache overflow events since write-behind cache has started.") public int getWriteBehindCriticalOverflowCount(); /** {@inheritDoc} */ - @MXBeanDescription("Count of cache cache entries that are currently in retry state.") + @Override @MXBeanDescription("Count of cache cache entries that are currently in retry state.") public int getWriteBehindErrorRetryCount(); /** {@inheritDoc} */ - @MXBeanDescription("Count of cache entries that are waiting to be flushed.") + @Override @MXBeanDescription("Count of cache entries that are waiting to be flushed.") public int getWriteBehindBufferSize(); /** {@inheritDoc} */ - @MXBeanDescription("Key type.") + @Override @MXBeanDescription("Key type.") public String getKeyType(); /** {@inheritDoc} */ - @MXBeanDescription("Value type.") + @Override @MXBeanDescription("Value type.") public String getValueType(); /** {@inheritDoc} */ - @MXBeanDescription("True if the cache is store by value.") + @Override @MXBeanDescription("True if the cache is store by value.") public boolean isStoreByValue(); /** {@inheritDoc} */ - @MXBeanDescription("True if statistics collection is enabled.") + @Override @MXBeanDescription("True if statistics collection is enabled.") public boolean isStatisticsEnabled(); /** {@inheritDoc} */ - @MXBeanDescription("True if management is enabled.") + @Override @MXBeanDescription("True if management is enabled.") public boolean isManagementEnabled(); /** {@inheritDoc} */ - @MXBeanDescription("True when a cache is in read-through mode.") + @Override @MXBeanDescription("True when a cache is in read-through mode.") public boolean isReadThrough(); /** {@inheritDoc} */ - @MXBeanDescription("True when a cache is in write-through mode.") + @Override @MXBeanDescription("True when a cache is in write-through mode.") public boolean isWriteThrough(); /** {@inheritDoc} */ - @MXBeanDescription("True when a cache topology is valid for read operations.") + @Override @MXBeanDescription("True when a cache topology is valid for read operations.") public boolean isValidForReading(); /** {@inheritDoc} */ - @MXBeanDescription("True when a cache topology is valid for write operations.") + @Override @MXBeanDescription("True when a cache topology is valid for write operations.") public boolean isValidForWriting(); /** http://git-wip-us.apache.org/repos/asf/ignite/blob/8f52344b/modules/core/src/main/java/org/apache/ignite/mxbean/ClusterMetricsMXBean.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/mxbean/ClusterMetricsMXBean.java b/modules/core/src/main/java/org/apache/ignite/mxbean/ClusterMetricsMXBean.java index 537cef7..ffb4080 100644 --- a/modules/core/src/main/java/org/apache/ignite/mxbean/ClusterMetricsMXBean.java +++ b/modules/core/src/main/java/org/apache/ignite/mxbean/ClusterMetricsMXBean.java @@ -27,234 +27,234 @@ import org.apache.ignite.cluster.ClusterMetrics; @MXBeanDescription("MBean that provides access to aggregated cluster metrics.") public interface ClusterMetricsMXBean extends ClusterMetrics { /** {@inheritDoc} */ - @MXBeanDescription("Last update time of this node metrics.") + @Override @MXBeanDescription("Last update time of this node metrics.") public long getLastUpdateTime(); /** {@inheritDoc} */ - @MXBeanDescription("Maximum number of jobs that ever ran concurrently on this node.") + @Override @MXBeanDescription("Maximum number of jobs that ever ran concurrently on this node.") public int getMaximumActiveJobs(); /** {@inheritDoc} */ - @MXBeanDescription("Number of currently active jobs concurrently executing on the node.") + @Override @MXBeanDescription("Number of currently active jobs concurrently executing on the node.") public int getCurrentActiveJobs(); /** {@inheritDoc} */ - @MXBeanDescription("Average number of active jobs concurrently executing on the node.") + @Override @MXBeanDescription("Average number of active jobs concurrently executing on the node.") public float getAverageActiveJobs(); /** {@inheritDoc} */ - @MXBeanDescription("Maximum number of waiting jobs this node had.") + @Override @MXBeanDescription("Maximum number of waiting jobs this node had.") public int getMaximumWaitingJobs(); /** {@inheritDoc} */ - @MXBeanDescription("Number of queued jobs currently waiting to be executed.") + @Override @MXBeanDescription("Number of queued jobs currently waiting to be executed.") public int getCurrentWaitingJobs(); /** {@inheritDoc} */ - @MXBeanDescription("Average number of waiting jobs this node had queued.") + @Override @MXBeanDescription("Average number of waiting jobs this node had queued.") public float getAverageWaitingJobs(); /** {@inheritDoc} */ - @MXBeanDescription("Maximum number of jobs rejected at once during a single collision resolution operation.") + @Override @MXBeanDescription("Maximum number of jobs rejected at once during a single collision resolution operation.") public int getMaximumRejectedJobs(); /** {@inheritDoc} */ - @MXBeanDescription("Number of jobs rejected after more recent collision resolution operation.") + @Override @MXBeanDescription("Number of jobs rejected after more recent collision resolution operation.") public int getCurrentRejectedJobs(); /** {@inheritDoc} */ - @MXBeanDescription("Average number of jobs this node rejects during collision resolution operations.") + @Override @MXBeanDescription("Average number of jobs this node rejects during collision resolution operations.") public float getAverageRejectedJobs(); /** {@inheritDoc} */ - @MXBeanDescription( + @Override @MXBeanDescription( "Total number of jobs this node rejects during collision resolution operations since node startup.") public int getTotalRejectedJobs(); /** {@inheritDoc} */ - @MXBeanDescription("Maximum number of cancelled jobs this node ever had running concurrently.") + @Override @MXBeanDescription("Maximum number of cancelled jobs this node ever had running concurrently.") public int getMaximumCancelledJobs(); /** {@inheritDoc} */ - @MXBeanDescription("Number of cancelled jobs that are still running.") + @Override @MXBeanDescription("Number of cancelled jobs that are still running.") public int getCurrentCancelledJobs(); /** {@inheritDoc} */ - @MXBeanDescription("Average number of cancelled jobs this node ever had running concurrently.") + @Override @MXBeanDescription("Average number of cancelled jobs this node ever had running concurrently.") public float getAverageCancelledJobs(); /** {@inheritDoc} */ - @MXBeanDescription("Total number of cancelled jobs since node startup.") + @Override @MXBeanDescription("Total number of cancelled jobs since node startup.") public int getTotalCancelledJobs(); /** {@inheritDoc} */ - @MXBeanDescription("Total number of jobs handled by the node.") + @Override @MXBeanDescription("Total number of jobs handled by the node.") public int getTotalExecutedJobs(); /** {@inheritDoc} */ - @MXBeanDescription("Total time all finished jobs takes to execute on the node.") + @Override @MXBeanDescription("Total time all finished jobs takes to execute on the node.") public long getTotalJobsExecutionTime(); /** {@inheritDoc} */ - @MXBeanDescription("Maximum time a job ever spent waiting in a queue to be executed.") + @Override @MXBeanDescription("Maximum time a job ever spent waiting in a queue to be executed.") public long getMaximumJobWaitTime(); /** {@inheritDoc} */ - @MXBeanDescription("Current wait time of oldest job.") + @Override @MXBeanDescription("Current wait time of oldest job.") public long getCurrentJobWaitTime(); /** {@inheritDoc} */ - @MXBeanDescription("Average time jobs spend waiting in the queue to be executed.") + @Override @MXBeanDescription("Average time jobs spend waiting in the queue to be executed.") public double getAverageJobWaitTime(); /** {@inheritDoc} */ - @MXBeanDescription("Time it took to execute the longest job on the node.") + @Override @MXBeanDescription("Time it took to execute the longest job on the node.") public long getMaximumJobExecuteTime(); /** {@inheritDoc} */ - @MXBeanDescription("Longest time a current job has been executing for.") + @Override @MXBeanDescription("Longest time a current job has been executing for.") public long getCurrentJobExecuteTime(); /** {@inheritDoc} */ - @MXBeanDescription("Average time a job takes to execute on the node.") + @Override @MXBeanDescription("Average time a job takes to execute on the node.") public double getAverageJobExecuteTime(); /** {@inheritDoc} */ - @MXBeanDescription("Total number of tasks handled by the node.") + @Override @MXBeanDescription("Total number of tasks handled by the node.") public int getTotalExecutedTasks(); /** {@inheritDoc} */ - @MXBeanDescription("Total time this node spent executing jobs.") + @Override @MXBeanDescription("Total time this node spent executing jobs.") public long getTotalBusyTime(); /** {@inheritDoc} */ - @MXBeanDescription("Total time this node spent idling (not executing any jobs).") + @Override @MXBeanDescription("Total time this node spent idling (not executing any jobs).") public long getTotalIdleTime(); /** {@inheritDoc} */ - @MXBeanDescription("Time this node spend idling since executing last job.") + @Override @MXBeanDescription("Time this node spend idling since executing last job.") public long getCurrentIdleTime(); /** {@inheritDoc} */ - @MXBeanDescription("Percentage of time this node is busy executing jobs vs. idling.") + @Override @MXBeanDescription("Percentage of time this node is busy executing jobs vs. idling.") public float getBusyTimePercentage(); /** {@inheritDoc} */ - @MXBeanDescription("Percentage of time this node is idling vs. executing jobs.") + @Override @MXBeanDescription("Percentage of time this node is idling vs. executing jobs.") public float getIdleTimePercentage(); /** {@inheritDoc} */ - @MXBeanDescription("The number of CPUs available to the Java Virtual Machine.") + @Override @MXBeanDescription("The number of CPUs available to the Java Virtual Machine.") public int getTotalCpus(); /** {@inheritDoc} */ - @MXBeanDescription("The system load average; or a negative value if not available.") + @Override @MXBeanDescription("The system load average; or a negative value if not available.") public double getCurrentCpuLoad(); /** {@inheritDoc} */ - @MXBeanDescription("Average of CPU load values over all metrics kept in the history.") + @Override @MXBeanDescription("Average of CPU load values over all metrics kept in the history.") public double getAverageCpuLoad(); /** {@inheritDoc} */ - @MXBeanDescription("Average time spent in GC since the last update.") + @Override @MXBeanDescription("Average time spent in GC since the last update.") public double getCurrentGcCpuLoad(); /** {@inheritDoc} */ - @MXBeanDescription("The initial size of memory in bytes; -1 if undefined.") + @Override @MXBeanDescription("The initial size of memory in bytes; -1 if undefined.") public long getHeapMemoryInitialized(); /** {@inheritDoc} */ - @MXBeanDescription("Current heap size that is used for object allocation.") + @Override @MXBeanDescription("Current heap size that is used for object allocation.") public long getHeapMemoryUsed(); /** {@inheritDoc} */ - @MXBeanDescription("The amount of committed memory in bytes.") + @Override @MXBeanDescription("The amount of committed memory in bytes.") public long getHeapMemoryCommitted(); /** {@inheritDoc} */ - @MXBeanDescription("The maximum amount of memory in bytes; -1 if undefined.") + @Override @MXBeanDescription("The maximum amount of memory in bytes; -1 if undefined.") public long getHeapMemoryMaximum(); /** {@inheritDoc} */ - @MXBeanDescription("The total amount of memory in bytes; -1 if undefined.") + @Override @MXBeanDescription("The total amount of memory in bytes; -1 if undefined.") public long getHeapMemoryTotal(); /** {@inheritDoc} */ - @MXBeanDescription("The initial size of memory in bytes; -1 if undefined.") + @Override @MXBeanDescription("The initial size of memory in bytes; -1 if undefined.") public long getNonHeapMemoryInitialized(); /** {@inheritDoc} */ - @MXBeanDescription("Current non-heap memory size that is used by Java VM.") + @Override @MXBeanDescription("Current non-heap memory size that is used by Java VM.") public long getNonHeapMemoryUsed(); /** {@inheritDoc} */ - @MXBeanDescription("Amount of non-heap memory in bytes that is committed for the JVM to use.") + @Override @MXBeanDescription("Amount of non-heap memory in bytes that is committed for the JVM to use.") public long getNonHeapMemoryCommitted(); /** {@inheritDoc} */ - @MXBeanDescription("Maximum amount of non-heap memory in bytes that can " + + @Override @MXBeanDescription("Maximum amount of non-heap memory in bytes that can " + "be used for memory management. -1 if undefined.") public long getNonHeapMemoryMaximum(); /** {@inheritDoc} */ - @MXBeanDescription("Total amount of non-heap memory in bytes that can " + + @Override @MXBeanDescription("Total amount of non-heap memory in bytes that can " + "be used for memory management. -1 if undefined.") public long getNonHeapMemoryTotal(); /** {@inheritDoc} */ - @MXBeanDescription("Uptime of the JVM in milliseconds.") + @Override @MXBeanDescription("Uptime of the JVM in milliseconds.") public long getUpTime(); /** {@inheritDoc} */ - @MXBeanDescription("Start time of the JVM in milliseconds.") + @Override @MXBeanDescription("Start time of the JVM in milliseconds.") public long getStartTime(); /** {@inheritDoc} */ - @MXBeanDescription("Current number of live threads.") + @Override @MXBeanDescription("Current number of live threads.") public int getCurrentThreadCount(); /** {@inheritDoc} */ - @MXBeanDescription("The peak live thread count.") + @Override @MXBeanDescription("The peak live thread count.") public int getMaximumThreadCount(); /** {@inheritDoc} */ - @MXBeanDescription("The total number of threads started.") + @Override @MXBeanDescription("The total number of threads started.") public long getTotalStartedThreadCount(); /** {@inheritDoc} */ - @MXBeanDescription("Current number of live daemon threads.") + @Override @MXBeanDescription("Current number of live daemon threads.") public int getCurrentDaemonThreadCount(); /** {@inheritDoc} */ - @MXBeanDescription("Last data version.") + @Override @MXBeanDescription("Last data version.") public long getLastDataVersion(); /** {@inheritDoc} */ - @MXBeanDescription("Sent messages count.") + @Override @MXBeanDescription("Sent messages count.") public int getSentMessagesCount(); /** {@inheritDoc} */ - @MXBeanDescription("Sent bytes count.") + @Override @MXBeanDescription("Sent bytes count.") public long getSentBytesCount(); /** {@inheritDoc} */ - @MXBeanDescription("Received messages count.") + @Override @MXBeanDescription("Received messages count.") public int getReceivedMessagesCount(); /** {@inheritDoc} */ - @MXBeanDescription("Received bytes count.") + @Override @MXBeanDescription("Received bytes count.") public long getReceivedBytesCount(); /** {@inheritDoc} */ - @MXBeanDescription("Outbound messages queue size.") + @Override @MXBeanDescription("Outbound messages queue size.") public int getOutboundMessagesQueueSize(); /** {@inheritDoc} */ - @MXBeanDescription("Start time of the grid node in milliseconds.") + @Override @MXBeanDescription("Start time of the grid node in milliseconds.") public long getNodeStartTime(); /** {@inheritDoc} */ - @MXBeanDescription("Total number of nodes.") + @Override @MXBeanDescription("Total number of nodes.") public int getTotalNodes(); /** http://git-wip-us.apache.org/repos/asf/ignite/blob/8f52344b/modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/internal/TcpCommunicationConnectionCheckFuture.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/internal/TcpCommunicationConnectionCheckFuture.java b/modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/internal/TcpCommunicationConnectionCheckFuture.java index c42fa57..46fdb0b 100644 --- a/modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/internal/TcpCommunicationConnectionCheckFuture.java +++ b/modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/internal/TcpCommunicationConnectionCheckFuture.java @@ -339,12 +339,12 @@ public class TcpCommunicationConnectionCheckFuture extends GridFutureAdapter<Bit } /** {@inheritDoc} */ - public void onTimeout() { + @Override public void onTimeout() { cancel(); } /** {@inheritDoc} */ - public void onConnected(UUID rmtNodeId) { + @Override public void onConnected(UUID rmtNodeId) { finish(nodeId(nodeIdx).equals(rmtNodeId)); } http://git-wip-us.apache.org/repos/asf/ignite/blob/8f52344b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ClientImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ClientImpl.java b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ClientImpl.java index afdffaf..c88ef20 100644 --- a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ClientImpl.java +++ b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ClientImpl.java @@ -2569,7 +2569,7 @@ class ClientImpl extends TcpDiscoveryImpl { } /** {@inheritDoc} */ - public String toString() { + @Override public String toString() { return sock.toString(); } } http://git-wip-us.apache.org/repos/asf/ignite/blob/8f52344b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ServerImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ServerImpl.java b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ServerImpl.java index 4ac27f6..3e7537a 100644 --- a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ServerImpl.java +++ b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ServerImpl.java @@ -2511,7 +2511,7 @@ class ServerImpl extends TcpDiscoveryImpl { * * @return Non-discarded messages iterator. */ - public Iterator<TcpDiscoveryAbstractMessage> iterator() { + @Override public Iterator<TcpDiscoveryAbstractMessage> iterator() { return new SkipIterator(); } http://git-wip-us.apache.org/repos/asf/ignite/blob/8f52344b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySpi.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySpi.java b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySpi.java index 1c4bf54..d8dc8f8 100644 --- a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySpi.java +++ b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySpi.java @@ -2195,7 +2195,7 @@ public class TcpDiscoverySpi extends IgniteSpiAdapter implements IgniteDiscovery } /** {@inheritDoc} */ - public void clientReconnect() throws IgniteSpiException { + @Override public void clientReconnect() throws IgniteSpiException { impl.reconnect(); } @@ -2282,7 +2282,7 @@ public class TcpDiscoverySpi extends IgniteSpiAdapter implements IgniteDiscovery * <p> * This method is intended for test purposes only. */ - public void simulateNodeFailure() { + @Override public void simulateNodeFailure() { impl.simulateNodeFailure(); } http://git-wip-us.apache.org/repos/asf/ignite/blob/8f52344b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/internal/TcpDiscoveryNode.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/internal/TcpDiscoveryNode.java b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/internal/TcpDiscoveryNode.java index 6c7d8e1..13d1006 100644 --- a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/internal/TcpDiscoveryNode.java +++ b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/internal/TcpDiscoveryNode.java @@ -229,7 +229,7 @@ public class TcpDiscoveryNode extends GridMetadataAwareAdapter implements Ignite * * @param consistentId Consistent globally unique node ID. */ - public void setConsistentId(Serializable consistentId) { + @Override public void setConsistentId(Serializable consistentId) { this.consistentId = consistentId; final Map<String, Object> map = new HashMap<>(attrs); @@ -291,14 +291,14 @@ public class TcpDiscoveryNode extends GridMetadataAwareAdapter implements Ignite } /** {@inheritDoc} */ - public void setMetrics(ClusterMetrics metrics) { + @Override public void setMetrics(ClusterMetrics metrics) { assert metrics != null; this.metrics = metrics; } /** {@inheritDoc} */ - public Map<Integer, CacheMetrics> cacheMetrics() { + @Override public Map<Integer, CacheMetrics> cacheMetrics() { if (metricsProvider != null) { Map<Integer, CacheMetrics> cacheMetrics0 = metricsProvider.cacheMetrics(); @@ -311,7 +311,7 @@ public class TcpDiscoveryNode extends GridMetadataAwareAdapter implements Ignite } /** {@inheritDoc} */ - public void setCacheMetrics(Map<Integer, CacheMetrics> cacheMetrics) { + @Override public void setCacheMetrics(Map<Integer, CacheMetrics> cacheMetrics) { this.cacheMetrics = cacheMetrics != null ? cacheMetrics : Collections.<Integer, CacheMetrics>emptyMap(); } http://git-wip-us.apache.org/repos/asf/ignite/blob/8f52344b/modules/core/src/main/java/org/apache/ignite/ssl/SslContextFactory.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/ssl/SslContextFactory.java b/modules/core/src/main/java/org/apache/ignite/ssl/SslContextFactory.java index c514b0f..edff5c9 100644 --- a/modules/core/src/main/java/org/apache/ignite/ssl/SslContextFactory.java +++ b/modules/core/src/main/java/org/apache/ignite/ssl/SslContextFactory.java @@ -477,7 +477,7 @@ public class SslContextFactory implements Factory<SSLContext> { } /** {@inheritDoc} */ - public String toString() { + @Override public String toString() { return getClass().getSimpleName() + parameters(); } http://git-wip-us.apache.org/repos/asf/ignite/blob/8f52344b/modules/core/src/test/java/org/apache/ignite/cache/IgniteCacheEntryProcessorSequentialCallTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/cache/IgniteCacheEntryProcessorSequentialCallTest.java b/modules/core/src/test/java/org/apache/ignite/cache/IgniteCacheEntryProcessorSequentialCallTest.java index 592449d..165bca7 100644 --- a/modules/core/src/test/java/org/apache/ignite/cache/IgniteCacheEntryProcessorSequentialCallTest.java +++ b/modules/core/src/test/java/org/apache/ignite/cache/IgniteCacheEntryProcessorSequentialCallTest.java @@ -252,7 +252,7 @@ public class IgniteCacheEntryProcessorSequentialCallTest extends GridCommonAbstr */ public static class NotNullCacheEntryProcessor implements CacheEntryProcessor<TestKey, TestValue, Object> { /** {@inheritDoc} */ - public Object process(MutableEntry entry, Object... arguments) throws EntryProcessorException { + @Override public Object process(MutableEntry entry, Object... arguments) throws EntryProcessorException { assertNotNull(entry.getValue()); return null; http://git-wip-us.apache.org/repos/asf/ignite/blob/8f52344b/modules/core/src/test/java/org/apache/ignite/cache/store/CacheStoreSessionListenerReadWriteThroughDisabledAbstractTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/cache/store/CacheStoreSessionListenerReadWriteThroughDisabledAbstractTest.java b/modules/core/src/test/java/org/apache/ignite/cache/store/CacheStoreSessionListenerReadWriteThroughDisabledAbstractTest.java index ab4477d..774d4f7 100644 --- a/modules/core/src/test/java/org/apache/ignite/cache/store/CacheStoreSessionListenerReadWriteThroughDisabledAbstractTest.java +++ b/modules/core/src/test/java/org/apache/ignite/cache/store/CacheStoreSessionListenerReadWriteThroughDisabledAbstractTest.java @@ -46,7 +46,7 @@ import org.apache.ignite.internal.processors.cache.GridCacheAbstractSelfTest; */ public abstract class CacheStoreSessionListenerReadWriteThroughDisabledAbstractTest extends GridCacheAbstractSelfTest { /** {@inheritDoc} */ - protected int gridCount() { + @Override protected int gridCount() { return 2; } @@ -54,7 +54,7 @@ public abstract class CacheStoreSessionListenerReadWriteThroughDisabledAbstractT protected final int CNT = 100; /** {@inheritDoc} */ - protected CacheConfiguration cacheConfiguration(String igniteInstanceName) throws Exception { + @Override protected CacheConfiguration cacheConfiguration(String igniteInstanceName) throws Exception { CacheConfiguration cacheCfg = super.cacheConfiguration(igniteInstanceName); cacheCfg.setCacheStoreFactory(FactoryBuilder.factoryOf(EmptyCacheStore.class)); @@ -70,7 +70,7 @@ public abstract class CacheStoreSessionListenerReadWriteThroughDisabledAbstractT } /** {@inheritDoc} */ - protected NearCacheConfiguration nearConfiguration() { + @Override protected NearCacheConfiguration nearConfiguration() { return null; } http://git-wip-us.apache.org/repos/asf/ignite/blob/8f52344b/modules/core/src/test/java/org/apache/ignite/failure/FailureHandlerTriggeredTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/failure/FailureHandlerTriggeredTest.java b/modules/core/src/test/java/org/apache/ignite/failure/FailureHandlerTriggeredTest.java index 8d56ced..23c7e08 100644 --- a/modules/core/src/test/java/org/apache/ignite/failure/FailureHandlerTriggeredTest.java +++ b/modules/core/src/test/java/org/apache/ignite/failure/FailureHandlerTriggeredTest.java @@ -93,7 +93,7 @@ public class FailureHandlerTriggeredTest extends GridCommonAbstractTest { } /** {@inheritDoc} */ - public SchemaAbstractDiscoveryMessage message() { + @Override public SchemaAbstractDiscoveryMessage message() { throw new Error("Exchange worker termination"); } } http://git-wip-us.apache.org/repos/asf/ignite/blob/8f52344b/modules/core/src/test/java/org/apache/ignite/internal/TaskNodeRestartTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/TaskNodeRestartTest.java b/modules/core/src/test/java/org/apache/ignite/internal/TaskNodeRestartTest.java index 573804e..7cab4e6 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/TaskNodeRestartTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/TaskNodeRestartTest.java @@ -180,7 +180,7 @@ public class TaskNodeRestartTest extends GridCommonAbstractTest { */ private static class TestTask2 implements ComputeTask<Void, Void> { /** {@inheritDoc} */ - @Nullable public Map<? extends ComputeJob, ClusterNode> map(List<ClusterNode> subgrid, Void arg) + @Override @Nullable public Map<? extends ComputeJob, ClusterNode> map(List<ClusterNode> subgrid, Void arg) throws IgniteException { Map<TestJob, ClusterNode> jobs = new HashMap<>(); http://git-wip-us.apache.org/repos/asf/ignite/blob/8f52344b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridProjectionForCachesOnDaemonNodeSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridProjectionForCachesOnDaemonNodeSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridProjectionForCachesOnDaemonNodeSelfTest.java index e32668b..85b2373 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridProjectionForCachesOnDaemonNodeSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridProjectionForCachesOnDaemonNodeSelfTest.java @@ -77,7 +77,7 @@ public class GridProjectionForCachesOnDaemonNodeSelfTest extends GridCommonAbstr } /** {@inheritDoc} */ - protected void beforeTest() throws Exception { + @Override protected void beforeTest() throws Exception { ignite.getOrCreateCache(DEFAULT_CACHE_NAME); } http://git-wip-us.apache.org/repos/asf/ignite/blob/8f52344b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheAbstractTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheAbstractTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheAbstractTest.java index 862ba6a..370a7a8 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheAbstractTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheAbstractTest.java @@ -218,7 +218,7 @@ public abstract class IgniteCacheAbstractTest extends GridCommonAbstractTest { /** * @return Cache. */ - protected <K, V> IgniteCache<K, V> jcache() { + @Override protected <K, V> IgniteCache<K, V> jcache() { return jcache(0); } @@ -226,7 +226,7 @@ public abstract class IgniteCacheAbstractTest extends GridCommonAbstractTest { * @param idx Grid index. * @return Cache. */ - protected <K, V> IgniteCache<K, V> jcache(int idx) { + @Override protected <K, V> IgniteCache<K, V> jcache(int idx) { return grid(idx).cache(DEFAULT_CACHE_NAME); } http://git-wip-us.apache.org/repos/asf/ignite/blob/8f52344b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheStoreValueAbstractTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheStoreValueAbstractTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheStoreValueAbstractTest.java index 4af0a15..bd259a5 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheStoreValueAbstractTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheStoreValueAbstractTest.java @@ -504,7 +504,7 @@ public abstract class IgniteCacheStoreValueAbstractTest extends IgniteCacheAbstr } /** {@inheritDoc} */ - public String toString() { + @Override public String toString() { return "TestValue [val=" + val + ']'; } } http://git-wip-us.apache.org/repos/asf/ignite/blob/8f52344b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteDynamicCacheStartFailWithPersistenceTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteDynamicCacheStartFailWithPersistenceTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteDynamicCacheStartFailWithPersistenceTest.java index 3b7bf52..24c9342 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteDynamicCacheStartFailWithPersistenceTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteDynamicCacheStartFailWithPersistenceTest.java @@ -34,7 +34,7 @@ public class IgniteDynamicCacheStartFailWithPersistenceTest extends IgniteAbstra return 5 * 60 * 1000; } - protected boolean persistenceEnabled() { + @Override protected boolean persistenceEnabled() { return true; } @@ -75,7 +75,7 @@ public class IgniteDynamicCacheStartFailWithPersistenceTest extends IgniteAbstra } /** {@inheritDoc} */ - protected void checkCacheOperations(IgniteCache<Integer, Value> cache) throws Exception { + @Override protected void checkCacheOperations(IgniteCache<Integer, Value> cache) throws Exception { super.checkCacheOperations(cache); // Disable write-ahead log. http://git-wip-us.apache.org/repos/asf/ignite/blob/8f52344b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteTopologyValidatorCacheGroupsAbstractTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteTopologyValidatorCacheGroupsAbstractTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteTopologyValidatorCacheGroupsAbstractTest.java index 3070d9d..8613225 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteTopologyValidatorCacheGroupsAbstractTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteTopologyValidatorCacheGroupsAbstractTest.java @@ -79,7 +79,7 @@ public abstract class IgniteTopologyValidatorCacheGroupsAbstractTest extends Ign /** * @throws Exception If failed. */ - public void testTopologyValidator() throws Exception { + @Override public void testTopologyValidator() throws Exception { putValid(DEFAULT_CACHE_NAME); remove(DEFAULT_CACHE_NAME); http://git-wip-us.apache.org/repos/asf/ignite/blob/8f52344b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/binary/GridCacheBinaryAtomicEntryProcessorDeploymentSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/binary/GridCacheBinaryAtomicEntryProcessorDeploymentSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/binary/GridCacheBinaryAtomicEntryProcessorDeploymentSelfTest.java index 596cf54..c65f41c 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/binary/GridCacheBinaryAtomicEntryProcessorDeploymentSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/binary/GridCacheBinaryAtomicEntryProcessorDeploymentSelfTest.java @@ -29,7 +29,7 @@ import org.apache.ignite.internal.processors.cache.GridCacheAtomicEntryProcessor public class GridCacheBinaryAtomicEntryProcessorDeploymentSelfTest extends GridCacheAtomicEntryProcessorDeploymentSelfTest { /** {@inheritDoc} */ - protected IgniteCache getCache() { + @Override protected IgniteCache getCache() { return grid(1).cache(DEFAULT_CACHE_NAME).withKeepBinary(); } http://git-wip-us.apache.org/repos/asf/ignite/blob/8f52344b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/GridCacheSequenceApiSelfAbstractTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/GridCacheSequenceApiSelfAbstractTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/GridCacheSequenceApiSelfAbstractTest.java index 45275f4..81292c7 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/GridCacheSequenceApiSelfAbstractTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/GridCacheSequenceApiSelfAbstractTest.java @@ -91,7 +91,7 @@ public abstract class GridCacheSequenceApiSelfAbstractTest extends IgniteAtomics } /** {@inheritDoc} */ - protected AtomicConfiguration atomicConfiguration() { + @Override protected AtomicConfiguration atomicConfiguration() { AtomicConfiguration atomicCfg = super.atomicConfiguration(); atomicCfg.setAtomicSequenceReserveSize(BATCH_SIZE); @@ -138,7 +138,7 @@ public abstract class GridCacheSequenceApiSelfAbstractTest extends IgniteAtomics } /** {@inheritDoc} */ - protected IgniteEx grid() { + @Override protected IgniteEx grid() { return grid(0); } http://git-wip-us.apache.org/repos/asf/ignite/blob/8f52344b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/CacheNearDisabledAtomicInvokeRestartSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/CacheNearDisabledAtomicInvokeRestartSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/CacheNearDisabledAtomicInvokeRestartSelfTest.java index 28f2fe0..89e075d 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/CacheNearDisabledAtomicInvokeRestartSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/CacheNearDisabledAtomicInvokeRestartSelfTest.java @@ -74,7 +74,7 @@ public class CacheNearDisabledAtomicInvokeRestartSelfTest extends CacheAbstractR } /** {@inheritDoc} */ - protected void checkCache(IgniteEx ignite, IgniteCache cache) throws Exception { + @Override protected void checkCache(IgniteEx ignite, IgniteCache cache) throws Exception { log.info("Start cache validation."); long startTime = U.currentTimeMillis(); http://git-wip-us.apache.org/repos/asf/ignite/blob/8f52344b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/CacheNearDisabledTransactionalInvokeRestartSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/CacheNearDisabledTransactionalInvokeRestartSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/CacheNearDisabledTransactionalInvokeRestartSelfTest.java index f4eea6c..e5f9e28 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/CacheNearDisabledTransactionalInvokeRestartSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/CacheNearDisabledTransactionalInvokeRestartSelfTest.java @@ -71,7 +71,7 @@ public class CacheNearDisabledTransactionalInvokeRestartSelfTest extends CacheAb } /** {@inheritDoc} */ - protected void checkCache(IgniteEx ignite, IgniteCache cache) { + @Override protected void checkCache(IgniteEx ignite, IgniteCache cache) { log.info("Start cache validation."); long startTime = U.currentTimeMillis(); http://git-wip-us.apache.org/repos/asf/ignite/blob/8f52344b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/CachePartitionStateTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/CachePartitionStateTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/CachePartitionStateTest.java index 3b05ac3..b1c25b7 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/CachePartitionStateTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/CachePartitionStateTest.java @@ -61,7 +61,7 @@ public class CachePartitionStateTest extends GridCommonAbstractTest { private CacheConfiguration ccfg; /** {@inheritDoc} */ - protected IgniteConfiguration getConfiguration(String igniteInstanceName) throws Exception { + @Override protected IgniteConfiguration getConfiguration(String igniteInstanceName) throws Exception { IgniteConfiguration cfg = super.getConfiguration(igniteInstanceName); ((TcpDiscoverySpi)cfg.getDiscoverySpi()).setIpFinder(ipFinder);
