http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/jdbc/thin/JdbcThinResultSet.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/jdbc/thin/JdbcThinResultSet.java b/modules/core/src/main/java/org/apache/ignite/internal/jdbc/thin/JdbcThinResultSet.java index 26c61d5..4e2fef2 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/jdbc/thin/JdbcThinResultSet.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/jdbc/thin/JdbcThinResultSet.java @@ -1752,7 +1752,6 @@ public class JdbcThinResultSet implements ResultSet { } /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Override public <T> T unwrap(Class<T> iface) throws SQLException { if (!isWrapperFor(iface)) throw new SQLException("Result set is not a wrapper for " + iface.getName()); @@ -1766,7 +1765,6 @@ public class JdbcThinResultSet implements ResultSet { } /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Override public <T> T getObject(int colIdx, Class<T> targetCls) throws SQLException { return (T)getObject0(colIdx, targetCls); }
http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/jdbc/thin/JdbcThinStatement.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/jdbc/thin/JdbcThinStatement.java b/modules/core/src/main/java/org/apache/ignite/internal/jdbc/thin/JdbcThinStatement.java index 98b970c..be25201 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/jdbc/thin/JdbcThinStatement.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/jdbc/thin/JdbcThinStatement.java @@ -802,7 +802,6 @@ public class JdbcThinStatement implements Statement { } /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Override public <T> T unwrap(Class<T> iface) throws SQLException { if (!isWrapperFor(iface)) throw new SQLException("Statement is not a wrapper for " + iface.getName()); http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/jdbc2/JdbcConnection.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/jdbc2/JdbcConnection.java b/modules/core/src/main/java/org/apache/ignite/internal/jdbc2/JdbcConnection.java index 96e4554..896deb7 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/jdbc2/JdbcConnection.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/jdbc2/JdbcConnection.java @@ -768,7 +768,6 @@ public class JdbcConnection implements Connection { } /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Override public <T> T unwrap(Class<T> iface) throws SQLException { if (!isWrapperFor(iface)) throw new SQLException("Connection is not a wrapper for " + iface.getName()); http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/jdbc2/JdbcDatabaseMetadata.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/jdbc2/JdbcDatabaseMetadata.java b/modules/core/src/main/java/org/apache/ignite/internal/jdbc2/JdbcDatabaseMetadata.java index 20cf0d3..663c988 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/jdbc2/JdbcDatabaseMetadata.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/jdbc2/JdbcDatabaseMetadata.java @@ -1363,7 +1363,6 @@ public class JdbcDatabaseMetadata implements DatabaseMetaData { } /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Override public <T> T unwrap(Class<T> iface) throws SQLException { if (!isWrapperFor(iface)) throw new SQLException("Database meta data is not a wrapper for " + iface.getName()); http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/jdbc2/JdbcResultSet.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/jdbc2/JdbcResultSet.java b/modules/core/src/main/java/org/apache/ignite/internal/jdbc2/JdbcResultSet.java index 43fb755..f3fc160 100755 --- a/modules/core/src/main/java/org/apache/ignite/internal/jdbc2/JdbcResultSet.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/jdbc2/JdbcResultSet.java @@ -1752,7 +1752,6 @@ public class JdbcResultSet implements ResultSet { } /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Override public <T> T unwrap(Class<T> iface) throws SQLException { if (!isWrapperFor(iface)) throw new SQLException("Result set is not a wrapper for " + iface.getName()); @@ -1835,7 +1834,6 @@ public class JdbcResultSet implements ResultSet { * @return Object field value. * @throws SQLException In case of error. */ - @SuppressWarnings("unchecked") private Object getValue(int colIdx) throws SQLException { ensureNotClosed(); ensureHasCurrentRow(); http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/jdbc2/JdbcResultSetMetadata.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/jdbc2/JdbcResultSetMetadata.java b/modules/core/src/main/java/org/apache/ignite/internal/jdbc2/JdbcResultSetMetadata.java index ce8c269..42392a8 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/jdbc2/JdbcResultSetMetadata.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/jdbc2/JdbcResultSetMetadata.java @@ -156,7 +156,6 @@ public class JdbcResultSetMetadata implements ResultSetMetaData { } /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Override public <T> T unwrap(Class<T> iface) throws SQLException { if (!isWrapperFor(iface)) throw new SQLException("Result set meta data is not a wrapper for " + iface.getName()); http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/jdbc2/JdbcStatement.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/jdbc2/JdbcStatement.java b/modules/core/src/main/java/org/apache/ignite/internal/jdbc2/JdbcStatement.java index f87c162..5700a65 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/jdbc2/JdbcStatement.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/jdbc2/JdbcStatement.java @@ -600,7 +600,6 @@ public class JdbcStatement implements Statement { } /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Override public <T> T unwrap(Class<T> iface) throws SQLException { if (!isWrapperFor(iface)) throw new SQLException("Statement is not a wrapper for " + iface.getName()); http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoManager.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoManager.java b/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoManager.java index 491baa2..09c7b96 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoManager.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoManager.java @@ -257,7 +257,6 @@ public class GridIoManager extends GridManagerAdapter<CommunicationSpi<Serializa } /** {@inheritDoc} */ - @SuppressWarnings("deprecation") @Override public void start() throws IgniteCheckedException { startSpi(); @@ -722,10 +721,9 @@ public class GridIoManager extends GridManagerAdapter<CommunicationSpi<Serializa } /** {@inheritDoc} */ - @SuppressWarnings({"deprecation", "SynchronizationOnLocalVariableOrMethodParameter"}) + @SuppressWarnings({"SynchronizationOnLocalVariableOrMethodParameter"}) @Override public void onKernalStart0() throws IgniteCheckedException { discoLsnr = new GridLocalEventListener() { - @SuppressWarnings({"TooBroadScope"}) @Override public void onEvent(Event evt) { assert evt instanceof DiscoveryEvent : "Invalid event: " + evt; @@ -1182,7 +1180,6 @@ public class GridIoManager extends GridManagerAdapter<CommunicationSpi<Serializa * @param msg Message. * @param nodeId Node ID. */ - @SuppressWarnings("deprecation") private void processRegularMessage0(GridIoMessage msg, UUID nodeId) { GridMessageListener lsnr = listenerGet0(msg.topic()); @@ -1695,7 +1692,6 @@ public class GridIoManager extends GridManagerAdapter<CommunicationSpi<Serializa * @param plc Type of processing. * @throws IgniteCheckedException Thrown in case of any errors. */ - @SuppressWarnings("TypeMayBeWeakened") public void sendToGridTopic(UUID nodeId, GridTopic topic, Message msg, byte plc) throws IgniteCheckedException { ClusterNode node = ctx.discovery().node(nodeId); @@ -1982,7 +1978,6 @@ public class GridIoManager extends GridManagerAdapter<CommunicationSpi<Serializa * @param topic Topic to subscribe to. * @param p Message predicate. */ - @SuppressWarnings("unchecked") public void addUserMessageListener(@Nullable final Object topic, @Nullable final IgniteBiPredicate<UUID, ?> p) { if (p != null) { try { @@ -2004,7 +1999,6 @@ public class GridIoManager extends GridManagerAdapter<CommunicationSpi<Serializa * @param topic Topic to unsubscribe from. * @param p Message predicate. */ - @SuppressWarnings("unchecked") public void removeUserMessageListener(@Nullable Object topic, IgniteBiPredicate<UUID, ?> p) { try { removeMessageListener(TOPIC_COMM_USER, @@ -2019,7 +2013,6 @@ public class GridIoManager extends GridManagerAdapter<CommunicationSpi<Serializa * @param topic Listener's topic. * @param lsnr Listener to add. */ - @SuppressWarnings({"TypeMayBeWeakened", "deprecation"}) public void addMessageListener(GridTopic topic, GridMessageListener lsnr) { addMessageListener((Object)topic, lsnr); } @@ -2042,7 +2035,6 @@ public class GridIoManager extends GridManagerAdapter<CommunicationSpi<Serializa * @param topic Listener's topic. * @param lsnr Listener to add. */ - @SuppressWarnings({"deprecation"}) public void addMessageListener(Object topic, final GridMessageListener lsnr) { assert lsnr != null; assert topic != null; @@ -2133,7 +2125,6 @@ public class GridIoManager extends GridManagerAdapter<CommunicationSpi<Serializa * @param lsnr Listener to remove. * @return Whether or not the lsnr was removed. */ - @SuppressWarnings("deprecation") public boolean removeMessageListener(GridTopic topic, @Nullable GridMessageListener lsnr) { return removeMessageListener((Object)topic, lsnr); } @@ -2143,7 +2134,6 @@ public class GridIoManager extends GridManagerAdapter<CommunicationSpi<Serializa * @param lsnr Listener to remove. * @return Whether or not the lsnr was removed. */ - @SuppressWarnings({"deprecation"}) public boolean removeMessageListener(Object topic, @Nullable GridMessageListener lsnr) { assert topic != null; @@ -2443,8 +2433,8 @@ public class GridIoManager extends GridManagerAdapter<CommunicationSpi<Serializa } /** {@inheritDoc} */ - @SuppressWarnings({"ConstantConditions", - "OverlyStrongTypeCast"}) + @SuppressWarnings({"ConstantConditions" + }) @Override public void onMessage(UUID nodeId, Object msg, byte plc) { if (!(msg instanceof GridIoUserMessage)) { U.error(log, "Received unknown message (potentially fatal problem): " + msg); http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/managers/deployment/GridDeployment.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/managers/deployment/GridDeployment.java b/modules/core/src/main/java/org/apache/ignite/internal/managers/deployment/GridDeployment.java index 9b486e9..e93066c 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/managers/deployment/GridDeployment.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/managers/deployment/GridDeployment.java @@ -338,7 +338,6 @@ public class GridDeployment extends GridMetadataAwareAdapter implements GridDepl * @return Annotation value. * @param <T> Annotation class. */ - @SuppressWarnings("unchecked") public <T extends Annotation> T annotation(Class<?> cls, Class<T> annCls) { ConcurrentMap<Class<? extends Annotation>, GridTuple<Annotation>> clsAnns = anns.get(cls); @@ -368,7 +367,6 @@ public class GridDeployment extends GridMetadataAwareAdapter implements GridDepl * @param taskCls Task class. * @return {@code True} if task is internal. */ - @SuppressWarnings("unchecked") public boolean internalTask(@Nullable ComputeTask task, Class<?> taskCls) { assert taskCls != null; @@ -392,7 +390,6 @@ public class GridDeployment extends GridMetadataAwareAdapter implements GridDepl * @param taskCls Task class. * @return {@code True} if task is internal. */ - @SuppressWarnings("unchecked") public boolean visorManagementTask(@Nullable ComputeTask task, @NotNull Class<?> taskCls) { return annotation(task instanceof GridPeerDeployAware ? ((GridPeerDeployAware)task).deployClass() : taskCls, http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/managers/deployment/GridDeploymentLocalStore.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/managers/deployment/GridDeploymentLocalStore.java b/modules/core/src/main/java/org/apache/ignite/internal/managers/deployment/GridDeploymentLocalStore.java index b27cc4b..10f0695 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/managers/deployment/GridDeploymentLocalStore.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/managers/deployment/GridDeploymentLocalStore.java @@ -430,7 +430,6 @@ class GridDeploymentLocalStore extends GridDeploymentStoreAdapter { * @param clsLdr Class loader. * @param recordEvt Flag indicating whether to record events. */ - @SuppressWarnings({"unchecked"}) private void recordDeployFailed(Class<?> cls, ClassLoader clsLdr, boolean recordEvt) { assert cls != null; assert clsLdr != null; http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/managers/eventstorage/GridEventStorageManager.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/managers/eventstorage/GridEventStorageManager.java b/modules/core/src/main/java/org/apache/ignite/internal/managers/eventstorage/GridEventStorageManager.java index e1ea031..5af3495 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/managers/eventstorage/GridEventStorageManager.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/managers/eventstorage/GridEventStorageManager.java @@ -413,7 +413,6 @@ public class GridEventStorageManager extends GridManagerAdapter<EventStorageSpi> * * @param types Events to disable. */ - @SuppressWarnings("deprecation") public synchronized void disableEvents(int[] types) { assert types != null; @@ -887,7 +886,6 @@ public class GridEventStorageManager extends GridManagerAdapter<EventStorageSpi> * @param p Grid event predicate. * @return Collection of grid events. */ - @SuppressWarnings("unchecked") public <T extends Event> Collection<T> localEvents(IgnitePredicate<T> p) throws IgniteCheckedException { assert p != null; @@ -949,7 +947,6 @@ public class GridEventStorageManager extends GridManagerAdapter<EventStorageSpi> * @return Collection of events. * @throws IgniteCheckedException Thrown in case of any errors. */ - @SuppressWarnings({"deprecation"}) private <T extends Event> List<T> query(IgnitePredicate<T> p, Collection<? extends ClusterNode> nodes, long timeout) throws IgniteCheckedException { assert p != null; @@ -988,7 +985,6 @@ public class GridEventStorageManager extends GridManagerAdapter<EventStorageSpi> }; GridMessageListener resLsnr = new GridMessageListener() { - @SuppressWarnings("deprecation") @Override public void onMessage(UUID nodeId, Object msg, byte plc) { assert nodeId != null; assert msg != null; http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/marshaller/optimized/OptimizedMarshaller.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/marshaller/optimized/OptimizedMarshaller.java b/modules/core/src/main/java/org/apache/ignite/internal/marshaller/optimized/OptimizedMarshaller.java index 66461de..afcabce 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/marshaller/optimized/OptimizedMarshaller.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/marshaller/optimized/OptimizedMarshaller.java @@ -212,7 +212,6 @@ public class OptimizedMarshaller extends AbstractNodeNameAwareMarshaller { } /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Override protected <T> T unmarshal0(InputStream in, @Nullable ClassLoader clsLdr) throws IgniteCheckedException { assert in != null; @@ -242,7 +241,6 @@ public class OptimizedMarshaller extends AbstractNodeNameAwareMarshaller { } /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Override protected <T> T unmarshal0(byte[] arr, @Nullable ClassLoader clsLdr) throws IgniteCheckedException { assert arr != null; http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/marshaller/optimized/OptimizedObjectInputStream.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/marshaller/optimized/OptimizedObjectInputStream.java b/modules/core/src/main/java/org/apache/ignite/internal/marshaller/optimized/OptimizedObjectInputStream.java index 2c87c75..2311439 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/marshaller/optimized/OptimizedObjectInputStream.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/marshaller/optimized/OptimizedObjectInputStream.java @@ -385,7 +385,6 @@ class OptimizedObjectInputStream extends ObjectInputStream { * @throws ClassNotFoundException If class not found. * @throws IOException In case of error. */ - @SuppressWarnings("unchecked") <T> T[] readArray(Class<T> compType) throws ClassNotFoundException, IOException { int len = in.readInt(); @@ -678,7 +677,6 @@ class OptimizedObjectInputStream extends ObjectInputStream { * @throws ClassNotFoundException If class not found. * @throws IOException In case of error. */ - @SuppressWarnings("unchecked") HashSet<?> readHashSet(long mapFieldOff) throws ClassNotFoundException, IOException { try { HashSet<Object> set = (HashSet<Object>)GridUnsafe.allocateInstance(HashSet.class); @@ -750,7 +748,6 @@ class OptimizedObjectInputStream extends ObjectInputStream { * @throws ClassNotFoundException If class not found. * @throws IOException In case of error. */ - @SuppressWarnings("unchecked") LinkedHashSet<?> readLinkedHashSet(long mapFieldOff) throws ClassNotFoundException, IOException { try { LinkedHashSet<Object> set = (LinkedHashSet<Object>)GridUnsafe.allocateInstance(LinkedHashSet.class); @@ -1252,7 +1249,6 @@ class OptimizedObjectInputStream extends ObjectInputStream { * @param dflt Default value. * @return Value. */ - @SuppressWarnings("unchecked") private <T> T value(String name, T dflt) { return objs[fieldInfo.getIndex(name)] != null ? (T)objs[fieldInfo.getIndex(name)] : dflt; } http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/affinity/GridAffinityProcessor.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/affinity/GridAffinityProcessor.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/affinity/GridAffinityProcessor.java index 07beb14..30bf113 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/affinity/GridAffinityProcessor.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/affinity/GridAffinityProcessor.java @@ -559,7 +559,6 @@ public class GridAffinityProcessor extends GridProcessorAdapter { * @return Affinity map. * @throws IgniteCheckedException If failed. */ - @SuppressWarnings({"unchecked"}) private <K> Map<ClusterNode, Collection<K>> affinityMap(AffinityInfo aff, Collection<? extends K> keys) throws IgniteCheckedException { assert aff != null; http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/authentication/IgniteAuthenticationProcessor.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/authentication/IgniteAuthenticationProcessor.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/authentication/IgniteAuthenticationProcessor.java index c7c5885..98f4201 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/authentication/IgniteAuthenticationProcessor.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/authentication/IgniteAuthenticationProcessor.java @@ -383,7 +383,6 @@ public class IgniteAuthenticationProcessor extends GridProcessorAdapter implemen } /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Override public void onReadyForRead(ReadOnlyMetastorage metastorage) throws IgniteCheckedException { if (!ctx.clientNode()) { users = new ConcurrentHashMap<>(); @@ -1309,7 +1308,6 @@ public class IgniteAuthenticationProcessor extends GridProcessorAdapter implemen } /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Override protected void body() throws InterruptedException, IgniteInterruptedCheckedException { if (ctx.clientNode()) return; http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheEntryImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheEntryImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheEntryImpl.java index 60eba21..5ba15da 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheEntryImpl.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheEntryImpl.java @@ -79,7 +79,6 @@ public class CacheEntryImpl<K, V> implements Cache.Entry<K, V>, Externalizable { } /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Override public <T> T unwrap(Class<T> cls) { if (cls.isAssignableFrom(getClass())) return cls.cast(this); http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheEntryImpl0.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheEntryImpl0.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheEntryImpl0.java index 1e97f0c..bce4e92 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheEntryImpl0.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheEntryImpl0.java @@ -47,7 +47,6 @@ public class CacheEntryImpl0<K, V> implements Cache.Entry<K, V> { } /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Override public <T> T unwrap(Class<T> cls) { if(cls.isAssignableFrom(getClass())) return cls.cast(this); http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheEvictableEntryImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheEvictableEntryImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheEvictableEntryImpl.java index 89f06dc..1de5906 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheEvictableEntryImpl.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheEvictableEntryImpl.java @@ -197,7 +197,6 @@ public class CacheEvictableEntryImpl<K, V> implements EvictableEntry<K, V> { } /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Override public <T> T unwrap(Class<T> clazz) { if (clazz.isAssignableFrom(IgniteCache.class)) return (T)cached.context().grid().cache(cached.context().name()); @@ -214,7 +213,6 @@ public class CacheEvictableEntryImpl<K, V> implements EvictableEntry<K, V> { } /** {@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/CacheInvokeEntry.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheInvokeEntry.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheInvokeEntry.java index dddc735..44a51ec 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheInvokeEntry.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheInvokeEntry.java @@ -170,7 +170,6 @@ public class CacheInvokeEntry<K, V> extends CacheLazyEntry<K, V> implements Muta } /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Override public <T> T unwrap(Class<T> cls) { if (cls.isAssignableFrom(CacheEntry.class) && ver != null) return (T)new CacheEntryImplEx<>(getKey(), getValue(), ver); http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheInvokeResult.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheInvokeResult.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheInvokeResult.java index 2e6d64a..7c0f256 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheInvokeResult.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheInvokeResult.java @@ -119,7 +119,6 @@ public class CacheInvokeResult<T> implements EntryProcessorResult<T>, Externaliz } /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Override public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException { res = (T)in.readObject(); http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheLazyEntry.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheLazyEntry.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheLazyEntry.java index 4463dc8..1a1645f 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheLazyEntry.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheLazyEntry.java @@ -143,7 +143,6 @@ public class CacheLazyEntry<K, V> extends CacheInterceptorEntry<K, V> { * @param keepBinary Flag to keep binary if needed. * @return the value corresponding to this entry */ - @SuppressWarnings("unchecked") public V getValue(boolean keepBinary) { if (val == null) val = (V)cctx.unwrapBinaryIfNeeded(valObj, keepBinary, true); @@ -187,7 +186,6 @@ public class CacheLazyEntry<K, V> extends CacheInterceptorEntry<K, V> { } /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Override public <T> T unwrap(Class<T> cls) { if (cls.isAssignableFrom(Ignite.class)) return (T)cctx.kernalContext().grid(); http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheObjectImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheObjectImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheObjectImpl.java index b29c19e..6ca700b 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheObjectImpl.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheObjectImpl.java @@ -54,7 +54,6 @@ public class CacheObjectImpl extends CacheObjectAdapter { } /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Nullable @Override public <T> T value(CacheObjectValueContext ctx, boolean cpy) { cpy = cpy && needCopy(ctx); http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheObjectUtils.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheObjectUtils.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheObjectUtils.java index aeca79e..ed2d324 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheObjectUtils.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheObjectUtils.java @@ -162,7 +162,6 @@ public class CacheObjectUtils { * @param o Object to unwrap. * @return Unwrapped object. */ - @SuppressWarnings("unchecked") private static Object unwrapBinary(CacheObjectValueContext ctx, Object o, boolean keepBinary, boolean cpy) { if (o == null) return o; http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CachePartialUpdateCheckedException.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CachePartialUpdateCheckedException.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CachePartialUpdateCheckedException.java index 9d2686c..220d642 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CachePartialUpdateCheckedException.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CachePartialUpdateCheckedException.java @@ -48,7 +48,6 @@ public class CachePartialUpdateCheckedException extends IgniteCheckedException { * Gets collection of failed keys. * @return Collection of failed keys. */ - @SuppressWarnings("unchecked") public synchronized <K> Collection<K> failedKeys() { return new LinkedHashSet<>((Collection<K>)failedKeys); } http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheAdapter.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheAdapter.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheAdapter.java index 4d93726..a1c403b 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheAdapter.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheAdapter.java @@ -485,7 +485,6 @@ public abstract class GridCacheAdapter<K, V> implements IgniteInternalCache<K, V } /** {@inheritDoc} */ - @SuppressWarnings({"unchecked", "RedundantCast"}) @Override public final <K1, V1> IgniteInternalCache<K1, V1> cache() { return (IgniteInternalCache<K1, V1>)this; } @@ -1712,7 +1711,6 @@ public abstract class GridCacheAdapter<K, V> implements IgniteInternalCache<K, V * @param map Result map. * @return Map with values returned by cache interceptor.. */ - @SuppressWarnings("IfMayBeConditional") private Map<K, V> interceptGet(@Nullable Collection<? extends K> keys, Map<K, V> map) { if (F.isEmpty(keys)) return map; @@ -1753,7 +1751,6 @@ public abstract class GridCacheAdapter<K, V> implements IgniteInternalCache<K, V * @param map Result map. * @return Map with values returned by cache interceptor.. */ - @SuppressWarnings("IfMayBeConditional") private Collection<CacheEntry<K, V>> interceptGetEntries( @Nullable Collection<? extends K> keys, Map<K, EntryGetResult> map) { if (F.isEmpty(keys)) { @@ -3135,7 +3132,6 @@ public abstract class GridCacheAdapter<K, V> implements IgniteInternalCache<K, V } /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Override public void removeAll() throws IgniteCheckedException { assert ctx.isLocal(); @@ -4213,7 +4209,7 @@ public abstract class GridCacheAdapter<K, V> implements IgniteInternalCache<K, V * @return Operation result. * @throws IgniteCheckedException If operation failed. */ - @SuppressWarnings({"TypeMayBeWeakened", "ErrorNotRethrown", "AssignmentToCatchBlockParameter"}) + @SuppressWarnings({"ErrorNotRethrown", "AssignmentToCatchBlockParameter"}) @Nullable private <T> T syncOp(SyncOp<T> op) throws IgniteCheckedException { checkJta(); @@ -6219,7 +6215,6 @@ public abstract class GridCacheAdapter<K, V> implements IgniteInternalCache<K, V } /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Override public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException { p = (IgniteBiPredicate<K, 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/GridCacheContext.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheContext.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheContext.java index 426a29c..19c01b2 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheContext.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheContext.java @@ -1889,7 +1889,6 @@ public class GridCacheContext<K, V> implements Externalizable { * @param cpy Copy flag. * @param ver GridCacheVersion. */ - @SuppressWarnings("unchecked") public <K1, V1> void addResult(Map<K1, V1> map, KeyCacheObject key, CacheObject val, @@ -1915,7 +1914,6 @@ public class GridCacheContext<K, V> implements Externalizable { * @param cpy Copy flag. * @param needVer Need version flag. */ - @SuppressWarnings("unchecked") public <K1, V1> void addResult(Map<K1, V1> map, KeyCacheObject key, EntryGetResult getRes, @@ -1943,7 +1941,6 @@ public class GridCacheContext<K, V> implements Externalizable { * @param ttl Entry TTL. * @param needVer Need version flag. */ - @SuppressWarnings("unchecked") public <K1, V1> void addResult(Map<K1, V1> map, KeyCacheObject key, CacheObject val, @@ -1991,7 +1988,6 @@ public class GridCacheContext<K, V> implements Externalizable { * @param needVer Need version flag. * @return EntryGetResult or value. */ - @SuppressWarnings("unchecked") private <V1> V1 createValue(final GridCacheVersion ver, final long expireTime, final long ttl, http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheEvictionManager.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheEvictionManager.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheEvictionManager.java index a1bf0ff..5a3453a 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheEvictionManager.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheEvictionManager.java @@ -357,7 +357,6 @@ public class GridCacheEvictionManager extends GridCacheManagerAdapter implements * @param near Near flag. * @throws IgniteCheckedException If registration failed. */ - @SuppressWarnings("unchecked") private void registerMbean(Object obj, @Nullable String cacheName, boolean near) throws IgniteCheckedException { if (U.IGNITE_MBEANS_DISABLED) http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheIoManager.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheIoManager.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheIoManager.java index 2f29ffb..710931f 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheIoManager.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheIoManager.java @@ -543,7 +543,6 @@ public class GridCacheIoManager extends GridCacheSharedManagerAdapter { } /** {@inheritDoc} */ - @SuppressWarnings("BusyWait") @Override protected void onKernalStop0(boolean cancel) { cctx.gridIO().removeMessageListener(TOPIC_CACHE); @@ -569,7 +568,6 @@ public class GridCacheIoManager extends GridCacheSharedManagerAdapter { * @param c Handler closure. * @param plc Message policy. */ - @SuppressWarnings({"ConstantConditions"}) private void onMessage0(final UUID nodeId, final GridCacheMessage cacheMsg, final IgniteBiInClosure<UUID, GridCacheMessage> c, byte plc) { try { @@ -1405,7 +1403,6 @@ public class GridCacheIoManager extends GridCacheSharedManagerAdapter { * @param c Handler. * @param msgHandlers Message handlers. */ - @SuppressWarnings({"unchecked"}) private void addHandler( int hndId, Class<? extends GridCacheMessage> type, @@ -1537,7 +1534,6 @@ public class GridCacheIoManager extends GridCacheSharedManagerAdapter { * @param topic Topic. * @param c Handler. */ - @SuppressWarnings({"unchecked"}) private void addOrderedHandler(GridCacheSharedContext cctx, boolean cacheGrp, Object topic, IgniteBiInClosure<UUID, ? extends GridCacheMessage> c) { MessageHandlers msgHandlers = cacheGrp ? grpHandlers : cacheHandlers; http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheMapEntry.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheMapEntry.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheMapEntry.java index b5f9dfc..881e868 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheMapEntry.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheMapEntry.java @@ -615,7 +615,6 @@ public abstract class GridCacheMapEntry extends GridMetadataAwareAdapter impleme * @return Read value. * @throws IgniteCheckedException If failed. */ - @SuppressWarnings({"RedundantTypeArguments"}) @Nullable protected Object readThrough(@Nullable IgniteInternalTx tx, KeyCacheObject key, boolean reload, UUID subjId, String taskName) throws IgniteCheckedException { return cctx.store().load(tx, key); @@ -710,7 +709,7 @@ public abstract class GridCacheMapEntry extends GridMetadataAwareAdapter impleme } /** {@inheritDoc} */ - @SuppressWarnings({"unchecked", "RedundantTypeArguments", "TooBroadScope"}) + @SuppressWarnings({"TooBroadScope"}) private Object innerGet0( GridCacheVersion nextVer, IgniteInternalTx tx, @@ -979,7 +978,7 @@ public abstract class GridCacheMapEntry extends GridMetadataAwareAdapter impleme } /** {@inheritDoc} */ - @SuppressWarnings({"unchecked", "TooBroadScope"}) + @SuppressWarnings({"TooBroadScope"}) @Nullable @Override public final CacheObject innerReload() throws IgniteCheckedException, GridCacheEntryRemovedException { CU.checkStore(cctx); @@ -3306,7 +3305,6 @@ public abstract class GridCacheMapEntry extends GridMetadataAwareAdapter impleme } /** {@inheritDoc} */ - @SuppressWarnings({"RedundantTypeArguments"}) @Override public boolean initialValue( CacheObject val, GridCacheVersion ver, @@ -4148,7 +4146,6 @@ public abstract class GridCacheMapEntry extends GridMetadataAwareAdapter impleme } /** {@inheritDoc} */ - @SuppressWarnings({"IfMayBeConditional"}) @Override public long expireTime() throws GridCacheEntryRemovedException { IgniteTxLocalAdapter tx = currentTx(); @@ -4172,7 +4169,6 @@ public abstract class GridCacheMapEntry extends GridMetadataAwareAdapter impleme } /** {@inheritDoc} */ - @SuppressWarnings({"IfMayBeConditional"}) @Override public long ttl() throws GridCacheEntryRemovedException { IgniteTxLocalAdapter tx = currentTx(); @@ -4419,7 +4415,6 @@ public abstract class GridCacheMapEntry extends GridMetadataAwareAdapter impleme } /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Override public <K, V> Cache.Entry<K, V> wrap() { try { IgniteInternalTx tx = cctx.tm().userTx(); @@ -5308,7 +5303,6 @@ public abstract class GridCacheMapEntry extends GridMetadataAwareAdapter impleme } /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Override public void apply(IgniteInternalFuture lockFut) { WALPointer logPtr = null; boolean valid; @@ -5666,13 +5660,11 @@ public abstract class GridCacheMapEntry extends GridMetadataAwareAdapter impleme } /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Override public V getValue() { return (V)cctx.cacheObjectContext().unwrapBinaryIfNeeded(peekVisibleValue(), keepBinary, true); } /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Override public <T> T unwrap(Class<T> cls) { if (cls.isAssignableFrom(IgniteCache.class)) return (T)cctx.grid().cache(cctx.name()); @@ -6687,7 +6679,6 @@ public abstract class GridCacheMapEntry extends GridMetadataAwareAdapter impleme * @param invokeEntry Entry for {@link EntryProcessor}. * @return Entry processor return value. */ - @SuppressWarnings("unchecked") private IgniteBiTuple<Object, Exception> runEntryProcessor(CacheInvokeEntry<Object, Object> invokeEntry) { EntryProcessor<Object, Object, ?> entryProcessor = (EntryProcessor<Object, Object, ?>)writeObj; http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheMvccManager.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheMvccManager.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheMvccManager.java index 0281631..bd2b58d 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheMvccManager.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheMvccManager.java @@ -154,7 +154,6 @@ public class GridCacheMvccManager extends GridCacheSharedManagerAdapter { @GridToStringExclude private final GridCacheLockCallback cb = new GridCacheLockCallback() { /** {@inheritDoc} */ - @SuppressWarnings({"unchecked"}) @Override public void onOwnerChanged(final GridCacheEntryEx entry, final GridCacheMvccCandidate owner) { int nested = nestedLsnrCalls.get(); @@ -719,7 +718,6 @@ public class GridCacheMvccManager extends GridCacheSharedManagerAdapter { * @param futId Future ID. * @return Future. */ - @SuppressWarnings({"unchecked"}) @Nullable public GridCacheVersionedFuture<?> versionedFuture(GridCacheVersion ver, IgniteUuid futId) { Collection<GridCacheVersionedFuture<?>> futs = this.verFuts.get(ver); @@ -748,7 +746,6 @@ public class GridCacheMvccManager extends GridCacheSharedManagerAdapter { * @param ver Lock ID. * @return Futures. */ - @SuppressWarnings({"unchecked"}) @Nullable public Collection<GridCacheVersionedFuture<?>> futuresForVersion(GridCacheVersion ver) { Collection<GridCacheVersionedFuture<?>> futs = this.verFuts.get(ver); @@ -1073,7 +1070,6 @@ public class GridCacheMvccManager extends GridCacheSharedManagerAdapter { * @param topVer Topology version. * @return Future that signals when all locks for given partitions are released. */ - @SuppressWarnings({"unchecked"}) public IgniteInternalFuture<?> finishLocks(AffinityTopologyVersion topVer) { assert topVer.compareTo(AffinityTopologyVersion.ZERO) > 0; return finishLocks(null, topVer); @@ -1143,7 +1139,6 @@ public class GridCacheMvccManager extends GridCacheSharedManagerAdapter { * * @return Finish update future. */ - @SuppressWarnings("unchecked") public IgniteInternalFuture<?> finishDataStreamerUpdates(AffinityTopologyVersion topVer) { GridCompoundFuture<Void, Object> res = new CacheObjectsReleaseFuture<>("DataStreamer", topVer); @@ -1163,7 +1158,6 @@ public class GridCacheMvccManager extends GridCacheSharedManagerAdapter { * @param topVer Topology version. * @return Future that signals when all locks for given keys are released. */ - @SuppressWarnings("unchecked") public IgniteInternalFuture<?> finishKeys(Collection<KeyCacheObject> keys, final int cacheId, AffinityTopologyVersion topVer) { http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProcessor.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProcessor.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProcessor.java index 5bd9eb8..6ab5cfe 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProcessor.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProcessor.java @@ -4533,7 +4533,6 @@ public class GridCacheProcessor extends GridProcessorAdapter { * @param <V> type of values. * @return Cache instance for given name. */ - @SuppressWarnings("unchecked") public <K, V> IgniteInternalCache<K, V> cache(String name) { assert name != null; @@ -4608,7 +4607,6 @@ public class GridCacheProcessor extends GridProcessorAdapter { * @return Cache instance for given name. * @throws IgniteCheckedException If failed. */ - @SuppressWarnings("unchecked") public <K, V> IgniteInternalCache<K, V> getOrStartCache( String name, CacheConfiguration ccfg @@ -4698,7 +4696,6 @@ public class GridCacheProcessor extends GridProcessorAdapter { * @param <V> type of values. * @return Cache instance for given name. */ - @SuppressWarnings("unchecked") public <K, V> IgniteInternalCache<K, V> publicCache(String name) { assert name != null; @@ -4740,7 +4737,6 @@ public class GridCacheProcessor extends GridProcessorAdapter { * @return Cache instance for given name. * @throws IgniteCheckedException If failed. */ - @SuppressWarnings({"unchecked", "ConstantConditions"}) @Nullable public <K, V> IgniteCacheProxy<K, V> publicJCache(String cacheName, boolean failIfNotStarted, boolean checkThreadTx) throws IgniteCheckedException { @@ -4966,7 +4962,6 @@ public class GridCacheProcessor extends GridProcessorAdapter { * @param <V> type of values. * @return Cache instance for given name. */ - @SuppressWarnings("unchecked") public <K, V> GridCacheAdapter<K, V> internalCache(String name) { assert name != null; @@ -5065,7 +5060,6 @@ public class GridCacheProcessor extends GridProcessorAdapter { * @param near Near flag. * @throws IgniteCheckedException If registration failed. */ - @SuppressWarnings("unchecked") private void registerMbean(Object obj, @Nullable String cacheName, boolean near) throws IgniteCheckedException { if (U.IGNITE_MBEANS_DISABLED) http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProxyImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProxyImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProxyImpl.java index fa9f3cb..94eb857 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProxyImpl.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProxyImpl.java @@ -299,7 +299,6 @@ public class GridCacheProxyImpl<K, V> implements IgniteInternalCache<K, V>, Exte } /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Override public <K1, V1> GridCacheProxyImpl<K1, V1> keepBinary() { if (opCtx != null && opCtx.isKeepBinary()) return (GridCacheProxyImpl<K1, V1>)this; @@ -1625,7 +1624,6 @@ public class GridCacheProxyImpl<K, V> implements IgniteInternalCache<K, V>, Exte } /** {@inheritDoc} */ - @SuppressWarnings({"unchecked"}) @Override public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException { ctx = (GridCacheContext<K, V>)in.readObject(); delegate = (IgniteInternalCache<K, 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/GridCacheReturn.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheReturn.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheReturn.java index 22aa425..0762dfc 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheReturn.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheReturn.java @@ -122,7 +122,6 @@ public class GridCacheReturn implements Externalizable, Message { /** * @return Value. */ - @SuppressWarnings("unchecked") @Nullable public <V> V value() { return (V)v; } @@ -221,7 +220,6 @@ public class GridCacheReturn implements Externalizable, Message { * @param err Error. * @param keepBinary Keep binary. */ - @SuppressWarnings("unchecked") public synchronized void addEntryProcessResult( GridCacheContext cctx, KeyCacheObject key, @@ -288,7 +286,6 @@ public class GridCacheReturn implements Externalizable, Message { /** * @param other Other result to merge with. */ - @SuppressWarnings("unchecked") public synchronized void mergeEntryProcessResults(GridCacheReturn other) { assert invokeRes || v == null : "Invalid state to merge: " + this; assert other.invokeRes; http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheUtilityKey.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheUtilityKey.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheUtilityKey.java index affa6ce..3d66950 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheUtilityKey.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheUtilityKey.java @@ -27,7 +27,6 @@ public abstract class GridCacheUtilityKey<K extends GridCacheUtilityKey> impleme private static final long serialVersionUID = 0L; /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Override public final boolean equals(Object obj) { return obj == this || obj != null && obj.getClass() == getClass() && equalsx((K)obj); } http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheUtils.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheUtils.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheUtils.java index ebc1d11..bf1c359 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheUtils.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheUtils.java @@ -455,7 +455,6 @@ public class GridCacheUtils { */ public static <K, V> IgniteClosure<Integer, IgnitePredicate<Cache.Entry<K, V>>[]> factory() { return new IgniteClosure<Integer, IgnitePredicate<Cache.Entry<K, V>>[]>() { - @SuppressWarnings({"unchecked"}) @Override public IgnitePredicate<Cache.Entry<K, V>>[] apply(Integer len) { return (IgnitePredicate<Cache.Entry<K, V>>[])(len == 0 ? EMPTY : new IgnitePredicate[len]); } @@ -527,7 +526,6 @@ public class GridCacheUtils { /** * @return Empty filter. */ - @SuppressWarnings({"unchecked"}) public static <K, V> IgnitePredicate<Cache.Entry<K, V>>[] empty() { return (IgnitePredicate<Cache.Entry<K, V>>[])EMPTY_FILTER; } @@ -535,7 +533,6 @@ public class GridCacheUtils { /** * @return Empty filter. */ - @SuppressWarnings({"unchecked"}) public static CacheEntryPredicate[] empty0() { return EMPTY_FILTER0; } @@ -550,7 +547,6 @@ public class GridCacheUtils { /** * @return Closure which converts transaction entry xid to XID version. */ - @SuppressWarnings( {"unchecked"}) public static IgniteClosure<IgniteInternalTx, GridCacheVersion> tx2xidVersion() { return (IgniteClosure<IgniteInternalTx, GridCacheVersion>)tx2xidVer; } @@ -566,7 +562,6 @@ public class GridCacheUtils { /** * @return Closure that converts entry info to key. */ - @SuppressWarnings({"unchecked"}) public static <K, V> IgniteClosure<GridCacheEntryInfo, K> info2Key() { return (IgniteClosure<GridCacheEntryInfo, K>)info2key; } @@ -793,7 +788,6 @@ public class GridCacheUtils { * @return Buffer that contains obtained byte array. * @throws IgniteCheckedException If marshalling failed. */ - @SuppressWarnings("unchecked") public static byte[] marshal(GridCacheContext ctx, Object obj) throws IgniteCheckedException { assert ctx != null; http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheOffheapManagerImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheOffheapManagerImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheOffheapManagerImpl.java index 5997f57..0976f63 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheOffheapManagerImpl.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheOffheapManagerImpl.java @@ -664,7 +664,6 @@ public class IgniteCacheOffheapManagerImpl implements IgniteCacheOffheapManager } /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Override @Nullable public CacheDataRow read(GridCacheMapEntry entry) throws IgniteCheckedException { KeyCacheObject key = entry.key(); @@ -763,7 +762,6 @@ public class IgniteCacheOffheapManagerImpl implements IgniteCacheOffheapManager * * @param readers {@code True} to clear readers. */ - @SuppressWarnings("unchecked") @Override public void clearCache(GridCacheContext cctx, boolean readers) { GridCacheVersion obsoleteVer = null; http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheProxy.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheProxy.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheProxy.java index ccf5cb4..886dac5 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheProxy.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheProxy.java @@ -73,14 +73,12 @@ public interface IgniteCacheProxy<K, V> extends IgniteCache<K, V>, Externalizabl * * @return Projection for binary objects. */ - @SuppressWarnings("unchecked") public <K1, V1> IgniteCache<K1, V1> keepBinary(); /** * @param dataCenterId Data center ID. * @return Projection for data center id. */ - @SuppressWarnings("unchecked") public IgniteCache<K, V> withDataCenterId(byte dataCenterId); /** http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheProxyImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheProxyImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheProxyImpl.java index 504c375..a6a1fc1 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheProxyImpl.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheProxyImpl.java @@ -661,7 +661,6 @@ public class IgniteCacheProxyImpl<K, V> extends AsyncSupportAdapter<IgniteCache< } /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Override public <R> QueryCursor<R> query(Query<R> qry) { A.notNull(qry, "qry"); try { @@ -1628,7 +1627,6 @@ public class IgniteCacheProxyImpl<K, V> extends AsyncSupportAdapter<IgniteCache< } /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Override public <T> T unwrap(Class<T> clazz) { if (clazz.isAssignableFrom(getClass())) return (T)this; @@ -1862,7 +1860,6 @@ public class IgniteCacheProxyImpl<K, V> extends AsyncSupportAdapter<IgniteCache< } /** {@inheritDoc} */ - @SuppressWarnings({"unchecked"}) @Override public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException { ctx = (GridCacheContext<K, 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/KeyCacheObjectImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/KeyCacheObjectImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/KeyCacheObjectImpl.java index 1f4e790..92e8a4f 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/KeyCacheObjectImpl.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/KeyCacheObjectImpl.java @@ -93,7 +93,6 @@ public class KeyCacheObjectImpl extends CacheObjectAdapter implements KeyCacheOb } /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Nullable @Override public <T> T value(CacheObjectValueContext ctx, boolean cpy) { assert val != null; http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/affinity/GridCacheAffinityProxy.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/affinity/GridCacheAffinityProxy.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/affinity/GridCacheAffinityProxy.java index 07ca3cc..c6b5a60 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/affinity/GridCacheAffinityProxy.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/affinity/GridCacheAffinityProxy.java @@ -251,7 +251,6 @@ public class GridCacheAffinityProxy<K, V> implements Affinity<K>, Externalizable } /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Override public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException { cctx = (GridCacheContext<K, 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/binary/CacheObjectBinaryProcessorImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/binary/CacheObjectBinaryProcessorImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/binary/CacheObjectBinaryProcessorImpl.java index 0a1e887..7b6b4ab 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/binary/CacheObjectBinaryProcessorImpl.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/binary/CacheObjectBinaryProcessorImpl.java @@ -409,7 +409,6 @@ public class CacheObjectBinaryProcessorImpl extends GridProcessorAdapter impleme } /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Override public Object marshalToBinary( @Nullable Object obj, boolean failIfUnregistered @@ -786,7 +785,6 @@ public class CacheObjectBinaryProcessorImpl extends GridProcessorAdapter impleme } /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Override public Collection<BinaryType> metadata() throws BinaryObjectException { return F.viewReadOnly(metadataLocCache.values(), new IgniteClosure<BinaryMetadataHolder, BinaryType>() { @Override public BinaryType apply(BinaryMetadataHolder metaHolder) { http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/binary/IgniteBinaryImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/binary/IgniteBinaryImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/binary/IgniteBinaryImpl.java index 0ee8a0c..0fc1b9f 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/binary/IgniteBinaryImpl.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/binary/IgniteBinaryImpl.java @@ -61,7 +61,6 @@ public class IgniteBinaryImpl implements IgniteBinary { } /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Override public <T> T toBinary(@Nullable Object obj) throws BinaryObjectException { guard(); http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/datastructures/CacheDataStructuresManager.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/datastructures/CacheDataStructuresManager.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/datastructures/CacheDataStructuresManager.java index 9c3c4a6..8c44852 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/datastructures/CacheDataStructuresManager.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/datastructures/CacheDataStructuresManager.java @@ -224,7 +224,6 @@ public class CacheDataStructuresManager extends GridCacheManagerAdapter { * @return Queue header. * @throws IgniteCheckedException If failed. */ - @SuppressWarnings("unchecked") @Nullable public <T> GridCacheQueueProxy<T> queue(final String name, final int cap, boolean colloc, @@ -423,7 +422,6 @@ public class CacheDataStructuresManager extends GridCacheManagerAdapter { * @param topVer Topology version. * @throws IgniteCheckedException If failed. */ - @SuppressWarnings("unchecked") private void removeSetData(IgniteUuid setId, AffinityTopologyVersion topVer) throws IgniteCheckedException { boolean loc = cctx.isLocal(); @@ -465,7 +463,6 @@ public class CacheDataStructuresManager extends GridCacheManagerAdapter { * @param separated Separated cache flag. * @throws IgniteCheckedException If failed. */ - @SuppressWarnings("unchecked") public void removeSetData(IgniteUuid id, boolean separated) throws IgniteCheckedException { assert id != null; @@ -557,7 +554,6 @@ public class CacheDataStructuresManager extends GridCacheManagerAdapter { /** * @param setId Set ID. */ - @SuppressWarnings("unchecked") private void blockSet(IgniteUuid setId) { GridCacheSetProxy set = setsMap.remove(setId); http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/CacheDistributedGetFutureAdapter.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/CacheDistributedGetFutureAdapter.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/CacheDistributedGetFutureAdapter.java index feea264..da6d8f8 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/CacheDistributedGetFutureAdapter.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/CacheDistributedGetFutureAdapter.java @@ -354,7 +354,6 @@ public abstract class CacheDistributedGetFutureAdapter<K, V> /** {@inheritDoc} */ @Override public String toString() { Collection<String> futuresStrings = F.viewReadOnly(futures(), new C1<IgniteInternalFuture<?>, String>() { - @SuppressWarnings("unchecked") @Override public String apply(IgniteInternalFuture<?> f) { if (isMini(f)) { AbstractMiniFuture mini = (AbstractMiniFuture)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/GridDhtCacheAdapter.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtCacheAdapter.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtCacheAdapter.java index 611c87c..58b12ed 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtCacheAdapter.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtCacheAdapter.java @@ -1101,7 +1101,7 @@ public abstract class GridDhtCacheAdapter<K, V> extends GridDistributedCacheAdap public void sendTtlUpdateRequest(@Nullable final IgniteCacheExpiryPolicy expiryPlc) { if (expiryPlc != null && expiryPlc.entries() != null) { ctx.closures().runLocalSafe(new Runnable() { - @SuppressWarnings({"unchecked", "ForLoopReplaceableByForEach"}) + @SuppressWarnings({"ForLoopReplaceableByForEach"}) @Override public void run() { Map<KeyCacheObject, GridCacheVersion> entries = expiryPlc.entries(); http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtCacheEntry.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtCacheEntry.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtCacheEntry.java index 8eea5a3..a1eb01c 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtCacheEntry.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtCacheEntry.java @@ -544,7 +544,6 @@ public class GridDhtCacheEntry extends GridDistributedCacheEntry { * @return {@code True} if reader was removed as a result of this operation. * @throws GridCacheEntryRemovedException If entry was removed. */ - @SuppressWarnings("unchecked") public boolean removeReader(UUID nodeId, long msgId) throws GridCacheEntryRemovedException { lockEntry(); @@ -587,7 +586,6 @@ public class GridDhtCacheEntry extends GridDistributedCacheEntry { /** * Clears all readers (usually when partition becomes invalid and ready for eviction). */ - @SuppressWarnings("unchecked") @Override public void clearReaders() { lockEntry(); @@ -699,7 +697,7 @@ public class GridDhtCacheEntry extends GridDistributedCacheEntry { * @return Collection of readers after check. * @throws GridCacheEntryRemovedException If removed. */ - @SuppressWarnings({"unchecked", "ManualArrayToCollectionCopy"}) + @SuppressWarnings({"ManualArrayToCollectionCopy"}) protected Collection<ReaderId> checkReadersLocked() throws GridCacheEntryRemovedException { assert lockedByCurrentThread(); http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtLockFuture.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtLockFuture.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtLockFuture.java index 9361b30..ef2e70d 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtLockFuture.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtLockFuture.java @@ -574,7 +574,6 @@ public final class GridDhtLockFuture extends GridCacheCompoundIdentityFuture<Boo * @param miniId Mini ID to find. * @return Mini future. */ - @SuppressWarnings("ForLoopReplaceableByForEach") private MiniFuture miniFuture(IgniteUuid miniId) { // We iterate directly over the futs collection here to avoid copy. synchronized (this) { @@ -1354,7 +1353,6 @@ public final class GridDhtLockFuture extends GridCacheCompoundIdentityFuture<Boo * @param msgId Message ID. * @param entries Entries to check. */ - @SuppressWarnings({"ForLoopReplaceableByForEach"}) private void evictReaders(GridCacheContext<?, ?> cacheCtx, Collection<IgniteTxKey> keys, UUID nodeId, long msgId, @Nullable List<GridDhtCacheEntry> entries) { if (entries == null || keys == null || entries.isEmpty() || keys.isEmpty()) http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTxAbstractEnlistFuture.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTxAbstractEnlistFuture.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTxAbstractEnlistFuture.java index ea1c58d..2864712 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTxAbstractEnlistFuture.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTxAbstractEnlistFuture.java @@ -160,7 +160,6 @@ public abstract class GridDhtTxAbstractEnlistFuture<T> extends GridCacheFutureAd private Object peek; /** */ - @SuppressWarnings({"FieldCanBeLocal"}) @GridToStringExclude private volatile int skipCntr; @@ -788,7 +787,6 @@ public abstract class GridDhtTxAbstractEnlistFuture<T> extends GridCacheFutureAd * @param backups Backup nodes. * @return {@code True} if there is possible to add this key to batch or send ready batch. */ - @SuppressWarnings("ForLoopReplaceableByForEach") private boolean ensureFreeSlot(KeyCacheObject key, List<ClusterNode> backups) { if (F.isEmpty(batches) || F.isEmpty(pending)) return true; http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTxFinishFuture.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTxFinishFuture.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTxFinishFuture.java index a9c133a..6c83700 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTxFinishFuture.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTxFinishFuture.java @@ -136,7 +136,6 @@ public final class GridDhtTxFinishFuture<K, V> extends GridCacheCompoundIdentity } /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Override public boolean onNodeLeft(UUID nodeId) { for (IgniteInternalFuture<?> fut : futures()) if (isMini(fut)) { @@ -614,7 +613,6 @@ public final class GridDhtTxFinishFuture<K, V> extends GridCacheCompoundIdentity } /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Override public void addDiagnosticRequest(IgniteDiagnosticPrepareContext ctx) { if (!isDone()) { for (IgniteInternalFuture fut : futures()) { @@ -657,7 +655,6 @@ public final class GridDhtTxFinishFuture<K, V> extends GridCacheCompoundIdentity /** {@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() == MiniFuture.class) { return "[node=" + ((MiniFuture)f).node().id() + http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTxLocal.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTxLocal.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTxLocal.java index 53c4942..c83681c 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTxLocal.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTxLocal.java @@ -539,7 +539,6 @@ public class GridDhtTxLocal extends GridDhtTxLocalAdapter implements GridCacheMa } /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Override public IgniteInternalFuture<IgniteInternalTx> commitAsync() { return commitDhtLocalAsync(); } @@ -663,7 +662,6 @@ public class GridDhtTxLocal extends GridDhtTxLocalAdapter implements GridCacheMa } /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Nullable @Override public IgniteInternalFuture<?> currentPrepareFuture() { return prepFut; } http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTxPrepareFuture.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTxPrepareFuture.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTxPrepareFuture.java index 58edc9d..2e46d2b 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTxPrepareFuture.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTxPrepareFuture.java @@ -1035,7 +1035,6 @@ public final class GridDhtTxPrepareFuture extends GridCacheCompoundFuture<Ignite * * @param req Prepare request. */ - @SuppressWarnings("TypeMayBeWeakened") public void prepare(GridNearTxPrepareRequest req) { assert req != 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/NearTxQueryEnlistResultHandler.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/NearTxQueryEnlistResultHandler.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/NearTxQueryEnlistResultHandler.java index 2058377..00289ca 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/NearTxQueryEnlistResultHandler.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/NearTxQueryEnlistResultHandler.java @@ -56,7 +56,6 @@ public final class NearTxQueryEnlistResultHandler implements CI1<IgniteInternalF * @param future Enlist future. * @return Enlist response. */ - @SuppressWarnings("unchecked") public static <T extends GridNearTxQueryEnlistResponse> T createResponse(IgniteInternalFuture<?> future) { assert future != 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/NearTxResultHandler.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/NearTxResultHandler.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/NearTxResultHandler.java index 0bc00e1..1332b09 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/NearTxResultHandler.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/NearTxResultHandler.java @@ -57,7 +57,6 @@ public final class NearTxResultHandler implements CI1<IgniteInternalFuture<GridC * @param future Enlist future. * @return Enlist response. */ - @SuppressWarnings("unchecked") public static <T> T createResponse(IgniteInternalFuture<?> future) { assert future != 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/atomic/GridDhtAtomicCache.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicCache.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicCache.java index 51dae50..ab4287e 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicCache.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicCache.java @@ -224,7 +224,6 @@ public class GridDhtAtomicCache<K, V> extends GridDhtCacheAdapter<K, V> { } /** {@inheritDoc} */ - @SuppressWarnings({"IfMayBeConditional"}) @Override public void start() throws IgniteCheckedException { super.start(); @@ -2730,7 +2729,6 @@ public class GridDhtAtomicCache<K, V> extends GridDhtCacheAdapter<K, V> { * @param expiry Expiry policy. * @param sndPrevVal If {@code true} sends previous value to backups. */ - @SuppressWarnings("ForLoopReplaceableByForEach") @Nullable private void updatePartialBatch( final boolean hasNear, final int firstEntryIdx, @@ -2984,7 +2982,6 @@ public class GridDhtAtomicCache<K, V> extends GridDhtCacheAdapter<K, V> { * @throws GridDhtInvalidPartitionException If entry does not belong to local node. If exception is thrown, locks * are released. */ - @SuppressWarnings("ForLoopReplaceableByForEach") private List<GridDhtCacheEntry> lockEntries(GridNearAtomicAbstractUpdateRequest req, AffinityTopologyVersion topVer) throws GridDhtInvalidPartitionException { if (req.size() == 1) { 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/GridNearAtomicFullUpdateRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicFullUpdateRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicFullUpdateRequest.java index 170586b..08aa469 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicFullUpdateRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicFullUpdateRequest.java @@ -267,7 +267,6 @@ public class GridNearAtomicFullUpdateRequest extends GridNearAtomicAbstractUpdat } /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Override public CacheObject value(int idx) { assert op == UPDATE : op; @@ -275,7 +274,6 @@ public class GridNearAtomicFullUpdateRequest extends GridNearAtomicAbstractUpdat } /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Override public EntryProcessor<Object, Object, Object> entryProcessor(int idx) { assert op == TRANSFORM : op; 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/GridNearAtomicSingleUpdateFuture.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicSingleUpdateFuture.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicSingleUpdateFuture.java index 486a6e0..d4e81e0 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicSingleUpdateFuture.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicSingleUpdateFuture.java @@ -222,7 +222,6 @@ public class GridNearAtomicSingleUpdateFuture extends GridNearAtomicAbstractUpda } /** {@inheritDoc} */ - @SuppressWarnings({"unchecked"}) @Override public void onPrimaryResponse(UUID nodeId, GridNearAtomicUpdateResponse res, boolean nodeErr) { GridNearAtomicAbstractUpdateRequest req;
