http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicUpdateFuture.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicUpdateFuture.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicUpdateFuture.java index 7210dfe..072918e 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicUpdateFuture.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicUpdateFuture.java @@ -70,15 +70,12 @@ public class GridNearAtomicUpdateFuture extends GridNearAtomicAbstractUpdateFutu private Collection<?> keys; /** Values. */ - @SuppressWarnings({"FieldAccessedSynchronizedAndUnsynchronized"}) private Collection<?> vals; /** Conflict put values. */ - @SuppressWarnings({"FieldAccessedSynchronizedAndUnsynchronized"}) private Collection<GridCacheDrInfo> conflictPutVals; /** Conflict remove values. */ - @SuppressWarnings({"FieldAccessedSynchronizedAndUnsynchronized"}) private Collection<GridCacheVersion> conflictRmvVals; /** Mappings if operations is mapped to more than one node. */ @@ -347,7 +344,6 @@ public class GridNearAtomicUpdateFuture extends GridNearAtomicAbstractUpdateFutu } /** {@inheritDoc} */ - @SuppressWarnings({"unchecked"}) @Override public void onPrimaryResponse(UUID nodeId, GridNearAtomicUpdateResponse res, boolean nodeErr) { GridNearAtomicAbstractUpdateRequest req; @@ -915,7 +911,6 @@ public class GridNearAtomicUpdateFuture extends GridNearAtomicAbstractUpdateFutu * @return Mapping. * @throws Exception If failed. */ - @SuppressWarnings("ForLoopReplaceableByForEach") private Map<UUID, PrimaryRequestState> mapUpdate(Collection<ClusterNode> topNodes, AffinityTopologyVersion topVer, Long futId,
http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/colocated/GridDhtColocatedCache.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/colocated/GridDhtColocatedCache.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/colocated/GridDhtColocatedCache.java index 8fc353c..a6ac902 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/colocated/GridDhtColocatedCache.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/colocated/GridDhtColocatedCache.java @@ -210,7 +210,6 @@ public class GridDhtColocatedCache<K, V> extends GridDhtTransactionalCacheAdapte needVer); return fut.chain(new CX1<IgniteInternalFuture<Map<Object, Object>>, V>() { - @SuppressWarnings("unchecked") @Override public V applyx(IgniteInternalFuture<Map<Object, Object>> e) throws IgniteCheckedException { Map<Object, Object> map = e.get(); http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtForceKeysFuture.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtForceKeysFuture.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtForceKeysFuture.java index 323fe75..9d6c8fc 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtForceKeysFuture.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtForceKeysFuture.java @@ -166,7 +166,6 @@ public final class GridDhtForceKeysFuture<K, V> extends GridCompoundFuture<Objec /** * @param evt Discovery event. */ - @SuppressWarnings( {"unchecked"}) public void onDiscoveryEvent(DiscoveryEvent evt) { topCntr.incrementAndGet(); @@ -192,7 +191,6 @@ public final class GridDhtForceKeysFuture<K, V> extends GridCompoundFuture<Objec /** * @param res Response. */ - @SuppressWarnings( {"unchecked"}) public void onResult(GridDhtForceKeysResponse res) { for (IgniteInternalFuture<Object> f : futures()) if (isMini(f)) { http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionSupplier.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionSupplier.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionSupplier.java index 9254766..d26d68f 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionSupplier.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionSupplier.java @@ -178,7 +178,6 @@ class GridDhtPartitionSupplier { * @param nodeId Id of the node which sent the demand message. * @param demandMsg Demand message. */ - @SuppressWarnings("unchecked") public void handleDemandMessage(int topicId, UUID nodeId, GridDhtPartitionDemandMessage demandMsg) { assert demandMsg != null; assert nodeId != null; http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsSingleMessage.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsSingleMessage.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsSingleMessage.java index 8db7176..403b862 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsSingleMessage.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsSingleMessage.java @@ -210,7 +210,6 @@ public class GridDhtPartitionsSingleMessage extends GridDhtPartitionsAbstractMes * @param partsCnt Total cache partitions. * @return Partition update counters. */ - @SuppressWarnings("unchecked") public CachePartitionPartialCountersMap partitionUpdateCounters(int grpId, int partsCnt) { Object res = partCntrs == null ? null : partCntrs.get(grpId); http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/topology/GridClientPartitionTopology.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/topology/GridClientPartitionTopology.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/topology/GridClientPartitionTopology.java index 9fb6825..a6c17c0 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/topology/GridClientPartitionTopology.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/topology/GridClientPartitionTopology.java @@ -170,7 +170,6 @@ public class GridClientPartitionTopology implements GridDhtPartitionTopology { /** * @return Full map string representation. */ - @SuppressWarnings({"ConstantConditions"}) private String fullMapString() { return node2part == null ? "null" : FULL_MAP_DEBUG ? node2part.toFullString() : node2part.toString(); } @@ -179,7 +178,6 @@ public class GridClientPartitionTopology implements GridDhtPartitionTopology { * @param map Map to get string for. * @return Full map string representation. */ - @SuppressWarnings({"ConstantConditions"}) private String mapString(GridDhtPartitionMap map) { return map == null ? "null" : FULL_MAP_DEBUG ? map.toFullString() : map.toString(); } http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/topology/GridDhtPartitionTopologyImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/topology/GridDhtPartitionTopologyImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/topology/GridDhtPartitionTopologyImpl.java index c90d40f..bb62d64 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/topology/GridDhtPartitionTopologyImpl.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/topology/GridDhtPartitionTopologyImpl.java @@ -217,7 +217,6 @@ public class GridDhtPartitionTopologyImpl implements GridDhtPartitionTopology { /** * @return Full map string representation. */ - @SuppressWarnings({"ConstantConditions"}) private String fullMapString() { return node2part == null ? "null" : FULL_MAP_DEBUG ? node2part.toFullString() : node2part.toString(); } @@ -226,7 +225,6 @@ public class GridDhtPartitionTopologyImpl implements GridDhtPartitionTopology { * @param map Map to get string for. * @return Full map string representation. */ - @SuppressWarnings({"ConstantConditions"}) private String mapString(GridDhtPartitionMap map) { return map == null ? "null" : FULL_MAP_DEBUG ? map.toFullString() : map.toString(); } http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearAtomicCache.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearAtomicCache.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearAtomicCache.java index 503c324..998dcf9 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearAtomicCache.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearAtomicCache.java @@ -447,13 +447,11 @@ public class GridNearAtomicCache<K, V> extends GridNearCacheAdapter<K, V> { } /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Override public IgniteInternalFuture<V> getAndPutAsync0(K key, V val, @Nullable CacheEntryPredicate filter) { return dht.getAndPutAsync0(key, val, filter); } /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Override public IgniteInternalFuture<Boolean> putAsync0(K key, V val, @Nullable CacheEntryPredicate filter) { return dht.putAsync0(key, val, filter); } @@ -533,7 +531,6 @@ public class GridNearAtomicCache<K, V> extends GridNearCacheAdapter<K, V> { } /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Override public IgniteInternalFuture<V> getAndRemoveAsync(K key) { return dht.getAndRemoveAsync(key); } @@ -555,7 +552,6 @@ public class GridNearAtomicCache<K, V> extends GridNearCacheAdapter<K, V> { } /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Override public IgniteInternalFuture<Boolean> removeAsync(K key, @Nullable CacheEntryPredicate filter) { return dht.removeAsync(key, filter); } http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearGetFuture.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearGetFuture.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearGetFuture.java index 09445f7..40dbf6a 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearGetFuture.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearGetFuture.java @@ -570,7 +570,6 @@ public final class GridNearGetFuture<K, V> extends CacheDistributedGetFutureAdap * @param v Value. * @param ver Version. */ - @SuppressWarnings("unchecked") private void addResult(KeyCacheObject key, CacheObject v, GridCacheVersion ver) { if (keepCacheObjects) { K key0 = (K)key; http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearLockFuture.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearLockFuture.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearLockFuture.java index 0863f6e..3691250 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearLockFuture.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearLockFuture.java @@ -151,7 +151,6 @@ public final class GridNearLockFuture extends GridCacheCompoundIdentityFuture<Bo private volatile int done; /** Keys locked so far. */ - @SuppressWarnings({"FieldAccessedSynchronizedAndUnsynchronized"}) @GridToStringExclude private List<GridDistributedCacheEntry> entries; http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxFinishFuture.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxFinishFuture.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxFinishFuture.java index 20d9e50..ca9e1bf 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxFinishFuture.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxFinishFuture.java @@ -147,7 +147,6 @@ public final class GridNearTxFinishFuture<K, V> extends GridCacheCompoundIdentit } /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Override public boolean onNodeLeft(UUID nodeId) { boolean found = false; @@ -841,7 +840,6 @@ public final class GridNearTxFinishFuture<K, V> extends GridCacheCompoundIdentit /** {@inheritDoc} */ @Override public String toString() { Collection<String> futs = F.viewReadOnly(futures(), new C1<IgniteInternalFuture<?>, String>() { - @SuppressWarnings("unchecked") @Override public String apply(IgniteInternalFuture<?> f) { if (f.getClass() == FinishMiniFuture.class) { FinishMiniFuture fut = (FinishMiniFuture)f; http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxLocal.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxLocal.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxLocal.java index ef74de4..fb2f8e3 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxLocal.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxLocal.java @@ -412,7 +412,6 @@ public class GridNearTxLocal extends GridDhtTxLocalAdapter implements GridTimeou * @param retval Flag indicating whether a value should be returned. * @return Future for put operation. */ - @SuppressWarnings("unchecked") public <K, V> IgniteInternalFuture<GridCacheReturn> putAllAsync( GridCacheContext cacheCtx, @Nullable AffinityTopologyVersion entryTopVer, @@ -481,7 +480,6 @@ public class GridNearTxLocal extends GridDhtTxLocalAdapter implements GridTimeou * @param invokeArgs Optional arguments for entry processor. * @return Operation future. */ - @SuppressWarnings("unchecked") public <K, V, T> IgniteInternalFuture<GridCacheReturn> invokeAsync( GridCacheContext cacheCtx, @Nullable AffinityTopologyVersion entryTopVer, @@ -3990,7 +3988,6 @@ public class GridNearTxLocal extends GridDhtTxLocalAdapter implements GridTimeou * @param req Prepare request. * @return Future that will be completed when locks are acquired. */ - @SuppressWarnings("TypeMayBeWeakened") public IgniteInternalFuture<GridNearTxPrepareResponse> prepareAsyncLocal(GridNearTxPrepareRequest req) { long timeout = remainingTime(); http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/local/atomic/GridLocalAtomicCache.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/local/atomic/GridLocalAtomicCache.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/local/atomic/GridLocalAtomicCache.java index 919f6d2..dc7e3ec 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/local/atomic/GridLocalAtomicCache.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/local/atomic/GridLocalAtomicCache.java @@ -122,7 +122,6 @@ public class GridLocalAtomicCache<K, V> extends GridLocalCache<K, V> { } /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Override protected V getAndPut0(K key, V val, @Nullable CacheEntryPredicate filter) throws IgniteCheckedException { CacheOperationContext opCtx = ctx.operationContextPerCall(); @@ -233,7 +232,6 @@ public class GridLocalAtomicCache<K, V> extends GridLocalCache<K, V> { } /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Override public void removeAll0(Collection<? extends K> keys) throws IgniteCheckedException { CacheOperationContext opCtx = ctx.operationContextPerCall(); @@ -256,7 +254,6 @@ public class GridLocalAtomicCache<K, V> extends GridLocalCache<K, V> { } /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Override public boolean remove0(K key, final CacheEntryPredicate filter) throws IgniteCheckedException { CacheOperationContext opCtx = ctx.operationContextPerCall(); @@ -295,7 +292,6 @@ public class GridLocalAtomicCache<K, V> extends GridLocalCache<K, V> { } /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Override protected V get0( final K key, String taskName, @@ -314,7 +310,6 @@ public class GridLocalAtomicCache<K, V> extends GridLocalCache<K, V> { } /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Override public final Map<K, V> getAll0(Collection<? extends K> keys, boolean deserializeBinary, boolean needVer) throws IgniteCheckedException { A.notNull(keys, "keys"); @@ -675,7 +670,6 @@ public class GridLocalAtomicCache<K, V> extends GridLocalCache<K, V> { } /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Override public <T> Map<K, EntryProcessorResult<T>> invokeAll( Map<? extends K, ? extends EntryProcessor<K, V, T>> map, Object... args) throws IgniteCheckedException { @@ -1556,7 +1550,6 @@ public class GridLocalAtomicCache<K, V> extends GridLocalCache<K, V> { } /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Override public IgniteInternalFuture<Boolean> lockAllAsync(@Nullable Collection<? extends K> keys, long timeout) { return new GridFinishedFuture<>(new UnsupportedOperationException("Locks are not supported for " + @@ -1564,7 +1557,6 @@ public class GridLocalAtomicCache<K, V> extends GridLocalCache<K, V> { } /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Override public void unlockAll(@Nullable Collection<? extends K> keys) throws IgniteCheckedException { throw new UnsupportedOperationException("Locks are not supported for " + "CacheAtomicityMode.ATOMIC mode (use CacheAtomicityMode.TRANSACTIONAL instead)"); http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/mvcc/MvccProcessorImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/mvcc/MvccProcessorImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/mvcc/MvccProcessorImpl.java index b840206..c448620 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/mvcc/MvccProcessorImpl.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/mvcc/MvccProcessorImpl.java @@ -2041,7 +2041,6 @@ public class MvccProcessorImpl extends GridProcessorAdapter implements MvccProce } /** */ - @SuppressWarnings("unchecked") private static class CompoundWaiter implements Waiter { /** */ private final Object inner; @@ -2406,7 +2405,6 @@ public class MvccProcessorImpl extends GridProcessorAdapter implements MvccProce * @param metrics Vacuum metrics. * @throws IgniteCheckedException If failed. */ - @SuppressWarnings("unchecked") private void cleanup(GridDhtLocalPartition part, KeyCacheObject key, List<MvccLinkAwareSearchRow> cleanupRows, Object rest, GridCacheContext cctx, VacuumMetrics metrics) throws IgniteCheckedException { assert key != null && cctx != null && (!F.isEmpty(cleanupRows) || rest != null); http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/pagemem/PageMemoryImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/pagemem/PageMemoryImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/pagemem/PageMemoryImpl.java index ed55854..5f16ce8 100755 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/pagemem/PageMemoryImpl.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/pagemem/PageMemoryImpl.java @@ -1079,7 +1079,6 @@ public class PageMemoryImpl implements PageMemoryEx { } /** {@inheritDoc} */ - @SuppressWarnings({"unchecked", "TooBroadScope"}) @Override public void finishCheckpoint() { if (segments == null) return; http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/tree/BPlusTree.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/tree/BPlusTree.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/tree/BPlusTree.java index 7b07dcf..e9b7248 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/tree/BPlusTree.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/tree/BPlusTree.java @@ -361,7 +361,6 @@ public abstract class BPlusTree<L, T extends L> extends DataStructure implements */ public class Replace extends GetPageHandler<Put> { /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Override public Result run0(long pageId, long page, long pageAddr, BPlusIO<L> io, Put p, int lvl) throws IgniteCheckedException { // Check the triangle invariant. @@ -1192,7 +1191,6 @@ public abstract class BPlusTree<L, T extends L> extends DataStructure implements } /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Override public T findLast() throws IgniteCheckedException { return findLast(null); } @@ -1242,7 +1240,6 @@ public abstract class BPlusTree<L, T extends L> extends DataStructure implements * @return Found result or {@code null}. * @throws IgniteCheckedException If failed. */ - @SuppressWarnings("unchecked") public final <R> R findOne(L row, TreeRowClosure<L, T> c, Object x) throws IgniteCheckedException { checkDestroyed(); @@ -1269,7 +1266,6 @@ public abstract class BPlusTree<L, T extends L> extends DataStructure implements * @return Found row. * @throws IgniteCheckedException If failed. */ - @SuppressWarnings("unchecked") @Override public final T findOne(L row) throws IgniteCheckedException { return findOne(row, null, null); } @@ -2898,7 +2894,6 @@ public abstract class BPlusTree<L, T extends L> extends DataStructure implements } /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Override boolean found(BPlusIO<L> io, long pageAddr, int idx, int lvl) throws IgniteCheckedException { // Check if we are on an inner page and can't get row from it. if (lvl != 0 && !canGetRowFromInner) @@ -3042,7 +3037,6 @@ public abstract class BPlusTree<L, T extends L> extends DataStructure implements * @param cnt Number of rows in the buffer. * @throws IgniteCheckedException If failed. */ - @SuppressWarnings("unchecked") private void visit(long pageAddr, BPlusIO<L> io, int startIdx, int cnt) throws IgniteCheckedException { assert io.isLeaf() : io; @@ -3983,7 +3977,6 @@ public abstract class BPlusTree<L, T extends L> extends DataStructure implements } /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Override public long pollFreePage() { if (freePages == null) return 0L; @@ -4002,7 +3995,6 @@ public abstract class BPlusTree<L, T extends L> extends DataStructure implements } /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Override public void addFreePage(long pageId) { assert pageId != 0L; @@ -4410,7 +4402,6 @@ public abstract class BPlusTree<L, T extends L> extends DataStructure implements * @param idx Index to remove. * @throws IgniteCheckedException If failed. */ - @SuppressWarnings("unchecked") private void removeDataRowFromLeaf(long pageId, long page, long pageAddr, Boolean walPlc, BPlusIO<L> io, int cnt, int idx) throws IgniteCheckedException { @@ -4642,7 +4633,6 @@ public abstract class BPlusTree<L, T extends L> extends DataStructure implements /** * @throws IgniteCheckedException If failed. */ - @SuppressWarnings("unchecked") private void reuseFreePages() throws IgniteCheckedException { // If we have a bag, then it will be processed at the upper level. if (reuseList != null && freePages != null) @@ -5178,7 +5168,6 @@ public abstract class BPlusTree<L, T extends L> extends DataStructure implements /** * */ - @SuppressWarnings("unchecked") private abstract class AbstractForwardCursor { /** */ long nextPageId; @@ -5310,7 +5299,6 @@ public abstract class BPlusTree<L, T extends L> extends DataStructure implements * @return {@code true} If we were able to fetch rows from this page. * @throws IgniteCheckedException If failed. */ - @SuppressWarnings("unchecked") private boolean fillFromBuffer(long pageAddr, BPlusIO<L> io, int startIdx, int cnt) throws IgniteCheckedException { assert io.isLeaf() : io; @@ -5406,7 +5394,6 @@ public abstract class BPlusTree<L, T extends L> extends DataStructure implements /** * Closure cursor. */ - @SuppressWarnings("unchecked") private final class ClosureCursor extends AbstractForwardCursor { /** */ private final TreeRowClosure<L, T> p; @@ -5502,7 +5489,6 @@ public abstract class BPlusTree<L, T extends L> extends DataStructure implements /** * Forward cursor. */ - @SuppressWarnings("unchecked") private final class ForwardCursor extends AbstractForwardCursor implements GridCursor<T> { /** */ final Object x; @@ -5592,7 +5578,6 @@ public abstract class BPlusTree<L, T extends L> extends DataStructure implements } /** {@inheritDoc} */ - @SuppressWarnings("SimplifiableIfStatement") @Override public boolean next() throws IgniteCheckedException { if (rows == null) return false; @@ -5643,7 +5628,6 @@ public abstract class BPlusTree<L, T extends L> extends DataStructure implements */ private abstract class GetPageHandler<G extends Get> extends PageHandler<G, Result> { /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Override public Result run(int cacheId, long pageId, long page, long pageAddr, PageIO iox, Boolean walPlc, G g, int lvl, IoStatisticsHolder statHolder) throws IgniteCheckedException { assert PageIO.getPageId(pageAddr) == pageId; http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/tree/io/PageIO.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/tree/io/PageIO.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/tree/io/PageIO.java index 56ebb0f..423be3d 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/tree/io/PageIO.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/tree/io/PageIO.java @@ -616,7 +616,6 @@ public abstract class PageIO { * @return Page IO. * @throws IgniteCheckedException If failed. */ - @SuppressWarnings("unchecked") public static <Q extends PageIO> Q getPageIO(int type, int ver) throws IgniteCheckedException { switch (type) { case T_DATA: @@ -674,7 +673,6 @@ public abstract class PageIO { * @return IO for either inner or leaf B+Tree page. * @throws IgniteCheckedException If failed. */ - @SuppressWarnings("unchecked") public static <Q extends BPlusIO<?>> Q getBPlusIO(int type, int ver) throws IgniteCheckedException { if (type >= T_H2_EX_REF_LEAF_START && type <= T_H2_EX_REF_LEAF_END) return (Q)h2ExtraLeafIOs.get(type - T_H2_EX_REF_LEAF_START).forVersion(ver); http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheDistributedQueryFuture.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheDistributedQueryFuture.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheDistributedQueryFuture.java index 241a1e6..1380772 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheDistributedQueryFuture.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheDistributedQueryFuture.java @@ -58,7 +58,6 @@ public class GridCacheDistributedQueryFuture<K, V, R> extends GridCacheQueryFutu * @param qry Query. * @param nodes Nodes. */ - @SuppressWarnings("unchecked") protected GridCacheDistributedQueryFuture(GridCacheContext<K, V> ctx, long reqId, GridCacheQueryBean qry, Iterable<ClusterNode> nodes) { super(ctx, qry, false); @@ -195,7 +194,6 @@ public class GridCacheDistributedQueryFuture<K, V, R> extends GridCacheQueryFutu } /** {@inheritDoc} */ - @SuppressWarnings("NonPrivateFieldAccessedInSynchronizedContext") @Override protected void loadPage() { assert !Thread.holdsLock(this); @@ -214,7 +212,6 @@ public class GridCacheDistributedQueryFuture<K, V, R> extends GridCacheQueryFutu } /** {@inheritDoc} */ - @SuppressWarnings("NonPrivateFieldAccessedInSynchronizedContext") @Override protected void loadAllPages() throws IgniteInterruptedCheckedException { assert !Thread.holdsLock(this); http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheDistributedQueryManager.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheDistributedQueryManager.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheDistributedQueryManager.java index c5f64c9..0f9ee28 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheDistributedQueryManager.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheDistributedQueryManager.java @@ -194,7 +194,6 @@ public class GridCacheDistributedQueryManager<K, V> extends GridCacheQueryManage * @param sndId Sender node id. * @param req Query request. */ - @SuppressWarnings("unchecked") @Override void processQueryRequest(UUID sndId, GridCacheQueryRequest req) { assert req.mvccSnapshot() != null || !cctx.mvccEnabled() || req.cancel() || (req.type() == null && !req.fields()) : req; // Last assertion means next page request. @@ -722,7 +721,6 @@ public class GridCacheDistributedQueryManager<K, V> extends GridCacheQueryManage } /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Override public CacheQueryFuture<?> queryFieldsDistributed(GridCacheQueryBean qry, Collection<ClusterNode> nodes) { assert cctx.config().getCacheMode() != LOCAL; @@ -790,7 +788,6 @@ public class GridCacheDistributedQueryManager<K, V> extends GridCacheQueryManage * @param nodes Nodes. * @throws IgniteCheckedException In case of error. */ - @SuppressWarnings("unchecked") private void sendRequest( final GridCacheDistributedQueryFuture<?, ?, ?> fut, final GridCacheQueryRequest req, @@ -892,7 +889,6 @@ public class GridCacheDistributedQueryManager<K, V> extends GridCacheQueryManage } /** {@inheritDoc} */ - @SuppressWarnings({"unchecked"}) @Override public boolean equals(Object obj) { if (obj == this) return true; http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryAdapter.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryAdapter.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryAdapter.java index 6f3772c..0dbdef1 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryAdapter.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryAdapter.java @@ -424,7 +424,6 @@ public class GridCacheQueryAdapter<T> implements CacheQuery<T> { /** * @return Key-value filter. */ - @SuppressWarnings("unchecked") @Nullable public <K, V> IgniteBiPredicate<K, V> scanFilter() { return (IgniteBiPredicate<K, V>)filter; } @@ -432,7 +431,6 @@ public class GridCacheQueryAdapter<T> implements CacheQuery<T> { /** * @return Transformer. */ - @SuppressWarnings("unchecked") @Nullable public <K, V> IgniteClosure<Map.Entry<K, V>, Object> transform() { return (IgniteClosure<Map.Entry<K, V>, Object>)transform; } @@ -477,7 +475,7 @@ public class GridCacheQueryAdapter<T> implements CacheQuery<T> { * @param args Arguments. * @return Future. */ - @SuppressWarnings({"IfMayBeConditional", "unchecked"}) + @SuppressWarnings({"IfMayBeConditional"}) private <R> CacheQueryFuture<R> execute0(@Nullable IgniteReducer<T, R> rmtReducer, @Nullable Object... args) { assert type != SCAN : this; @@ -528,7 +526,6 @@ public class GridCacheQueryAdapter<T> implements CacheQuery<T> { } /** {@inheritDoc} */ - @SuppressWarnings({"unchecked"}) @Override public GridCloseableIterator executeScanQuery() throws IgniteCheckedException { assert type == SCAN : "Wrong processing of query: " + type; http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryFutureAdapter.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryFutureAdapter.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryFutureAdapter.java index 140966e..4330cd0 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryFutureAdapter.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryFutureAdapter.java @@ -324,7 +324,6 @@ public abstract class GridCacheQueryFutureAdapter<K, V, R> extends GridFutureAda /** * @param col Collection. */ - @SuppressWarnings({"unchecked"}) protected void enqueue(Collection<?> col) { assert Thread.holdsLock(this); @@ -338,7 +337,6 @@ public abstract class GridCacheQueryFutureAdapter<K, V, R> extends GridFutureAda * @return If dedup flag is {@code true} deduplicated collection (considering keys), * otherwise passed in collection without any modifications. */ - @SuppressWarnings({"unchecked"}) private Collection<?> dedupIfRequired(Collection<?> col) { if (!qry.query().enableDedup()) return col; @@ -360,7 +358,6 @@ public abstract class GridCacheQueryFutureAdapter<K, V, R> extends GridFutureAda * @param err Error (if was). * @param finished Finished or not. */ - @SuppressWarnings({"unchecked"}) public void onPage(@Nullable UUID nodeId, @Nullable Collection<?> data, @Nullable Throwable err, boolean finished) { if (isCancelled()) return; http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryManager.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryManager.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryManager.java index f42164e..8949a2f 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryManager.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryManager.java @@ -1340,7 +1340,7 @@ public abstract class GridCacheQueryManager<K, V> extends GridCacheManagerAdapte * @param qry Query. * @param updateStatistics Update statistics flag. */ - @SuppressWarnings({"unchecked", "serial"}) + @SuppressWarnings({"unchecked"}) protected GridCloseableIterator scanQueryLocal(final GridCacheQueryAdapter qry, boolean updateStatistics) throws IgniteCheckedException { if (!enterBusy()) http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryResponse.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryResponse.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryResponse.java index a1650be..8e05c02 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryResponse.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryResponse.java @@ -234,7 +234,6 @@ public class GridCacheQueryResponse extends GridCacheIdMessage implements GridCa /** * @param data Query data. */ - @SuppressWarnings("unchecked") public void data(Collection<?> data) { this.data = (Collection<Object>)data; } http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryResponseEntry.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryResponseEntry.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryResponseEntry.java index 650f0c0..5c63eaa 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryResponseEntry.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryResponseEntry.java @@ -87,7 +87,6 @@ public class GridCacheQueryResponseEntry<K, V> implements Map.Entry<K, V>, Exter } /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Override public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException { key = (K)in.readObject(); val = (V)in.readObject(); http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryEventBuffer.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryEventBuffer.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryEventBuffer.java index 2fc6993..c707c72 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryEventBuffer.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryEventBuffer.java @@ -421,7 +421,6 @@ public class CacheContinuousQueryEventBuffer { * @param backup Backup entry flag. * @return New result. */ - @SuppressWarnings("unchecked") @Nullable private Object processEntry0( @Nullable Object res, long cntr, http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryHandler.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryHandler.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryHandler.java index ade360a..503a514 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryHandler.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryHandler.java @@ -1211,7 +1211,6 @@ public class CacheContinuousQueryHandler<K, V> implements GridContinuousHandler } /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Override public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException { cacheName = U.readString(in); topic = in.readObject(); http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryHandlerV3.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryHandlerV3.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryHandlerV3.java index 14d5605..78228f3 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryHandlerV3.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryHandlerV3.java @@ -156,7 +156,6 @@ public class CacheContinuousQueryHandlerV3<K, V> extends CacheContinuousQueryHan } /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Override public void writeExternal(ObjectOutput out) throws IOException { super.writeExternal(out); @@ -171,7 +170,6 @@ public class CacheContinuousQueryHandlerV3<K, V> extends CacheContinuousQueryHan } /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Override public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException { super.readExternal(in); http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryManager.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryManager.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryManager.java index 4c399bf..d688a52 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryManager.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryManager.java @@ -1216,7 +1216,6 @@ public class CacheContinuousQueryManager extends GridCacheManagerAdapter { * @param evt Event. * @return Singleton iterable. */ - @SuppressWarnings("unchecked") private Iterable<CacheEntryEvent<? extends K, ? extends V>> singleton( CacheEntryEvent<? extends K, ? extends V> evt) { assert evt instanceof CacheContinuousQueryEvent; @@ -1296,7 +1295,6 @@ public class CacheContinuousQueryManager extends GridCacheManagerAdapter { } /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Override public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException { impl = (CacheEntryEventFilter)in.readObject(); types = in.readByte(); http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/store/GridCacheWriteBehindStore.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/store/GridCacheWriteBehindStore.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/store/GridCacheWriteBehindStore.java index 82ff3aa..fdf3649 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/store/GridCacheWriteBehindStore.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/store/GridCacheWriteBehindStore.java @@ -531,7 +531,6 @@ public class GridCacheWriteBehindStore<K, V> implements CacheStore<K, V>, Lifecy } /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Override public void delete(Object key) { try { if (log.isDebugEnabled()) http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxAdapter.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxAdapter.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxAdapter.java index 47a0276..8be90dd 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxAdapter.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxAdapter.java @@ -1764,7 +1764,7 @@ public abstract class IgniteTxAdapter extends GridMetadataAwareAdapter implement * @throws IgniteCheckedException In case of eny exception. * @throws GridCacheEntryRemovedException If entry got removed. */ - @SuppressWarnings({"unchecked", "ConstantConditions"}) + @SuppressWarnings({"unchecked"}) protected IgniteBiTuple<GridCacheOperation, GridCacheVersionConflictContext> conflictResolve( GridCacheOperation op, IgniteTxEntry txEntry, http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxLocalAdapter.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxLocalAdapter.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxLocalAdapter.java index df43615..c829d45 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxLocalAdapter.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxLocalAdapter.java @@ -1177,7 +1177,6 @@ public abstract class IgniteTxLocalAdapter extends IgniteTxAdapter implements Ig * @param computeInvoke If {@code true} computes return value for invoke operation. * @throws IgniteCheckedException If error. */ - @SuppressWarnings("unchecked") protected final void postLockWrite( GridCacheContext cacheCtx, Iterable<KeyCacheObject> keys, http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxManager.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxManager.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxManager.java index a8b594b..ce914e8 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxManager.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxManager.java @@ -737,7 +737,6 @@ public class IgniteTxManager extends GridCacheSharedManagerAdapter { /** * @return Transaction for current thread. */ - @SuppressWarnings({"unchecked"}) public <T> T tx() { IgniteInternalTx tx = txContext(); @@ -845,7 +844,6 @@ public class IgniteTxManager extends GridCacheSharedManagerAdapter { * @param threadId Id of thread for transaction. * @return Transaction for thread with given ID. */ - @SuppressWarnings({"unchecked"}) private <T> T tx(GridCacheContext cctx, long threadId) { if (cctx == null || !cctx.systemTx()) return (T)threadMap.get(threadId); @@ -866,7 +864,6 @@ public class IgniteTxManager extends GridCacheSharedManagerAdapter { * @param txId Transaction ID. * @return Transaction with given ID. */ - @SuppressWarnings({"unchecked"}) @Nullable public <T extends IgniteInternalTx> T tx(GridCacheVersion txId) { return (T)idMap.get(txId); } @@ -875,7 +872,6 @@ public class IgniteTxManager extends GridCacheSharedManagerAdapter { * @param txId Transaction ID. * @return Transaction with given ID. */ - @SuppressWarnings({"unchecked"}) @Nullable public <T extends IgniteInternalTx> T nearTx(GridCacheVersion txId) { return (T)nearIdMap.get(txId); } @@ -1771,7 +1767,6 @@ public class IgniteTxManager extends GridCacheSharedManagerAdapter { /** * @return Currently committing transaction. */ - @SuppressWarnings({"unchecked"}) private IgniteInternalTx txContext() { return threadCtx.get(); } @@ -2332,7 +2327,6 @@ public class IgniteTxManager extends GridCacheSharedManagerAdapter { /** * @return Collection of active transaction deadlock detection futures. */ - @SuppressWarnings("unchecked") public Collection<IgniteInternalFuture<?>> deadlockDetectionFutures() { Collection<? extends IgniteInternalFuture<?>> values = deadlockDetectFuts.values(); @@ -2756,7 +2750,6 @@ public class IgniteTxManager extends GridCacheSharedManagerAdapter { */ private class DeadlockDetectionListener implements GridMessageListener { /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Override public void onMessage(UUID nodeId, Object msg, byte plc) { GridCacheMessage cacheMsg = (GridCacheMessage)msg; http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/TxDeadlockDetection.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/TxDeadlockDetection.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/TxDeadlockDetection.java index 1cf7809..a904e5b 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/TxDeadlockDetection.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/TxDeadlockDetection.java @@ -220,7 +220,6 @@ public class TxDeadlockDetection { * @param topVer Transaction topology version. * @param keys Keys. */ - @SuppressWarnings("unchecked") private TxDeadlockFuture(GridCacheSharedContext cctx, GridCacheVersion txId, AffinityTopologyVersion topVer, http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/version/GridCacheLazyPlainVersionedEntry.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/version/GridCacheLazyPlainVersionedEntry.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/version/GridCacheLazyPlainVersionedEntry.java index 0fa2f7e..84dfae1 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/version/GridCacheLazyPlainVersionedEntry.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/version/GridCacheLazyPlainVersionedEntry.java @@ -98,7 +98,6 @@ public class GridCacheLazyPlainVersionedEntry<K, V> extends GridCachePlainVersio * @param keepBinary Flag to keep binary if needed. * @return the value corresponding to this entry */ - @SuppressWarnings("unchecked") public V value(boolean keepBinary) { if (val == null) val = (V)cctx.unwrapBinaryIfNeeded(valObj, keepBinary, true); http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/cluster/ClusterProcessor.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cluster/ClusterProcessor.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cluster/ClusterProcessor.java index 48c0299..6d0710b 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cluster/ClusterProcessor.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cluster/ClusterProcessor.java @@ -332,7 +332,6 @@ public class ClusterProcessor extends GridProcessorAdapter { /** * @param vals collection to seek through. */ - @SuppressWarnings("unchecked") private Boolean findLastFlag(Collection<Serializable> vals) { Boolean flag = null; http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/GridContinuousMessage.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/GridContinuousMessage.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/GridContinuousMessage.java index 5e7cc9d..cdfb2a4 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/GridContinuousMessage.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/GridContinuousMessage.java @@ -118,7 +118,6 @@ public class GridContinuousMessage implements Message { /** * @return Message data. */ - @SuppressWarnings("unchecked") public <T> T data() { return msgs != null ? (T)msgs : (T)data; } http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/GridContinuousProcessor.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/GridContinuousProcessor.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/GridContinuousProcessor.java index 4569f65..22d6997 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/GridContinuousProcessor.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/GridContinuousProcessor.java @@ -811,7 +811,6 @@ public class GridContinuousProcessor extends GridProcessorAdapter { * @param prjPred Projection predicate. * @return Future. */ - @SuppressWarnings("TooBroadScope") public IgniteInternalFuture<UUID> startRoutine(GridContinuousHandler hnd, boolean locOnly, int bufSize, @@ -1712,7 +1711,6 @@ public class GridContinuousProcessor extends GridProcessorAdapter { if (interval > 0) { IgniteThread checker = new IgniteThread(new GridWorker(ctx.igniteInstanceName(), "continuous-buffer-checker", log) { - @SuppressWarnings("ConstantConditions") @Override protected void body() { long interval0 = interval; @@ -2371,7 +2369,6 @@ public class GridContinuousProcessor extends GridProcessorAdapter { } /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Override public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException { routineId = U.readUuid(in); prjPred = (IgnitePredicate<ClusterNode>)in.readObject(); http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/StartRequestData.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/StartRequestData.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/StartRequestData.java index 2314f29..4035cdb 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/StartRequestData.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/StartRequestData.java @@ -245,7 +245,6 @@ class StartRequestData implements Externalizable { } /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Override public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException { boolean b = in.readBoolean(); http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerImpl.java index 4253fb2..76cb899 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerImpl.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerImpl.java @@ -1230,7 +1230,6 @@ public class DataStreamerImpl<K, V> implements IgniteDataStreamer<K, V>, Delayed } /** {@inheritDoc} */ - @SuppressWarnings("ForLoopReplaceableByForEach") @Override public void flush() throws CacheException { lock(true); http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/datastructures/DataStructuresProcessor.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/datastructures/DataStructuresProcessor.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/datastructures/DataStructuresProcessor.java index 92671e0..ea78f6c 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/datastructures/DataStructuresProcessor.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/datastructures/DataStructuresProcessor.java @@ -181,7 +181,6 @@ public final class DataStructuresProcessor extends GridProcessorAdapter implemen } /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Override public void onKernalStart(boolean active) { if (ctx.config().isDaemon() || !active) return; @@ -837,7 +836,6 @@ public final class DataStructuresProcessor extends GridProcessorAdapter implemen * @return Instance of queue. * @throws IgniteCheckedException If failed. */ - @SuppressWarnings("unchecked") public final <T> IgniteQueue<T> queue(final String name, @Nullable final String grpName, int cap, @Nullable final CollectionConfiguration cfg) throws IgniteCheckedException { @@ -1550,7 +1548,6 @@ public final class DataStructuresProcessor extends GridProcessorAdapter implemen * @return Set instance. * @throws IgniteCheckedException If failed. */ - @SuppressWarnings("unchecked") @Nullable public <T> IgniteSet<T> set(final String name, @Nullable final String grpName, @Nullable final CollectionConfiguration cfg) throws IgniteCheckedException { A.notNull(name, "name"); @@ -1615,7 +1612,6 @@ public final class DataStructuresProcessor extends GridProcessorAdapter implemen * @return Object has casted to expected type. * @throws IgniteCheckedException If {@code obj} has different to {@code cls} type. */ - @SuppressWarnings("unchecked") @Nullable private <R> R cast(@Nullable Object obj, Class<R> cls) throws IgniteCheckedException { if (obj == null) return null; http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/datastructures/GridCacheAtomicReferenceValue.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/datastructures/GridCacheAtomicReferenceValue.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/datastructures/GridCacheAtomicReferenceValue.java index b3a2243..32b8b31 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/datastructures/GridCacheAtomicReferenceValue.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/datastructures/GridCacheAtomicReferenceValue.java @@ -75,7 +75,6 @@ public final class GridCacheAtomicReferenceValue<T> extends AtomicDataStructureV } /** {@inheritDoc} */ - @SuppressWarnings( {"unchecked"}) @Override public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException { val = (T)in.readObject(); } http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/datastructures/GridCacheAtomicStampedValue.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/datastructures/GridCacheAtomicStampedValue.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/datastructures/GridCacheAtomicStampedValue.java index 89f83c1..a328fb1 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/datastructures/GridCacheAtomicStampedValue.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/datastructures/GridCacheAtomicStampedValue.java @@ -100,7 +100,6 @@ public final class GridCacheAtomicStampedValue<T, S> extends AtomicDataStructure } /** {@inheritDoc} */ - @SuppressWarnings( {"unchecked"}) @Override public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException { val = (T)in.readObject(); stamp = (S)in.readObject(); http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/datastructures/GridCacheCountDownLatchImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/datastructures/GridCacheCountDownLatchImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/datastructures/GridCacheCountDownLatchImpl.java index 7662acf..8453080 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/datastructures/GridCacheCountDownLatchImpl.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/datastructures/GridCacheCountDownLatchImpl.java @@ -309,7 +309,6 @@ public final class GridCacheCountDownLatchImpl extends AtomicDataStructureProxy< * @return Reconstructed object. * @throws ObjectStreamException Thrown in case of unmarshalling error. */ - @SuppressWarnings({"ConstantConditions"}) private Object readResolve() throws ObjectStreamException { try { IgniteBiTuple<GridKernalContext, String> t = stash.get(); http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsAbstractOutputStream.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsAbstractOutputStream.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsAbstractOutputStream.java index c1e751e..463fb64 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsAbstractOutputStream.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsAbstractOutputStream.java @@ -110,7 +110,6 @@ abstract class IgfsAbstractOutputStream extends IgfsOutputStream { } /** {@inheritDoc} */ - @SuppressWarnings("NullableProblems") @Override public void write(byte[] b, int off, int len) throws IOException { A.notNull(b, "b"); http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsDataManager.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsDataManager.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsDataManager.java index 5f8f314..9184f5e 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsDataManager.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsDataManager.java @@ -1497,7 +1497,6 @@ public class IgfsDataManager extends IgfsManager { } /** {@inheritDoc} */ - @SuppressWarnings("ConstantConditions") @Override protected void body() throws InterruptedException, IgniteInterruptedCheckedException { try { while (!isCancelled()) { http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsImpl.java index bac536d..5931d40 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsImpl.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsImpl.java @@ -414,7 +414,6 @@ public final class IgfsImpl implements IgfsEx { } /** {@inheritDoc} */ - @SuppressWarnings("ConstantConditions") @Override public IgfsStatus globalSpace() { return safeOp(new Callable<IgfsStatus>() { @Override public IgfsStatus call() throws Exception { @@ -765,7 +764,6 @@ public final class IgfsImpl implements IgfsEx { } /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Override public Collection<IgfsPath> listPaths(final IgfsPath path) { A.notNull(path, "path"); @@ -1554,7 +1552,6 @@ public final class IgfsImpl implements IgfsEx { * @param arg Optional task argument. * @return Execution future. */ - @SuppressWarnings("unchecked") <T, R> IgniteInternalFuture<R> executeAsync0(Class<? extends IgfsTask<T, R>> taskCls, @Nullable IgfsRecordResolver rslvr, Collection<IgfsPath> paths, boolean skipNonExistentFiles, long maxRangeLen, @Nullable T arg) { @@ -1790,7 +1787,6 @@ public final class IgfsImpl implements IgfsEx { /** * IGFS thread factory. */ - @SuppressWarnings("NullableProblems") private static class IgfsThreadFactory implements ThreadFactory { /** IGFS name. */ private final String name; http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsInputStreamImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsInputStreamImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsInputStreamImpl.java index 40352aa..a24f8dc 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsInputStreamImpl.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsInputStreamImpl.java @@ -59,7 +59,6 @@ public class IgfsInputStreamImpl extends IgfsInputStream implements IgfsSecondar private final IgfsContext igfsCtx; /** Secondary file system reader. */ - @SuppressWarnings("FieldAccessedSynchronizedAndUnsynchronized") private final IgfsSecondaryFileSystemPositionedReadable secReader; /** Logger. */ http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/client/ClientResourceRegistry.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/client/ClientResourceRegistry.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/client/ClientResourceRegistry.java index 0ac3368..faa0e7f 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/client/ClientResourceRegistry.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/client/ClientResourceRegistry.java @@ -52,7 +52,6 @@ public class ClientResourceRegistry { * @param <T> Object type. * @return Object. */ - @SuppressWarnings("unchecked") public <T> T get(long hnd) { Object obj = res.get(hnd); http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/dotnet/PlatformDotNetCacheStore.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/dotnet/PlatformDotNetCacheStore.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/dotnet/PlatformDotNetCacheStore.java index fbf8191..c2303ac 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/dotnet/PlatformDotNetCacheStore.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/dotnet/PlatformDotNetCacheStore.java @@ -270,7 +270,6 @@ public class PlatformDotNetCacheStore<K, V> implements CacheStore<K, V>, Platfor } /** {@inheritDoc} */ - @SuppressWarnings({"unchecked"}) @Override public void writeAll(final Collection<Cache.Entry<? extends K, ? extends V>> entries) { assert entries != null; try { http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/dotnet/PlatformDotNetConfigurationClosure.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/dotnet/PlatformDotNetConfigurationClosure.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/dotnet/PlatformDotNetConfigurationClosure.java index 05ee693..89ad088 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/dotnet/PlatformDotNetConfigurationClosure.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/dotnet/PlatformDotNetConfigurationClosure.java @@ -75,7 +75,6 @@ public class PlatformDotNetConfigurationClosure extends PlatformAbstractConfigur } /** {@inheritDoc} */ - @SuppressWarnings("deprecation") @Override protected void apply0(IgniteConfiguration igniteCfg) { // Validate and copy Interop configuration setting environment pointer along the way. PlatformConfiguration interopCfg = igniteCfg.getPlatformConfiguration(); http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/events/PlatformEvents.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/events/PlatformEvents.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/events/PlatformEvents.java index bd22298..218b112 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/events/PlatformEvents.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/events/PlatformEvents.java @@ -443,19 +443,17 @@ public class PlatformEvents extends PlatformAbstractTarget { } /** <inheritDoc /> */ - @SuppressWarnings("unchecked") @Override public void write(BinaryRawWriterEx writer, Object obj, Throwable err) { - Collection<Event> events = (Collection<Event>)obj; + Collection<Event> evts = (Collection<Event>)obj; if (obj != null) { - writer.writeInt(events.size()); + writer.writeInt(evts.size()); - for (Event e : events) + for (Event e : evts) platformCtx.writeEvent(writer, e); } - else { + else writer.writeInt(-1); - } } /** <inheritDoc /> */ http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/utils/PlatformUtils.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/utils/PlatformUtils.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/utils/PlatformUtils.java index bfd31b6..6b34149 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/utils/PlatformUtils.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/utils/PlatformUtils.java @@ -81,7 +81,6 @@ import static org.apache.ignite.internal.IgniteNodeAttributes.ATTR_PREFIX; /** * Platform utility methods. */ -@SuppressWarnings({"unchecked"}) public class PlatformUtils { /** Node attribute: platform. */ public static final String ATTR_PLATFORM = ATTR_PREFIX + ".platform"; http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/plugin/CachePluginManager.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/plugin/CachePluginManager.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/plugin/CachePluginManager.java index 556bb26..abab9d6 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/plugin/CachePluginManager.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/plugin/CachePluginManager.java @@ -109,7 +109,6 @@ public class CachePluginManager extends GridCacheManagerAdapter { * @param cls Component class. * @return Created component. */ - @SuppressWarnings("unchecked") public <T> T createComponent(Class<T> cls) { for (CachePluginProvider provider : providersList) { T res = (T)provider.createComponent(cls); @@ -146,7 +145,7 @@ public class CachePluginManager extends GridCacheManagerAdapter { * @param <V> Value type. * @return New instance of underlying type or {@code null} if it's not available. */ - @SuppressWarnings({"unchecked", "ForLoopReplaceableByForEach"}) + @SuppressWarnings({"ForLoopReplaceableByForEach"}) @Nullable public <T, K, V> T unwrapCacheEntry(Cache.Entry<K, V> entry, Class<T> cls) { for (int i = 0; i < providersList.size(); i++) { final T res = (T)providersList.get(i).unwrapCacheEntry(entry, cls); http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/plugin/IgnitePluginProcessor.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/plugin/IgnitePluginProcessor.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/plugin/IgnitePluginProcessor.java index c1e542d..6e82a0d 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/plugin/IgnitePluginProcessor.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/plugin/IgnitePluginProcessor.java @@ -108,7 +108,6 @@ public class IgnitePluginProcessor extends GridProcessorAdapter { * @param name Plugin name. * @return Plugin provider. */ - @SuppressWarnings("unchecked") @Nullable public <T extends PluginProvider> T pluginProvider(String name) { return (T)plugins.get(name); } @@ -124,7 +123,6 @@ public class IgnitePluginProcessor extends GridProcessorAdapter { * @param provider Plugin context. * @return Plugin context. */ - @SuppressWarnings("unchecked") public <T extends PluginContext> T pluginContextForProvider(PluginProvider provider) { return (T)pluginCtxMap.get(provider); } http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/query/GridQueryCacheObjectsIterator.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/query/GridQueryCacheObjectsIterator.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/query/GridQueryCacheObjectsIterator.java index b0e1562..08934e9 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/query/GridQueryCacheObjectsIterator.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/query/GridQueryCacheObjectsIterator.java @@ -62,7 +62,6 @@ public class GridQueryCacheObjectsIterator implements Iterator<List<?>>, AutoClo } /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Override public List<?> next() { return ((List<?>)CacheObjectUtils.unwrapBinariesIfNeeded( cacheObjValCtx, (Collection<Object>)iter.next(), keepBinary)); http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/query/GridQueryProcessor.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/query/GridQueryProcessor.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/query/GridQueryProcessor.java index eee21e2..bf2f943 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/query/GridQueryProcessor.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/query/GridQueryProcessor.java @@ -336,7 +336,6 @@ public class GridQueryProcessor extends GridProcessorAdapter { } /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Override public void onGridDataReceived(DiscoveryDataBag.GridDiscoveryData data) { synchronized (stateMux) { // Preserve proposals. http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/query/QueryKeyValueIterator.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/query/QueryKeyValueIterator.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/query/QueryKeyValueIterator.java index 02dde9d..af984cd 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/query/QueryKeyValueIterator.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/query/QueryKeyValueIterator.java @@ -46,7 +46,6 @@ public class QueryKeyValueIterator<K, V> implements Iterator<Cache.Entry<K, V>> } /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Override public Cache.Entry<K, V> next() { try { List<?> row = iter.next(); http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/query/QueryTypeDescriptorImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/query/QueryTypeDescriptorImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/query/QueryTypeDescriptorImpl.java index 722205b..865c5df 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/query/QueryTypeDescriptorImpl.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/query/QueryTypeDescriptorImpl.java @@ -205,7 +205,6 @@ public class QueryTypeDescriptorImpl implements GridQueryTypeDescriptor { } /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Override public <T> T value(String field, Object key, Object val) throws IgniteCheckedException { assert field != null; http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/query/property/QueryBinaryProperty.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/query/property/QueryBinaryProperty.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/query/property/QueryBinaryProperty.java index 3f2d233..0405057 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/query/property/QueryBinaryProperty.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/query/property/QueryBinaryProperty.java @@ -213,7 +213,6 @@ public class QueryBinaryProperty implements GridQueryProperty { * @param <T> Value type. */ private <T> void setValue0(BinaryObjectBuilder builder, String field, Object val, Class<T> valType) { - //noinspection unchecked builder.setField(field, (T)val, valType); } http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/client/message/GridClientTaskResultBean.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/client/message/GridClientTaskResultBean.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/client/message/GridClientTaskResultBean.java index dc2a953..8329276 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/client/message/GridClientTaskResultBean.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/client/message/GridClientTaskResultBean.java @@ -73,7 +73,6 @@ public class GridClientTaskResultBean implements Externalizable { /** * @return Task result. */ - @SuppressWarnings("unchecked") public <R> R getResult() { return (R)res; }
