add serialVersionUID field to class which implement Serializable inte…

…rface

examples/storm-hdfs-examples/src/main/java/org/apache/storm/hdfs/spout/HdfsSpoutTopology.java

@@ -153,8 +153,8 @@ static void printMetrics(Nimbus.Iface client, String name) throws Exception {
     }
 
     public static class ConstBolt extends BaseRichBolt {
-        public static final String FIELDS = "message";
         private static final long serialVersionUID = -5313598399155365865L;
+        public static final String FIELDS = "message";
         private static final Logger log = LoggerFactory.getLogger(ConstBolt.class);
         int count = 0;
         private OutputCollector collector;

examples/storm-jms-examples/src/main/java/org/apache/storm/jms/example/GenericBolt.java

@@ -40,8 +40,8 @@
  *
  * @author tgoetz
  */
-@SuppressWarnings("serial")
 public class GenericBolt extends BaseRichBolt {
+    private static final long serialVersionUID = 8669713806304573619L;
     private static final Logger LOG = LoggerFactory.getLogger(GenericBolt.class);
     private OutputCollector collector;
     private boolean autoAck = false;

examples/storm-kafka-client-examples/src/main/java/org/apache/storm/kafka/spout/KafkaSpoutTestBolt.java

@@ -28,6 +28,7 @@
 import org.slf4j.LoggerFactory;
 
 public class KafkaSpoutTestBolt extends BaseRichBolt {
+    private static final long serialVersionUID = -2971714387602762051L;
     protected static final Logger LOG = LoggerFactory.getLogger(KafkaSpoutTestBolt.class);
     private OutputCollector collector;
 

examples/storm-loadgen/src/main/java/org/apache/storm/loadgen/InputStream.java

@@ -34,6 +34,7 @@
  */
 public class InputStream implements Serializable {
     private static final Logger LOG = LoggerFactory.getLogger(InputStream.class);
+    private static final long serialVersionUID = -6336477049725202777L;
     public final String fromComponent;
     public final String toComponent;
     public final String id;

examples/storm-loadgen/src/main/java/org/apache/storm/loadgen/LoadBolt.java

@@ -39,6 +39,7 @@
  * A bolt that simulates a real world bolt based off of statistics about it.
  */
 public class LoadBolt extends BaseRichBolt {
+    private static final long serialVersionUID = 9147991310167687246L;
     private static final Logger LOG = LoggerFactory.getLogger(LoadBolt.class);
     private final List<OutputStream> outputStreamStats;
     private List<OutputStreamEngine> outputStreams;

examples/storm-loadgen/src/main/java/org/apache/storm/loadgen/NormalDistStats.java

@@ -33,6 +33,7 @@
  */
 public class NormalDistStats implements Serializable {
     private static final Logger LOG = LoggerFactory.getLogger(NormalDistStats.class);
+    private static final long serialVersionUID = -303929340157333380L;
     public final double mean;
     public final double stddev;
     public final double min;

examples/storm-perf/src/main/java/org/apache/storm/perf/BackPressureTopo.java

@@ -84,6 +84,7 @@ public static void main(String[] args) throws Exception {
     }
 
     private static class ThrottledBolt extends BaseRichBolt {
+        private static final long serialVersionUID = -8621048146348639308L;
         private static final org.slf4j.Logger LOG = LoggerFactory.getLogger(ThrottledBolt.class);
         private OutputCollector collector;
         private long sleepMs;

examples/storm-perf/src/main/java/org/apache/storm/perf/LowThroughputTopo.java

@@ -128,6 +128,7 @@ public void ack(Object msgId) {
     }
 
     private static class LatencyPrintBolt extends BaseRichBolt {
+        private static final long serialVersionUID = -3566535176387956870L;
         private static final org.slf4j.Logger LOG = LoggerFactory.getLogger(LatencyPrintBolt.class);
         private OutputCollector collector;
 

examples/storm-perf/src/main/java/org/apache/storm/perf/bolt/DevNullBolt.java

@@ -30,6 +30,7 @@
 
 
 public class DevNullBolt extends BaseRichBolt {
+    private static final long serialVersionUID = 3353976718364358702L;
     private static final org.slf4j.Logger LOG = LoggerFactory.getLogger(DevNullBolt.class);
     private OutputCollector collector;
     private Long sleepNanos;
@@ -55,3 +56,4 @@ public void declareOutputFields(OutputFieldsDeclarer declarer) {
 
     }
 }
+

examples/storm-perf/src/main/java/org/apache/storm/perf/bolt/IdBolt.java

@@ -28,6 +28,7 @@
 import org.apache.storm.tuple.Values;
 
 public class IdBolt extends BaseRichBolt {
+    private static final long serialVersionUID = 8578055825211897856L;
     private OutputCollector collector;
 
     @Override

examples/storm-perf/src/main/java/org/apache/storm/perf/utils/IdentityBolt.java

@@ -26,6 +26,7 @@
 import org.apache.storm.tuple.Tuple;
 
 public class IdentityBolt extends BaseRichBolt {
+    private static final long serialVersionUID = 7556207705817740527L;
     private OutputCollector collector;
 
     @Override

examples/storm-starter/src/jvm/org/apache/storm/starter/bolt/SingleJoinBolt.java

@@ -33,6 +33,7 @@
  * NOTE: Prefer to use the built-in JoinBolt wherever applicable
  */
 public class SingleJoinBolt extends BaseRichBolt {
+    private static final long serialVersionUID = 2986304714244016387L;
     OutputCollector collector;
     Fields idFields;
     Fields outFields;

external/storm-cassandra/src/main/java/org/apache/storm/cassandra/DynamicStatementBuilder.java

@@ -29,6 +29,8 @@
 
 public class DynamicStatementBuilder implements Serializable {
 
+    private static final long serialVersionUID = 4417334935956874165L;
+
     private DynamicStatementBuilder() {
     }
 

external/storm-cassandra/src/main/java/org/apache/storm/cassandra/bolt/BatchCassandraWriterBolt.java

@@ -30,7 +30,7 @@
 import org.slf4j.LoggerFactory;
 
 public class BatchCassandraWriterBolt extends BaseCassandraBolt<List<Tuple>> {
-
+    private static final long serialVersionUID = 3874909124472122932L;
     public static final int DEFAULT_EMIT_FREQUENCY = 2;
     private static final Logger LOG = LoggerFactory.getLogger(BatchCassandraWriterBolt.class);
     private LinkedBlockingQueue<Tuple> queue;

external/storm-cassandra/src/main/java/org/apache/storm/cassandra/bolt/CassandraWriterBolt.java

@@ -20,7 +20,7 @@
 import org.apache.storm.tuple.Tuple;
 
 public class CassandraWriterBolt extends BaseCassandraBolt<Tuple> {
-
+    private static final long serialVersionUID = 5043125450713195041L;
     private AsyncResultHandler<Tuple> asyncResultHandler;
 
     /**

external/storm-cassandra/src/main/java/org/apache/storm/cassandra/client/CassandraConf.java

@@ -36,7 +36,7 @@
  * Configuration used by cassandra storm components.
  */
 public class CassandraConf implements Serializable {
-
+    private static final long serialVersionUID = -297312399366194518L;
     public static final String CASSANDRA_USERNAME = "cassandra.username";
     public static final String CASSANDRA_PASSWORD = "cassandra.password";
     public static final String CASSANDRA_KEYSPACE = "cassandra.keyspace";

external/storm-cassandra/src/main/java/org/apache/storm/cassandra/client/impl/DefaultClient.java

@@ -31,6 +31,7 @@
 public class DefaultClient implements SimpleClient, Closeable, Serializable {
 
     private static final Logger LOG = LoggerFactory.getLogger(DefaultClient.class);
+    private static final long serialVersionUID = -5197633787983669015L;
 
     private String keyspace;
 

external/storm-cassandra/src/main/java/org/apache/storm/cassandra/query/builder/ObjectMapperCqlStatementMapperBuilder.java

@@ -31,6 +31,7 @@
  * </p>
  */
 public class ObjectMapperCqlStatementMapperBuilder implements CQLStatementBuilder<ObjectMapperCqlStatementMapper>, Serializable {
+    private static final long serialVersionUID = 7678503881511207283L;
     private final String operationField;
     private final String valueField;
     private final Collection<Class<?>> udtClasses = new ArrayList<>();

external/storm-cassandra/src/main/java/org/apache/storm/cassandra/query/builder/SimpleCQLStatementMapperBuilder.java

@@ -28,6 +28,7 @@
 @SuppressWarnings("checkstyle:AbbreviationAsWordInName")
 public class SimpleCQLStatementMapperBuilder implements CQLStatementBuilder<SimpleCQLStatementMapper>, Serializable {
 
+    private static final long serialVersionUID = 7042291088422917602L;
     private final String queryString;
 
     private CqlMapper mapper;

external/storm-elasticsearch/src/main/java/org/apache/storm/elasticsearch/bolt/EsIndexBolt.java

@@ -36,6 +36,7 @@
  * Basic bolt for storing tuple to ES document.
  */
 public class EsIndexBolt extends AbstractEsBolt {
+    private static final long serialVersionUID = -7642077255818586463L;
     private final EsTupleMapper tupleMapper;
 
     /**

external/storm-elasticsearch/src/main/java/org/apache/storm/elasticsearch/bolt/EsLookupBolt.java

@@ -41,6 +41,7 @@
  */
 public class EsLookupBolt extends AbstractEsBolt {
 
+    private static final long serialVersionUID = -5863240030393506846L;
     private final EsTupleMapper tupleMapper;
     private final EsLookupResultOutput output;
 

external/storm-elasticsearch/src/main/java/org/apache/storm/elasticsearch/bolt/EsPercolateBolt.java

@@ -41,6 +41,7 @@
  */
 public class EsPercolateBolt extends AbstractEsBolt {
 
+    private static final long serialVersionUID = 8103823842646188246L;
     private final EsTupleMapper tupleMapper;
 
     /**

external/storm-elasticsearch/src/main/java/org/apache/storm/elasticsearch/common/StormElasticSearchClient.java

@@ -28,6 +28,7 @@
  */
 public final class StormElasticSearchClient implements Serializable {
 
+    private static final long serialVersionUID = -3910184447842451527L;
     private final EsConfig esConfig;
 
     public StormElasticSearchClient(EsConfig esConfig) {

external/storm-eventhubs/src/main/java/org/apache/storm/eventhubs/bolt/EventHubBolt.java

@@ -38,8 +38,7 @@
  */
 public class EventHubBolt extends BaseRichBolt {
     private static final long serialVersionUID = 1L;
-    private static final Logger logger = LoggerFactory
-        .getLogger(EventHubBolt.class);
+    private static final Logger logger = LoggerFactory.getLogger(EventHubBolt.class);
 
     protected OutputCollector collector;
     protected PartitionSender sender;

external/storm-eventhubs/src/test/java/org/apache/storm/eventhubs/samples/AtMostOnceEventCount.java

@@ -28,6 +28,8 @@
 import org.apache.storm.eventhubs.spout.SimplePartitionManager;
 
 public class AtMostOnceEventCount extends EventCount implements Serializable {
+    private static final long serialVersionUID = 2276482213939453480L;
+
     public static void main(String[] args) throws Exception {
         AtMostOnceEventCount scenario = new AtMostOnceEventCount();
 

external/storm-hbase/src/main/java/org/apache/storm/hbase/bolt/HBaseBolt.java

@@ -35,6 +35,7 @@
  */
 @SuppressWarnings("checkstyle:AbbreviationAsWordInName")
 public class HBaseBolt extends AbstractHBaseBolt {
+    private static final long serialVersionUID = 2138011224544163322L;
     private static final Logger LOG = LoggerFactory.getLogger(HBaseBolt.class);
     private static final int DEFAULT_FLUSH_INTERVAL_SECS = 1;
 

external/storm-hbase/src/main/java/org/apache/storm/hbase/bolt/HBaseLookupBolt.java

@@ -39,6 +39,7 @@
  * <p>Note: Each HBaseBolt defined in a topology is tied to a specific table.
  */
 public class HBaseLookupBolt extends AbstractHBaseBolt {
+    private static final long serialVersionUID = -8206079974670011700L;
     private static final Logger LOG = LoggerFactory.getLogger(HBaseLookupBolt.class);
 
     private HBaseValueMapper rowToTupleMapper;

external/storm-hbase/src/main/java/org/apache/storm/hbase/trident/state/HBaseMapState.java

@@ -201,7 +201,7 @@ public void multiPut(List<List<Object>> keys, List<T> values) {
     }
 
     public static class Options<T> implements Serializable {
-
+        private static final long serialVersionUID = -6513148451415208612L;
         public Serializer<T> serializer = null;
         public int cacheSize = 5000;
         public String globalKey = "$HBASE_STATE_GLOBAL$";

external/storm-hdfs/src/main/java/org/apache/storm/hdfs/bolt/AvroGenericRecordBolt.java

@@ -33,7 +33,7 @@
 import org.slf4j.LoggerFactory;
 
 public class AvroGenericRecordBolt extends AbstractHdfsBolt {
-
+    private static final long serialVersionUID = 3426992477471290298L;
     private static final Logger LOG = LoggerFactory.getLogger(AvroGenericRecordBolt.class);
 
     public AvroGenericRecordBolt withFsUrl(String fsUrl) {

external/storm-hdfs/src/main/java/org/apache/storm/hdfs/bolt/HdfsBolt.java

@@ -33,6 +33,7 @@
 import org.slf4j.LoggerFactory;
 
 public class HdfsBolt extends AbstractHdfsBolt {
+    private static final long serialVersionUID = 8732488717499902331L;
     private static final Logger LOG = LoggerFactory.getLogger(HdfsBolt.class);
 
     private transient FSDataOutputStream out;

external/storm-hive/src/main/java/org/apache/storm/hive/bolt/HiveBolt.java

@@ -44,6 +44,7 @@
 import org.slf4j.LoggerFactory;
 
 public class HiveBolt extends BaseRichBolt {
+    private static final long serialVersionUID = -8477018696751233324L;
     private static final Logger LOG = LoggerFactory.getLogger(HiveBolt.class);
     @VisibleForTesting
     Map<HiveEndPoint, HiveWriter> allWriters;

external/storm-jdbc/src/main/java/org/apache/storm/jdbc/bolt/JdbcInsertBolt.java

@@ -33,6 +33,7 @@
  * Note: Each JdbcInsertBolt defined in a topology is tied to a specific table.
  */
 public class JdbcInsertBolt extends AbstractJdbcBolt {
+    private static final long serialVersionUID = -2719870314706220578L;
     private static final Logger LOG = LoggerFactory.getLogger(JdbcInsertBolt.class);
 
     private String tableName;

external/storm-jdbc/src/main/java/org/apache/storm/jdbc/bolt/JdbcLookupBolt.java

@@ -27,6 +27,7 @@
  * Basic bolt for querying from any database.
  */
 public class JdbcLookupBolt extends AbstractJdbcBolt {
+    private static final long serialVersionUID = 7695955541005384059L;
     private static final Logger LOG = LoggerFactory.getLogger(JdbcLookupBolt.class);
 
     private String selectQuery;

external/storm-jdbc/src/main/java/org/apache/storm/jdbc/trident/state/JdbcState.java

@@ -110,6 +110,7 @@ public List<List<Values>> batchRetrieve(List<TridentTuple> tridentTuples) {
     }
 
     public static class Options implements Serializable {
+        private static final long serialVersionUID = -1642655048655000396L;
         private JdbcMapper mapper;
         private JdbcLookupMapper jdbcLookupMapper;
         private ConnectionProvider connectionProvider;

external/storm-jms/src/main/java/org/apache/storm/jms/bolt/JmsBolt.java

@@ -53,6 +53,7 @@
  * it does not emit any tuples.
  */
 public class JmsBolt extends BaseTickTupleAwareRichBolt {
+    private static final long serialVersionUID = -6203834510835411472L;
     private static Logger LOG = LoggerFactory.getLogger(JmsBolt.class);
 
     private boolean autoAck = true;

external/storm-jms/src/main/java/org/apache/storm/jms/trident/JmsState.java

@@ -100,6 +100,7 @@ public void updateState(List<TridentTuple> tuples, TridentCollector collector) t
     }
 
     public static class Options implements Serializable {
+        private static final long serialVersionUID = 8022017182667431203L;
         private JmsProvider jmsProvider;
         private JmsMessageProducer msgProducer;
         private int jmsAcknowledgeMode = Session.AUTO_ACKNOWLEDGE;

external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/KafkaSpoutRetryExponentialBackoff.java

@@ -56,6 +56,8 @@ public class KafkaSpoutRetryExponentialBackoff implements KafkaSpoutRetryService
      * Comparator ordering by timestamp. 
      */
     private static class RetryEntryTimeStampComparator implements Serializable, Comparator<RetrySchedule> {
+        private static final long serialVersionUID = -4964614653561591552L;
+
         @Override
         public int compare(RetrySchedule entry1, RetrySchedule entry2) {
             int result = Long.valueOf(entry1.nextRetryTimeNanos()).compareTo(entry2.nextRetryTimeNanos());

external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/trident/KafkaTridentSpoutCoordinator.java

@@ -39,6 +39,7 @@ public class KafkaTridentSpoutCoordinator<K,V> implements
     IOpaquePartitionedTridentSpout.Coordinator<List<Map<String, Object>>>,
     IPartitionedTridentSpout.Coordinator<List<Map<String, Object>>>,
         Serializable {
+    private static final long serialVersionUID = 831108958500512737L;
     //Initial delay for the assignment refresh timer
     public static final long TIMER_DELAY_MS = 500;
     private static final Logger LOG = LoggerFactory.getLogger(KafkaTridentSpoutCoordinator.class);

external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/trident/KafkaTridentSpoutTopicPartition.java

@@ -26,6 +26,7 @@
  * {@link ISpoutPartition} that wraps {@link TopicPartition} information.
  */
 public class KafkaTridentSpoutTopicPartition implements ISpoutPartition, Serializable {
+    private static final long serialVersionUID = -4695977965301783511L;
     private final TopicPartition topicPartition;
 
     public KafkaTridentSpoutTopicPartition(String topic, int partition) {

external/storm-kinesis/src/main/java/org/apache/storm/kinesis/spout/KinesisConfig.java

@@ -24,6 +24,7 @@
 import java.util.Date;
 
 public class KinesisConfig implements Serializable {
+    private static final long serialVersionUID = -2660946324365967869L;
     // kinesis stream name to read from
     private final String streamName;
     // shard iterator type based on kinesis api - beginning of time, latest, at timestamp are only supported

external/storm-kinesis/src/main/java/org/apache/storm/kinesis/spout/KinesisConnectionInfo.java

@@ -33,6 +33,7 @@
 import org.objenesis.strategy.StdInstantiatorStrategy;
 
 public class KinesisConnectionInfo implements Serializable {
+    private static final long serialVersionUID = 8799748040190430626L;
     private final byte[] serializedKinesisCredsProvider;
     private final byte[] serializedkinesisClientConfig;
     private final Integer recordsLimit;

external/storm-kinesis/src/test/java/org/apache/storm/kinesis/spout/test/TestRecordToTupleMapper.java

@@ -32,6 +32,8 @@
 
 public class TestRecordToTupleMapper implements RecordToTupleMapper, Serializable {
     private static final Logger LOG = LoggerFactory.getLogger(TestRecordToTupleMapper.class);
+    private static final long serialVersionUID = -8825697100165763982L;
+
     @Override
     public Fields getOutputFields() {
         return new Fields("partitionKey", "sequenceNumber", "data");

external/storm-mongodb/src/main/java/org/apache/storm/mongodb/bolt/MongoInsertBolt.java

@@ -37,7 +37,7 @@
  * Note: Each MongoInsertBolt defined in a topology is tied to a specific collection.
  */
 public class MongoInsertBolt extends AbstractMongoBolt {
-
+    private static final long serialVersionUID = 5181213261367939689L;
     private static final int DEFAULT_FLUSH_INTERVAL_SECS = 1;
 
     private MongoMapper mapper;

external/storm-mongodb/src/main/java/org/apache/storm/mongodb/bolt/MongoLookupBolt.java

@@ -34,7 +34,7 @@
  * Note: Each MongoLookupBolt defined in a topology is tied to a specific collection.
  */
 public class MongoLookupBolt extends AbstractMongoBolt {
-
+    private static final long serialVersionUID = -5170877102054804819L;
     private QueryFilterCreator queryCreator;
     private MongoLookupMapper mapper;
 

external/storm-mongodb/src/main/java/org/apache/storm/mongodb/bolt/MongoUpdateBolt.java

@@ -32,7 +32,7 @@
  * Note: Each MongoUpdateBolt defined in a topology is tied to a specific collection.
  */
 public class MongoUpdateBolt extends AbstractMongoBolt {
-
+    private static final long serialVersionUID = -5520612633851250677L;
     private QueryFilterCreator queryCreator;
     private MongoUpdateMapper mapper;
 

external/storm-mongodb/src/main/java/org/apache/storm/mongodb/trident/state/MongoMapState.java

@@ -84,6 +84,7 @@ protected MongoMapState(Map<String, Object> map, Options options) {
     }
 
     public static class Options<T> implements Serializable {
+        private static final long serialVersionUID = 3252817063788089651L;
         public String url;
         public String collectionName;
         public MongoMapper mapper;

external/storm-mongodb/src/main/java/org/apache/storm/mongodb/trident/state/MongoState.java

@@ -53,6 +53,7 @@ protected MongoState(Map<String, Object> map, Options options) {
     }
 
     public static class Options implements Serializable {
+        private static final long serialVersionUID = 241563415043284544L;
         private String url;
         private String collectionName;
         private MongoMapper mapper;