You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by da...@apache.org on 2018/03/21 18:11:31 UTC
[4/5] storm git commit: removed unnecessary
@SuppressWarnings(rawtypes) annotations after adding generics to static types
of method parameters and variables
removed unnecessary @SuppressWarnings(rawtypes) annotations after adding generics to static types of method parameters and variables
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/1582024e
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/1582024e
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/1582024e
Branch: refs/heads/master
Commit: 1582024efc88a2d0b7da189774c380c01ac59683
Parents: c7394d1
Author: Karl-Philipp Richter <kr...@aol.de>
Authored: Mon Mar 19 21:16:50 2018 +0100
Committer: Karl-Philipp Richter <kr...@aol.de>
Committed: Mon Mar 19 21:25:35 2018 +0100
----------------------------------------------------------------------
.../java/org/apache/storm/hbase/topology/TotalWordCounter.java | 1 -
.../main/java/org/apache/storm/hbase/topology/WordCounter.java | 1 -
.../main/java/org/apache/storm/hbase/topology/WordSpout.java | 1 -
.../src/main/java/org/apache/storm/jdbc/spout/UserSpout.java | 1 -
.../main/java/org/apache/storm/jms/example/GenericBolt.java | 1 -
.../org/apache/storm/mongodb/topology/TotalWordCounter.java | 1 -
.../main/java/org/apache/storm/mongodb/topology/WordSpout.java | 1 -
.../main/java/org/apache/storm/redis/topology/WordCounter.java | 1 -
.../main/java/org/apache/storm/redis/topology/WordSpout.java | 1 -
.../jvm/org/apache/storm/starter/bolt/RollingCountAggBolt.java | 1 -
.../jvm/org/apache/storm/starter/bolt/RollingCountBolt.java | 1 -
.../main/java/org/apache/storm/hbase/bolt/HBaseLookupBolt.java | 1 -
.../java/org/apache/storm/jms/trident/TridentJmsSpout.java | 6 +++---
.../apache/storm/redis/trident/state/RedisClusterMapState.java | 2 +-
.../apache/storm/redis/trident/state/RedisClusterState.java | 2 +-
.../org/apache/storm/redis/trident/state/RedisMapState.java | 2 +-
.../java/org/apache/storm/redis/trident/state/RedisState.java | 2 +-
.../org/apache/storm/flux/examples/StatefulWordCounter.java | 1 -
.../main/java/org/apache/storm/flux/examples/WordCounter.java | 1 -
.../src/jvm/org/apache/storm/messaging/local/Context.java | 2 --
.../src/jvm/org/apache/storm/messaging/netty/Client.java | 1 -
.../src/jvm/org/apache/storm/messaging/netty/Context.java | 2 --
.../src/jvm/org/apache/storm/messaging/netty/Server.java | 2 --
storm-client/src/jvm/org/apache/storm/metric/SystemBolt.java | 2 +-
storm-server/src/main/java/org/apache/storm/Testing.java | 1 -
.../src/main/java/org/apache/storm/daemon/nimbus/Nimbus.java | 2 +-
.../storm/scheduler/multitenant/MultitenantScheduler.java | 1 -
27 files changed, 9 insertions(+), 32 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/1582024e/examples/storm-hbase-examples/src/main/java/org/apache/storm/hbase/topology/TotalWordCounter.java
----------------------------------------------------------------------
diff --git a/examples/storm-hbase-examples/src/main/java/org/apache/storm/hbase/topology/TotalWordCounter.java b/examples/storm-hbase-examples/src/main/java/org/apache/storm/hbase/topology/TotalWordCounter.java
index aa28a52..c107282 100644
--- a/examples/storm-hbase-examples/src/main/java/org/apache/storm/hbase/topology/TotalWordCounter.java
+++ b/examples/storm-hbase-examples/src/main/java/org/apache/storm/hbase/topology/TotalWordCounter.java
@@ -37,7 +37,6 @@ public class TotalWordCounter implements IBasicBolt {
private BigInteger total = BigInteger.ZERO;
private static final Logger LOG = LoggerFactory.getLogger(TotalWordCounter.class);
private static final Random RANDOM = new Random();
- @SuppressWarnings("rawtypes")
public void prepare(Map<String, Object> topoConf, TopologyContext context) {
}
http://git-wip-us.apache.org/repos/asf/storm/blob/1582024e/examples/storm-hbase-examples/src/main/java/org/apache/storm/hbase/topology/WordCounter.java
----------------------------------------------------------------------
diff --git a/examples/storm-hbase-examples/src/main/java/org/apache/storm/hbase/topology/WordCounter.java b/examples/storm-hbase-examples/src/main/java/org/apache/storm/hbase/topology/WordCounter.java
index 6054699..5c71ade 100644
--- a/examples/storm-hbase-examples/src/main/java/org/apache/storm/hbase/topology/WordCounter.java
+++ b/examples/storm-hbase-examples/src/main/java/org/apache/storm/hbase/topology/WordCounter.java
@@ -31,7 +31,6 @@ import static org.apache.storm.utils.Utils.tuple;
public class WordCounter implements IBasicBolt {
- @SuppressWarnings("rawtypes")
public void prepare(Map<String, Object> topoConf, TopologyContext context) {
}
http://git-wip-us.apache.org/repos/asf/storm/blob/1582024e/examples/storm-hbase-examples/src/main/java/org/apache/storm/hbase/topology/WordSpout.java
----------------------------------------------------------------------
diff --git a/examples/storm-hbase-examples/src/main/java/org/apache/storm/hbase/topology/WordSpout.java b/examples/storm-hbase-examples/src/main/java/org/apache/storm/hbase/topology/WordSpout.java
index 00ac67d..bcc9642 100644
--- a/examples/storm-hbase-examples/src/main/java/org/apache/storm/hbase/topology/WordSpout.java
+++ b/examples/storm-hbase-examples/src/main/java/org/apache/storm/hbase/topology/WordSpout.java
@@ -45,7 +45,6 @@ public class WordSpout implements IRichSpout {
return this.isDistributed;
}
- @SuppressWarnings("rawtypes")
public void open(Map<String, Object> conf, TopologyContext context, SpoutOutputCollector collector) {
this.collector = collector;
}
http://git-wip-us.apache.org/repos/asf/storm/blob/1582024e/examples/storm-jdbc-examples/src/main/java/org/apache/storm/jdbc/spout/UserSpout.java
----------------------------------------------------------------------
diff --git a/examples/storm-jdbc-examples/src/main/java/org/apache/storm/jdbc/spout/UserSpout.java b/examples/storm-jdbc-examples/src/main/java/org/apache/storm/jdbc/spout/UserSpout.java
index f05f79a..9641599 100644
--- a/examples/storm-jdbc-examples/src/main/java/org/apache/storm/jdbc/spout/UserSpout.java
+++ b/examples/storm-jdbc-examples/src/main/java/org/apache/storm/jdbc/spout/UserSpout.java
@@ -47,7 +47,6 @@ public class UserSpout implements IRichSpout {
return this.isDistributed;
}
- @SuppressWarnings("rawtypes")
public void open(Map<String, Object> conf, TopologyContext context, SpoutOutputCollector collector) {
this.collector = collector;
}
http://git-wip-us.apache.org/repos/asf/storm/blob/1582024e/examples/storm-jms-examples/src/main/java/org/apache/storm/jms/example/GenericBolt.java
----------------------------------------------------------------------
diff --git a/examples/storm-jms-examples/src/main/java/org/apache/storm/jms/example/GenericBolt.java b/examples/storm-jms-examples/src/main/java/org/apache/storm/jms/example/GenericBolt.java
index be6afb0..0b077c0 100644
--- a/examples/storm-jms-examples/src/main/java/org/apache/storm/jms/example/GenericBolt.java
+++ b/examples/storm-jms-examples/src/main/java/org/apache/storm/jms/example/GenericBolt.java
@@ -67,7 +67,6 @@ public class GenericBolt extends BaseRichBolt {
this(name, autoAck, autoAnchor, null);
}
- @SuppressWarnings("rawtypes")
public void prepare(Map<String, Object> topoConf, TopologyContext context,
OutputCollector collector) {
this.collector = collector;
http://git-wip-us.apache.org/repos/asf/storm/blob/1582024e/examples/storm-mongodb-examples/src/main/java/org/apache/storm/mongodb/topology/TotalWordCounter.java
----------------------------------------------------------------------
diff --git a/examples/storm-mongodb-examples/src/main/java/org/apache/storm/mongodb/topology/TotalWordCounter.java b/examples/storm-mongodb-examples/src/main/java/org/apache/storm/mongodb/topology/TotalWordCounter.java
index 3827e77..4dee7a0 100644
--- a/examples/storm-mongodb-examples/src/main/java/org/apache/storm/mongodb/topology/TotalWordCounter.java
+++ b/examples/storm-mongodb-examples/src/main/java/org/apache/storm/mongodb/topology/TotalWordCounter.java
@@ -37,7 +37,6 @@ public class TotalWordCounter implements IBasicBolt {
private BigInteger total = BigInteger.ZERO;
private static final Logger LOG = LoggerFactory.getLogger(TotalWordCounter.class);
private static final Random RANDOM = new Random();
- @SuppressWarnings("rawtypes")
public void prepare(Map<String, Object> topoConf, TopologyContext context) {
}
http://git-wip-us.apache.org/repos/asf/storm/blob/1582024e/examples/storm-mongodb-examples/src/main/java/org/apache/storm/mongodb/topology/WordSpout.java
----------------------------------------------------------------------
diff --git a/examples/storm-mongodb-examples/src/main/java/org/apache/storm/mongodb/topology/WordSpout.java b/examples/storm-mongodb-examples/src/main/java/org/apache/storm/mongodb/topology/WordSpout.java
index 086ac2f..f0bdde2 100644
--- a/examples/storm-mongodb-examples/src/main/java/org/apache/storm/mongodb/topology/WordSpout.java
+++ b/examples/storm-mongodb-examples/src/main/java/org/apache/storm/mongodb/topology/WordSpout.java
@@ -45,7 +45,6 @@ public class WordSpout implements IRichSpout {
return this.isDistributed;
}
- @SuppressWarnings("rawtypes")
public void open(Map<String, Object> conf, TopologyContext context, SpoutOutputCollector collector) {
this.collector = collector;
}
http://git-wip-us.apache.org/repos/asf/storm/blob/1582024e/examples/storm-redis-examples/src/main/java/org/apache/storm/redis/topology/WordCounter.java
----------------------------------------------------------------------
diff --git a/examples/storm-redis-examples/src/main/java/org/apache/storm/redis/topology/WordCounter.java b/examples/storm-redis-examples/src/main/java/org/apache/storm/redis/topology/WordCounter.java
index 6c6e67a..c321b83 100644
--- a/examples/storm-redis-examples/src/main/java/org/apache/storm/redis/topology/WordCounter.java
+++ b/examples/storm-redis-examples/src/main/java/org/apache/storm/redis/topology/WordCounter.java
@@ -31,7 +31,6 @@ import java.util.Map;
public class WordCounter implements IBasicBolt {
private Map<String, Integer> wordCounter = Maps.newHashMap();
- @SuppressWarnings("rawtypes")
public void prepare(Map<String, Object> topoConf, TopologyContext context) {
}
http://git-wip-us.apache.org/repos/asf/storm/blob/1582024e/examples/storm-redis-examples/src/main/java/org/apache/storm/redis/topology/WordSpout.java
----------------------------------------------------------------------
diff --git a/examples/storm-redis-examples/src/main/java/org/apache/storm/redis/topology/WordSpout.java b/examples/storm-redis-examples/src/main/java/org/apache/storm/redis/topology/WordSpout.java
index 76b2887..ef45cd2 100644
--- a/examples/storm-redis-examples/src/main/java/org/apache/storm/redis/topology/WordSpout.java
+++ b/examples/storm-redis-examples/src/main/java/org/apache/storm/redis/topology/WordSpout.java
@@ -45,7 +45,6 @@ public class WordSpout implements IRichSpout {
return this.isDistributed;
}
- @SuppressWarnings("rawtypes")
public void open(Map<String, Object> conf, TopologyContext context, SpoutOutputCollector collector) {
this.collector = collector;
}
http://git-wip-us.apache.org/repos/asf/storm/blob/1582024e/examples/storm-starter/src/jvm/org/apache/storm/starter/bolt/RollingCountAggBolt.java
----------------------------------------------------------------------
diff --git a/examples/storm-starter/src/jvm/org/apache/storm/starter/bolt/RollingCountAggBolt.java b/examples/storm-starter/src/jvm/org/apache/storm/starter/bolt/RollingCountAggBolt.java
index e292308..fafdbcc 100644
--- a/examples/storm-starter/src/jvm/org/apache/storm/starter/bolt/RollingCountAggBolt.java
+++ b/examples/storm-starter/src/jvm/org/apache/storm/starter/bolt/RollingCountAggBolt.java
@@ -44,7 +44,6 @@ public class RollingCountAggBolt extends BaseRichBolt {
private OutputCollector collector;
- @SuppressWarnings("rawtypes")
@Override
public void prepare(Map<String, Object> topoConf, TopologyContext context, OutputCollector collector) {
this.collector = collector;
http://git-wip-us.apache.org/repos/asf/storm/blob/1582024e/examples/storm-starter/src/jvm/org/apache/storm/starter/bolt/RollingCountBolt.java
----------------------------------------------------------------------
diff --git a/examples/storm-starter/src/jvm/org/apache/storm/starter/bolt/RollingCountBolt.java b/examples/storm-starter/src/jvm/org/apache/storm/starter/bolt/RollingCountBolt.java
index e7e72b1..b7ea55e 100644
--- a/examples/storm-starter/src/jvm/org/apache/storm/starter/bolt/RollingCountBolt.java
+++ b/examples/storm-starter/src/jvm/org/apache/storm/starter/bolt/RollingCountBolt.java
@@ -85,7 +85,6 @@ public class RollingCountBolt extends BaseRichBolt {
return windowLengthInSeconds / windowUpdateFrequencyInSeconds;
}
- @SuppressWarnings("rawtypes")
@Override
public void prepare(Map<String, Object> topoConf, TopologyContext context, OutputCollector collector) {
this.collector = collector;
http://git-wip-us.apache.org/repos/asf/storm/blob/1582024e/external/storm-hbase/src/main/java/org/apache/storm/hbase/bolt/HBaseLookupBolt.java
----------------------------------------------------------------------
diff --git a/external/storm-hbase/src/main/java/org/apache/storm/hbase/bolt/HBaseLookupBolt.java b/external/storm-hbase/src/main/java/org/apache/storm/hbase/bolt/HBaseLookupBolt.java
index 0212646..d20aab3 100644
--- a/external/storm-hbase/src/main/java/org/apache/storm/hbase/bolt/HBaseLookupBolt.java
+++ b/external/storm-hbase/src/main/java/org/apache/storm/hbase/bolt/HBaseLookupBolt.java
@@ -71,7 +71,6 @@ public class HBaseLookupBolt extends AbstractHBaseBolt {
return this;
}
- @SuppressWarnings({ "unchecked", "rawtypes" })
@Override
public void prepare(Map<String, Object> config, TopologyContext topologyContext, OutputCollector collector) {
super.prepare(config, topologyContext, collector);
http://git-wip-us.apache.org/repos/asf/storm/blob/1582024e/external/storm-jms/src/main/java/org/apache/storm/jms/trident/TridentJmsSpout.java
----------------------------------------------------------------------
diff --git a/external/storm-jms/src/main/java/org/apache/storm/jms/trident/TridentJmsSpout.java b/external/storm-jms/src/main/java/org/apache/storm/jms/trident/TridentJmsSpout.java
index 31f4d0d..afdc0b2 100644
--- a/external/storm-jms/src/main/java/org/apache/storm/jms/trident/TridentJmsSpout.java
+++ b/external/storm-jms/src/main/java/org/apache/storm/jms/trident/TridentJmsSpout.java
@@ -163,12 +163,12 @@ public class TridentJmsSpout implements ITridentSpout<JmsBatch> {
@Override
public ITridentSpout.BatchCoordinator<JmsBatch> getCoordinator(
- String txStateId, @SuppressWarnings("rawtypes") Map<String, Object> conf, TopologyContext context) {
+ String txStateId, Map<String, Object> conf, TopologyContext context) {
return new JmsBatchCoordinator(name);
}
@Override
- public Emitter<JmsBatch> getEmitter(String txStateId, @SuppressWarnings("rawtypes") Map<String, Object> conf, TopologyContext context) {
+ public Emitter<JmsBatch> getEmitter(String txStateId, Map<String, Object> conf, TopologyContext context) {
return new JmsEmitter(name, jmsProvider, tupleProducer, jmsAcknowledgeMode, conf);
}
@@ -210,7 +210,7 @@ public class TridentJmsSpout implements ITridentSpout<JmsBatch> {
private final Logger LOG = LoggerFactory.getLogger(JmsEmitter.class);
- public JmsEmitter(String name, JmsProvider jmsProvider, JmsTupleProducer tupleProducer, int jmsAcknowledgeMode, @SuppressWarnings("rawtypes") Map<String, Object> conf) {
+ public JmsEmitter(String name, JmsProvider jmsProvider, JmsTupleProducer tupleProducer, int jmsAcknowledgeMode, Map<String, Object> conf) {
if (jmsProvider == null) {
throw new IllegalStateException("JMS provider has not been set.");
}
http://git-wip-us.apache.org/repos/asf/storm/blob/1582024e/external/storm-redis/src/main/java/org/apache/storm/redis/trident/state/RedisClusterMapState.java
----------------------------------------------------------------------
diff --git a/external/storm-redis/src/main/java/org/apache/storm/redis/trident/state/RedisClusterMapState.java b/external/storm-redis/src/main/java/org/apache/storm/redis/trident/state/RedisClusterMapState.java
index 3744bd5..ecae18d 100644
--- a/external/storm-redis/src/main/java/org/apache/storm/redis/trident/state/RedisClusterMapState.java
+++ b/external/storm-redis/src/main/java/org/apache/storm/redis/trident/state/RedisClusterMapState.java
@@ -230,7 +230,7 @@ public class RedisClusterMapState<T> extends AbstractRedisMapState<T> {
* {@inheritDoc}
*/
@Override
- public State makeState(@SuppressWarnings("rawtypes") Map<String, Object> conf, IMetricsContext metrics, int partitionIndex, int numPartitions) {
+ public State makeState(Map<String, Object> conf, IMetricsContext metrics, int partitionIndex, int numPartitions) {
JedisCluster jedisCluster = new JedisCluster(jedisClusterConfig.getNodes(),
jedisClusterConfig.getTimeout(),
jedisClusterConfig.getTimeout(),
http://git-wip-us.apache.org/repos/asf/storm/blob/1582024e/external/storm-redis/src/main/java/org/apache/storm/redis/trident/state/RedisClusterState.java
----------------------------------------------------------------------
diff --git a/external/storm-redis/src/main/java/org/apache/storm/redis/trident/state/RedisClusterState.java b/external/storm-redis/src/main/java/org/apache/storm/redis/trident/state/RedisClusterState.java
index 6d0ed3e..11d8907 100644
--- a/external/storm-redis/src/main/java/org/apache/storm/redis/trident/state/RedisClusterState.java
+++ b/external/storm-redis/src/main/java/org/apache/storm/redis/trident/state/RedisClusterState.java
@@ -69,7 +69,7 @@ public class RedisClusterState implements State {
* {@inheritDoc}
*/
@Override
- public State makeState(@SuppressWarnings("rawtypes") Map<String, Object> conf, IMetricsContext metrics, int partitionIndex, int numPartitions) {
+ public State makeState(Map<String, Object> conf, IMetricsContext metrics, int partitionIndex, int numPartitions) {
JedisCluster jedisCluster = new JedisCluster(jedisClusterConfig.getNodes(),
jedisClusterConfig.getTimeout(),
jedisClusterConfig.getTimeout(),
http://git-wip-us.apache.org/repos/asf/storm/blob/1582024e/external/storm-redis/src/main/java/org/apache/storm/redis/trident/state/RedisMapState.java
----------------------------------------------------------------------
diff --git a/external/storm-redis/src/main/java/org/apache/storm/redis/trident/state/RedisMapState.java b/external/storm-redis/src/main/java/org/apache/storm/redis/trident/state/RedisMapState.java
index 21a40bd..f68b5ef 100644
--- a/external/storm-redis/src/main/java/org/apache/storm/redis/trident/state/RedisMapState.java
+++ b/external/storm-redis/src/main/java/org/apache/storm/redis/trident/state/RedisMapState.java
@@ -230,7 +230,7 @@ public class RedisMapState<T> extends AbstractRedisMapState<T> {
* {@inheritDoc}
*/
@Override
- public State makeState(@SuppressWarnings("rawtypes") Map<String, Object> conf, IMetricsContext metrics, int partitionIndex, int numPartitions) {
+ public State makeState(Map<String, Object> conf, IMetricsContext metrics, int partitionIndex, int numPartitions) {
JedisPool jedisPool = new JedisPool(DEFAULT_POOL_CONFIG,
jedisPoolConfig.getHost(),
jedisPoolConfig.getPort(),
http://git-wip-us.apache.org/repos/asf/storm/blob/1582024e/external/storm-redis/src/main/java/org/apache/storm/redis/trident/state/RedisState.java
----------------------------------------------------------------------
diff --git a/external/storm-redis/src/main/java/org/apache/storm/redis/trident/state/RedisState.java b/external/storm-redis/src/main/java/org/apache/storm/redis/trident/state/RedisState.java
index c6a6da3..ec0b679 100644
--- a/external/storm-redis/src/main/java/org/apache/storm/redis/trident/state/RedisState.java
+++ b/external/storm-redis/src/main/java/org/apache/storm/redis/trident/state/RedisState.java
@@ -69,7 +69,7 @@ public class RedisState implements State {
* {@inheritDoc}
*/
@Override
- public State makeState(@SuppressWarnings("rawtypes") Map<String, Object> conf, IMetricsContext metrics, int partitionIndex, int numPartitions) {
+ public State makeState(Map<String, Object> conf, IMetricsContext metrics, int partitionIndex, int numPartitions) {
JedisPool jedisPool = new JedisPool(DEFAULT_POOL_CONFIG,
jedisPoolConfig.getHost(),
jedisPoolConfig.getPort(),
http://git-wip-us.apache.org/repos/asf/storm/blob/1582024e/flux/flux-examples/src/main/java/org/apache/storm/flux/examples/StatefulWordCounter.java
----------------------------------------------------------------------
diff --git a/flux/flux-examples/src/main/java/org/apache/storm/flux/examples/StatefulWordCounter.java b/flux/flux-examples/src/main/java/org/apache/storm/flux/examples/StatefulWordCounter.java
index f1f4a6c..aa36af9 100644
--- a/flux/flux-examples/src/main/java/org/apache/storm/flux/examples/StatefulWordCounter.java
+++ b/flux/flux-examples/src/main/java/org/apache/storm/flux/examples/StatefulWordCounter.java
@@ -34,7 +34,6 @@ public class StatefulWordCounter extends BaseStatefulBolt<KeyValueState<String,
private KeyValueState<String, Long> wordCounts;
private OutputCollector collector;
- @SuppressWarnings("rawtypes")
@Override
public void prepare(Map<String, Object> topoConf, TopologyContext context, OutputCollector collector) {
this.collector = collector;
http://git-wip-us.apache.org/repos/asf/storm/blob/1582024e/flux/flux-examples/src/main/java/org/apache/storm/flux/examples/WordCounter.java
----------------------------------------------------------------------
diff --git a/flux/flux-examples/src/main/java/org/apache/storm/flux/examples/WordCounter.java b/flux/flux-examples/src/main/java/org/apache/storm/flux/examples/WordCounter.java
index f15af95..709c254 100644
--- a/flux/flux-examples/src/main/java/org/apache/storm/flux/examples/WordCounter.java
+++ b/flux/flux-examples/src/main/java/org/apache/storm/flux/examples/WordCounter.java
@@ -43,7 +43,6 @@ public class WordCounter extends BaseBasicBolt {
- @SuppressWarnings("rawtypes")
public void prepare(Map<String, Object> topoConf, TopologyContext context) {
}
http://git-wip-us.apache.org/repos/asf/storm/blob/1582024e/storm-client/src/jvm/org/apache/storm/messaging/local/Context.java
----------------------------------------------------------------------
diff --git a/storm-client/src/jvm/org/apache/storm/messaging/local/Context.java b/storm-client/src/jvm/org/apache/storm/messaging/local/Context.java
index 0babd5f..75fc899 100644
--- a/storm-client/src/jvm/org/apache/storm/messaging/local/Context.java
+++ b/storm-client/src/jvm/org/apache/storm/messaging/local/Context.java
@@ -233,7 +233,6 @@ public class Context implements IContext {
return ret;
}
- @SuppressWarnings("rawtypes")
@Override
public void prepare(Map<String, Object> topoConf) {
//NOOP
@@ -249,7 +248,6 @@ public class Context implements IContext {
return new LocalClient(getLocalServer(storm_id, port));
}
- @SuppressWarnings("rawtypes")
@Override
public void term() {
//NOOP
http://git-wip-us.apache.org/repos/asf/storm/blob/1582024e/storm-client/src/jvm/org/apache/storm/messaging/netty/Client.java
----------------------------------------------------------------------
diff --git a/storm-client/src/jvm/org/apache/storm/messaging/netty/Client.java b/storm-client/src/jvm/org/apache/storm/messaging/netty/Client.java
index e0736b5..bbcfb43 100644
--- a/storm-client/src/jvm/org/apache/storm/messaging/netty/Client.java
+++ b/storm-client/src/jvm/org/apache/storm/messaging/netty/Client.java
@@ -151,7 +151,6 @@ public class Client extends ConnectionWithStatus implements IStatefulObject, ISa
// wait strategy when the netty channel is not writable
private final IWaitStrategy waitStrategy;
- @SuppressWarnings("rawtypes")
Client(Map<String, Object> topoConf, AtomicBoolean[] remoteBpStatus, ChannelFactory factory, HashedWheelTimer scheduler, String host, int port, Context context) {
this.topoConf = topoConf;
closing = false;
http://git-wip-us.apache.org/repos/asf/storm/blob/1582024e/storm-client/src/jvm/org/apache/storm/messaging/netty/Context.java
----------------------------------------------------------------------
diff --git a/storm-client/src/jvm/org/apache/storm/messaging/netty/Context.java b/storm-client/src/jvm/org/apache/storm/messaging/netty/Context.java
index 5a169de..82ebc26 100644
--- a/storm-client/src/jvm/org/apache/storm/messaging/netty/Context.java
+++ b/storm-client/src/jvm/org/apache/storm/messaging/netty/Context.java
@@ -31,7 +31,6 @@ import org.apache.storm.messaging.IConnection;
import org.apache.storm.messaging.IContext;
public class Context implements IContext {
- @SuppressWarnings("rawtypes")
private Map<String, Object> topoConf;
private Map<String, IConnection> connections;
private NioClientSocketChannelFactory clientChannelFactory;
@@ -40,7 +39,6 @@ public class Context implements IContext {
/**
* initialization per Storm configuration
*/
- @SuppressWarnings("rawtypes")
public void prepare(Map<String, Object> topoConf) {
this.topoConf = topoConf;
connections = new HashMap<>();
http://git-wip-us.apache.org/repos/asf/storm/blob/1582024e/storm-client/src/jvm/org/apache/storm/messaging/netty/Server.java
----------------------------------------------------------------------
diff --git a/storm-client/src/jvm/org/apache/storm/messaging/netty/Server.java b/storm-client/src/jvm/org/apache/storm/messaging/netty/Server.java
index 0901cc3..9f16b8d 100644
--- a/storm-client/src/jvm/org/apache/storm/messaging/netty/Server.java
+++ b/storm-client/src/jvm/org/apache/storm/messaging/netty/Server.java
@@ -53,7 +53,6 @@ import org.slf4j.LoggerFactory;
class Server extends ConnectionWithStatus implements IStatefulObject, ISaslServer {
private static final Logger LOG = LoggerFactory.getLogger(Server.class);
- @SuppressWarnings("rawtypes")
Map<String, Object> topoConf;
int port;
private final ConcurrentHashMap<String, AtomicInteger> messagesEnqueued = new ConcurrentHashMap<>();
@@ -70,7 +69,6 @@ class Server extends ConnectionWithStatus implements IStatefulObject, ISaslServe
private Supplier<Object> newConnectionResponse;
private final int boundPort;
- @SuppressWarnings("rawtypes")
Server(Map<String, Object> topoConf, int port) {
this.topoConf = topoConf;
this.port = port;
http://git-wip-us.apache.org/repos/asf/storm/blob/1582024e/storm-client/src/jvm/org/apache/storm/metric/SystemBolt.java
----------------------------------------------------------------------
diff --git a/storm-client/src/jvm/org/apache/storm/metric/SystemBolt.java b/storm-client/src/jvm/org/apache/storm/metric/SystemBolt.java
index 67be2c9..629a60e 100644
--- a/storm-client/src/jvm/org/apache/storm/metric/SystemBolt.java
+++ b/storm-client/src/jvm/org/apache/storm/metric/SystemBolt.java
@@ -89,7 +89,7 @@ public class SystemBolt implements IBolt {
}
}
- @SuppressWarnings({ "unchecked", "rawtypes" })
+ @SuppressWarnings({ "unchecked" })
@Override
public void prepare(final Map<String, Object> topoConf, TopologyContext context, OutputCollector collector) {
if(_prepareWasCalled && !"local".equals(topoConf.get(Config.STORM_CLUSTER_MODE))) {
http://git-wip-us.apache.org/repos/asf/storm/blob/1582024e/storm-server/src/main/java/org/apache/storm/Testing.java
----------------------------------------------------------------------
diff --git a/storm-server/src/main/java/org/apache/storm/Testing.java b/storm-server/src/main/java/org/apache/storm/Testing.java
index 1d3758f..c391926 100644
--- a/storm-server/src/main/java/org/apache/storm/Testing.java
+++ b/storm-server/src/main/java/org/apache/storm/Testing.java
@@ -622,7 +622,6 @@ public class Testing {
return ret;
}
- @SuppressWarnings("rawtypes")
private static void printRec(Object o, String prefix) {
if (o instanceof Collection) {
LOG.info("{} {} ({}) [",prefix,o, o.getClass());
http://git-wip-us.apache.org/repos/asf/storm/blob/1582024e/storm-server/src/main/java/org/apache/storm/daemon/nimbus/Nimbus.java
----------------------------------------------------------------------
diff --git a/storm-server/src/main/java/org/apache/storm/daemon/nimbus/Nimbus.java b/storm-server/src/main/java/org/apache/storm/daemon/nimbus/Nimbus.java
index 9f4336e..f5d08ec 100644
--- a/storm-server/src/main/java/org/apache/storm/daemon/nimbus/Nimbus.java
+++ b/storm-server/src/main/java/org/apache/storm/daemon/nimbus/Nimbus.java
@@ -406,7 +406,7 @@ public class Nimbus implements Iface, Shutdownable, DaemonCommon {
public static class StandaloneINimbus implements INimbus {
@Override
- public void prepare(@SuppressWarnings("rawtypes") Map<String, Object> topoConf, String schedulerLocalDir) {
+ public void prepare(Map<String, Object> topoConf, String schedulerLocalDir) {
//NOOP
}
http://git-wip-us.apache.org/repos/asf/storm/blob/1582024e/storm-server/src/main/java/org/apache/storm/scheduler/multitenant/MultitenantScheduler.java
----------------------------------------------------------------------
diff --git a/storm-server/src/main/java/org/apache/storm/scheduler/multitenant/MultitenantScheduler.java b/storm-server/src/main/java/org/apache/storm/scheduler/multitenant/MultitenantScheduler.java
index d4d240c..65c657e 100644
--- a/storm-server/src/main/java/org/apache/storm/scheduler/multitenant/MultitenantScheduler.java
+++ b/storm-server/src/main/java/org/apache/storm/scheduler/multitenant/MultitenantScheduler.java
@@ -33,7 +33,6 @@ import org.slf4j.LoggerFactory;
public class MultitenantScheduler implements IScheduler {
private static final Logger LOG = LoggerFactory.getLogger(MultitenantScheduler.class);
- @SuppressWarnings("rawtypes")
private Map<String, Object> conf;
protected IConfigLoader configLoader;