KYLO-1611: Added serialVersionUID field to all Serializable classes

core/alerts/alerts-api/src/main/java/com/thinkbiganalytics/alerts/spi/DefaultAlertChangeEventContent.java

@@ -30,6 +30,8 @@
  */
 public class DefaultAlertChangeEventContent implements Serializable {
 
+    private static final long serialVersionUID = -164758136811173896L;
+
     Map<String,Object> content = new HashMap<>();
 
     public Map<String, Object> getContent() {

core/alerts/alerts-api/src/main/java/com/thinkbiganalytics/alerts/spi/EntityIdentificationAlertContent.java

@@ -31,6 +31,8 @@
  */
 public class EntityIdentificationAlertContent<C extends Serializable> implements Serializable{
 
+    private static final long serialVersionUID = 2800230633833411478L;
+
     private String entityId;
     /**
      * Should be of type SecurityRole.ENTITIES

core/cluster-manager/cluster-manager-api/src/main/java/com/thinkbiganalytics/cluster/StandardClusterMessage.java

@@ -26,6 +26,9 @@
  * A standard cluster message implementation
  */
 public class StandardClusterMessage implements ClusterMessage, Serializable {
+
+    private static final long serialVersionUID = 8137855394654778278L;
+
     private String id;
 
     private String type;

core/cluster-manager/cluster-manager-core/src/main/java/com/thinkbiganalytics/cluster/SimpleClusterMessageTest.java

@@ -28,6 +28,8 @@
  */
 public class SimpleClusterMessageTest implements Serializable{
 
+    private static final long serialVersionUID = 6313893570788932028L;
+
     private String type;
     private String message;
     private String from;

core/job-repository/job-repository-core/src/main/java/com/thinkbiganalytics/jobrepo/query/model/ExitStatus.java

@@ -24,6 +24,8 @@
 
 public class ExitStatus implements Serializable, Comparable<ExitStatus> {
 
+    private static final long serialVersionUID = -7478575185601667437L;
+
     public static final ExitStatus UNKNOWN = new ExitStatus("UNKNOWN");
     public static final ExitStatus EXECUTING = new ExitStatus("EXECUTING");
     public static final ExitStatus COMPLETED = new ExitStatus("COMPLETED");

core/operational-metadata/operational-metadata-api/src/main/java/com/thinkbiganalytics/metadata/api/event/job/DataConfidenceJobDetected.java

@@ -29,6 +29,8 @@
  */
 public class DataConfidenceJobDetected extends OperationStatus implements Serializable {
 
+    private static final long serialVersionUID = 4600288004150299218L;
+
     public DataConfidenceJobDetected(Feed.ID id, String feedName, FeedOperation.FeedType feedType,
                                      FeedOperation.ID opId, FeedOperation.State state, String status) {
         super(id, feedName, feedType, opId, state, status);

core/operational-metadata/operational-metadata-jpa/src/main/java/com/thinkbiganalytics/metadata/jpa/app/JpaKyloVersion.java

@@ -44,6 +44,8 @@
 @Table(name = "KYLO_VERSION")
 public class JpaKyloVersion extends AbstractAuditedEntity implements KyloVersion, Serializable {
 
+    private static final long serialVersionUID = -2921950159106351783L;
+
     private static final Logger log = LoggerFactory.getLogger(JpaKyloVersion.class);
 
     @Id

core/operational-metadata/operational-metadata-jpa/src/main/java/com/thinkbiganalytics/metadata/jpa/cache/CacheBackedProviderClusterMessage.java

@@ -27,6 +27,8 @@
  */
 public class CacheBackedProviderClusterMessage<T> implements Serializable {
 
+    private static final long serialVersionUID = 7885759295819771699L;
+
     public static enum Type {
         REMOVED, ADDED, REFRESHED
     }

core/operational-metadata/operational-metadata-jpa/src/main/java/com/thinkbiganalytics/metadata/jpa/cluster/JpaNiFiFlowCacheClusterSync.java

@@ -144,6 +144,8 @@ public void setModifiedTime(DateTime modifiedTime) {
     @Embeddable
     public static class NiFiFlowCacheKey implements Serializable {
 
+        private static final long serialVersionUID = -9135627079696305561L;
+
         @Column(name = "KYLO_CLUSTER_ADDRESS")
         private String clusterAddress;
 

core/operational-metadata/operational-metadata-jpa/src/main/java/com/thinkbiganalytics/metadata/jpa/common/JpaItemLastModified.java

@@ -39,6 +39,8 @@
 @Table(name = "ITEM_LAST_MODIFIED")
 public class JpaItemLastModified implements Serializable, ItemLastModified {
 
+    private static final long serialVersionUID = 3792281204005781733L;
+
 
     @Id
     @Column(name = "ITEM_KEY")

core/operational-metadata/operational-metadata-jpa/src/main/java/com/thinkbiganalytics/metadata/jpa/jobrepo/job/JpaBatchJobExecutionParameter.java

@@ -49,6 +49,8 @@
 @Table(name = "BATCH_JOB_EXECUTION_PARAMS")
 public class JpaBatchJobExecutionParameter implements Serializable, BatchJobExecutionParameter {
 
+    private static final long serialVersionUID = -5728274722237317174L;
+
 
     @EmbeddedId
     private BatchJobExecutionParametersPK jobExecutionParametersPK;

core/operational-metadata/operational-metadata-jpa/src/main/java/com/thinkbiganalytics/metadata/jpa/jobrepo/nifi/JpaNifiEvent.java

@@ -335,6 +335,8 @@ public void setClusterNodeAddress(String clusterNodeAddress) {
     @Embeddable
     public static class NiFiEventPK implements Serializable {
 
+        private static final long serialVersionUID = -1709077666909588873L;
+
         @Column(name = "EVENT_ID")
         private Long eventId;
 

core/operational-metadata/operational-metadata-jpa/src/main/java/com/thinkbiganalytics/metadata/jpa/jobrepo/nifi/JpaNifiEventJobExecution.java

@@ -42,6 +42,8 @@
 @Table(name = "BATCH_NIFI_JOB")
 public class JpaNifiEventJobExecution implements Serializable, NifiEventJobExecution {
 
+    private static final long serialVersionUID = 1468401235969406140L;
+
     @OneToOne(targetEntity = JpaBatchJobExecution.class, cascade = CascadeType.ALL, fetch = FetchType.LAZY, optional = false)
     @JoinColumn(name = "JOB_EXECUTION_ID", nullable = false, insertable = true, updatable = true)
     private BatchJobExecution jobExecution;

core/operational-metadata/operational-metadata-jpa/src/main/java/com/thinkbiganalytics/metadata/jpa/jobrepo/nifi/JpaNifiEventStepExecution.java

@@ -45,6 +45,8 @@
 @Table(name = "BATCH_NIFI_STEP")
 public class JpaNifiEventStepExecution implements Serializable, NifiEventStepExecution {
 
+    private static final long serialVersionUID = -7469099741665710069L;
+
     @EmbeddedId
     private NifiEventStepExecutionPK eventStepExecutionPK;
 

core/operational-metadata/operational-metadata-jpa/src/main/java/com/thinkbiganalytics/metadata/jpa/jobrepo/nifi/JpaNifiRelatedRootFlowFiles.java

@@ -98,6 +98,8 @@ public void setEvent(NifiEvent event) {
     @Embeddable
     public static class NifiRelatedFlowFilesPK implements Serializable {
 
+        private static final long serialVersionUID = -153279820265257805L;
+
         @Column(name = "FLOW_FILE_ID")
         private String flowFileId;
 

core/operational-metadata/operational-metadata-jpa/src/main/java/com/thinkbiganalytics/metadata/jpa/jobrepo/step/JpaBatchStepExecution.java

@@ -63,6 +63,8 @@
 @Table(name = "BATCH_STEP_EXECUTION")
 public class JpaBatchStepExecution implements Serializable, BatchStepExecution {
 
+    private static final long serialVersionUID = -4282924110260629615L;
+
 
     @TableGenerator(
         name = "STEP_EXECUTION_KEY_GENERATOR",

core/operational-metadata/operational-metadata-jpa/src/main/java/com/thinkbiganalytics/metadata/jpa/sla/CachedServiceLevelAgreement.java

@@ -29,6 +29,8 @@
  */
 public class CachedServiceLevelAgreement implements Serializable {
 
+    private static final long serialVersionUID = 2615928119119153488L;
+
 
     private String name;
     private String id;

integrations/nifi/nifi-nar-bundles/nifi-core-bundle/nifi-core-processors/src/main/java/com/thinkbiganalytics/ingest/TableMergeSyncSupport.java

@@ -49,6 +49,8 @@
  */
 public class TableMergeSyncSupport implements Serializable {
 
+    private static final long serialVersionUID = 372113810587361467L;
+
     private static final Logger logger = LoggerFactory.getLogger(TableMergeSyncSupport.class);
 
     protected Connection conn;

integrations/nifi/nifi-nar-bundles/nifi-core-bundle/nifi-core-processors/src/test/java/com/thinkbiganalytics/ingest/HiveShellTableMergeSyncSupport.java

@@ -56,6 +56,8 @@
 public class HiveShellTableMergeSyncSupport extends TableMergeSyncSupport {
     private static final Logger log = LoggerFactory.getLogger(HiveShellTableMergeSyncSupport.class);
 
+    private static final long serialVersionUID = 3459574380840626975L;
+
     private HiveShell shell;
 
     public HiveShellTableMergeSyncSupport(HiveShell shell) throws SQLException {

integrations/nifi/nifi-nar-bundles/nifi-provenance-repo-bundle/nifi-provenance-repo/src/main/java/com/thinkbiganalytics/nifi/provenance/ProvenanceEventRecordConverter.java

@@ -36,6 +36,8 @@
  */
 public class ProvenanceEventRecordConverter implements Serializable {
 
+    private static final long serialVersionUID = -5171655677407369400L;
+
 
     public static ProvenanceEventRecordDTO convert(final ProvenanceEventRecord event) {
         ProvenanceEventRecordDTO dto = new ProvenanceEventRecordDTO();

integrations/nifi/nifi-nar-bundles/nifi-provenance-repo-bundle/nifi-provenance-repo/src/main/java/com/thinkbiganalytics/nifi/provenance/repo/FeedEventStatistics.java

@@ -63,6 +63,8 @@
  */
 public class FeedEventStatistics implements Serializable {
 
+    private static final long serialVersionUID = 312709295696295868L;
+
     private static final Logger log = LoggerFactory.getLogger(FeedEventStatistics.class);
 
     protected Map<String, String> feedFlowFileIdToFeedProcessorId = new ConcurrentHashMap<>();

integrations/nifi/nifi-nar-bundles/nifi-provenance-repo-bundle/nifi-provenance-repo/src/main/java/com/thinkbiganalytics/nifi/provenance/repo/FeedEventStatisticsData.java

@@ -33,6 +33,8 @@
  */
 public class FeedEventStatisticsData implements Serializable {
 
+    private static final long serialVersionUID = 2553717886105461053L;
+
     protected Map<String, String> feedFlowFileIdToFeedProcessorId = new ConcurrentHashMap<>();
 
     ////Track feedFlowFile relationships to parent/child flow files for lifetime feed job execution

integrations/nifi/nifi-nar-bundles/nifi-provenance-repo-bundle/nifi-provenance-repo/src/main/java/com/thinkbiganalytics/nifi/provenance/repo/FeedEventStatisticsDataV2.java

@@ -28,6 +28,8 @@
  */
 public class FeedEventStatisticsDataV2 extends FeedEventStatisticsData {
 
+    private static final long serialVersionUID = -1800168647080612138L;
+
     /**
      * Count of the flows running by feed processor
      */

integrations/nifi/nifi-provenance-model/src/main/java/com/thinkbiganalytics/nifi/provenance/model/FeedFlowFileJobTrackingStats.java

@@ -41,6 +41,8 @@
  */
 public class FeedFlowFileJobTrackingStats implements Serializable{
 
+    private static final long serialVersionUID = -6092283143558777891L;
+
     //track flows sent vs actual
 
     private Map<String,Integer> actualProcessorIdParentFlowFileCount = null;

integrations/nifi/nifi-provenance-model/src/main/java/com/thinkbiganalytics/nifi/provenance/model/ProvenanceEventRecordDTOHolder.java

@@ -29,6 +29,8 @@
  */
 public class ProvenanceEventRecordDTOHolder implements Serializable {
 
+    private static final long serialVersionUID = -1618204003961560699L;
+
     /**
      * Unique UUID for the group of events
      */

integrations/nifi/nifi-provenance-model/src/main/java/com/thinkbiganalytics/nifi/provenance/model/stats/AggregatedFeedProcessorStatistics.java

@@ -33,6 +33,8 @@
  */
 public class AggregatedFeedProcessorStatistics implements Serializable {
 
+    private static final long serialVersionUID = -6344769389124838681L;
+
     String startingProcessorId;
     String processGroup;
     Map<String, AggregatedProcessorStatistics> processorStats = new ConcurrentHashMap<>();

integrations/nifi/nifi-provenance-model/src/main/java/com/thinkbiganalytics/nifi/provenance/model/stats/AggregatedFeedProcessorStatisticsHolder.java

@@ -38,6 +38,8 @@
  */
 public class AggregatedFeedProcessorStatisticsHolder implements Serializable {
 
+    private static final long serialVersionUID = -1068196853835366691L;
+
     DateTime minTime;
     DateTime maxTime;
     String collectionId;

integrations/nifi/nifi-provenance-model/src/main/java/com/thinkbiganalytics/nifi/provenance/model/stats/AggregatedFeedProcessorStatisticsHolderV2.java

@@ -20,22 +20,16 @@
  * #L%
  */
 
-import org.joda.time.DateTime;
-
 import java.io.Serializable;
 import java.util.HashMap;
-import java.util.List;
 import java.util.Map;
-import java.util.UUID;
-import java.util.concurrent.ConcurrentHashMap;
-import java.util.concurrent.atomic.AtomicLong;
-import java.util.function.Function;
-import java.util.stream.Collectors;
 
 /**
  */
 public class AggregatedFeedProcessorStatisticsHolderV2 extends AggregatedFeedProcessorStatisticsHolder implements Serializable {
 
+    private static final long serialVersionUID = 1295656068564781226L;
+
 
     Map<String,Long> processorIdRunningFlows = new HashMap<>();
 

integrations/nifi/nifi-provenance-model/src/main/java/com/thinkbiganalytics/nifi/provenance/model/stats/AggregatedFeedProcessorStatisticsV2.java

@@ -20,19 +20,15 @@
  * #L%
  */
 
-import com.thinkbiganalytics.nifi.provenance.model.ProvenanceEventRecordDTO;
-
-import org.apache.commons.lang3.StringUtils;
-
 import java.io.Serializable;
-import java.util.Map;
-import java.util.concurrent.ConcurrentHashMap;
 
 /**
  * Group Stats by Feed and Processor
  */
 public class AggregatedFeedProcessorStatisticsV2 extends AggregatedFeedProcessorStatistics implements  Serializable {
 
+    private static final long serialVersionUID = -6628381699524840478L;
+
     public AggregatedFeedProcessorStatisticsV2(){
     super();
     }

integrations/nifi/nifi-provenance-model/src/main/java/com/thinkbiganalytics/nifi/provenance/model/stats/AggregatedProcessorStatistics.java

@@ -20,14 +20,10 @@
  * #L%
  */
 
-import com.thinkbiganalytics.nifi.provenance.model.ProvenanceEventRecordDTO;
-
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 import java.io.Serializable;
-import java.util.ArrayList;
-import java.util.List;
 import java.util.Map;
 import java.util.concurrent.ConcurrentHashMap;
 
@@ -36,6 +32,8 @@
  */
 public class AggregatedProcessorStatistics implements Serializable {
 
+    private static final long serialVersionUID = -6190760690818174916L;
+
     private static final Logger log = LoggerFactory.getLogger(AggregatedProcessorStatistics.class);
 
     String processorId;

integrations/nifi/nifi-provenance-model/src/main/java/com/thinkbiganalytics/nifi/provenance/model/stats/AggregatedProcessorStatisticsV2.java

@@ -24,14 +24,14 @@
 import org.slf4j.LoggerFactory;
 
 import java.io.Serializable;
-import java.util.Map;
-import java.util.concurrent.ConcurrentHashMap;
 
 /**
  * Group Statistics by Processor
  */
 public class AggregatedProcessorStatisticsV2 extends  AggregatedProcessorStatistics implements Serializable {
 
+    private static final long serialVersionUID = -3337985467751428086L;
+
     private static final Logger log = LoggerFactory.getLogger(AggregatedProcessorStatisticsV2.class);
 
 

integrations/nifi/nifi-provenance-model/src/main/java/com/thinkbiganalytics/nifi/provenance/model/stats/BaseStatistics.java

@@ -26,6 +26,8 @@
  */
 public class BaseStatistics implements Serializable {
 
+    private static final long serialVersionUID = 8150307058243131533L;
+
     protected Long time;
     protected long bytesIn = 0L;
     protected long bytesOut = 0L;

integrations/nifi/nifi-provenance-model/src/main/java/com/thinkbiganalytics/nifi/provenance/model/stats/GroupedStats.java

@@ -21,19 +21,15 @@
  */
 
 
-import org.joda.time.DateTime;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
 import java.io.Serializable;
 
 /**
  */
 public class GroupedStats extends BaseStatistics implements Serializable {
 
-    public static final String DEFAULT_SOURCE_CONNECTION_ID = "DEFAULT";
+    private static final long serialVersionUID = 1707825126802974527L;
 
-    private static final Logger log = LoggerFactory.getLogger(GroupedStats.class);
+    public static final String DEFAULT_SOURCE_CONNECTION_ID = "DEFAULT";
 
     /**
      * Unique Key for this grouping of events

integrations/nifi/nifi-provenance-model/src/main/java/com/thinkbiganalytics/nifi/provenance/model/stats/GroupedStatsV2.java

@@ -28,6 +28,8 @@
  */
 public class GroupedStatsV2 extends GroupedStats {
 
+    private static final long serialVersionUID = -4416979090267950335L;
+
     protected Map<String,Object> additionalProperties = new HashMap<>();
 
     protected String latestFlowFileId;

integrations/nifi/nifi-rest/nifi-flow-visitor-model/src/main/java/com/thinkbiganalytics/nifi/rest/model/flow/NifiFlowProcessor.java

@@ -43,6 +43,8 @@
 @JsonIgnoreProperties(ignoreUnknown = true)
 public class NifiFlowProcessor implements Serializable {
 
+    private static final long serialVersionUID = 3637724741306167250L;
+
     private static final Logger log = LoggerFactory.getLogger(NifiFlowProcessor.class);
 
     @JsonProperty("id")

integrations/spark/spark-job-profiler/spark-job-profiler-api/src/main/java/com/thinkbiganalytics/spark/dataprofiler/output/OutputRow.java

@@ -28,9 +28,11 @@
  *
  * ColumnName, MetricType, MetricValue
  */
-@SuppressWarnings({"unused", "serial"})
+@SuppressWarnings("unused")
 public class OutputRow implements Serializable {
 
+    private static final long serialVersionUID = -8872905670704304249L;
+
     private String columnName;
     private String metricType;
     private String metricValue;