Change top level java package to spesb and adopt main class in gradle

Add the spesb prefix to all self implemented java packages of the
project. Because this changes the fully qualified class name of
the main classes the build.gradle files need to adopt to this.

uc1-application/build.gradle

@@ -21,7 +21,7 @@ dependencies {
     testCompile 'junit:junit:4.12'
 }
 
-mainClassName = "uc1.application.HistoryService"
+mainClassName = "spesb.uc1.application.HistoryService"
 
 eclipse {
     classpath {

uc1-application/src/main/java/uc1/application/ConfigurationKeys.java → uc1-application/src/main/java/spesb/uc1/application/ConfigurationKeys.java

-package uc1.application;
+package spesb.uc1.application;
 
 /**
  * Keys to access configuration parameters.

uc1-application/src/main/java/uc1/application/HistoryService.java → uc1-application/src/main/java/spesb/uc1/application/HistoryService.java

-package uc1.application;
+package spesb.uc1.application;
 
 import java.util.concurrent.CompletableFuture;
 import org.apache.commons.configuration2.Configuration;
 import org.apache.kafka.streams.KafkaStreams;
+import spesb.uc1.streamprocessing.KafkaStreamsBuilder;
 import titan.ccp.common.configuration.Configurations;
-import uc1.streamprocessing.KafkaStreamsBuilder;
 
 /**
  * A microservice that manages the history and, therefore, stores and aggregates incoming

uc1-application/src/main/java/uc1/streamprocessing/KafkaStreamsBuilder.java → uc1-application/src/main/java/spesb/uc1/streamprocessing/KafkaStreamsBuilder.java

-package uc1.streamprocessing;
+package spesb.uc1.streamprocessing;
 
 import java.util.Objects;
 import java.util.Properties;

uc1-application/src/main/java/uc1/streamprocessing/TopologyBuilder.java → uc1-application/src/main/java/spesb/uc1/streamprocessing/TopologyBuilder.java

-package uc1.streamprocessing;
+package spesb.uc1.streamprocessing;
 
 import com.google.gson.Gson;
 import org.apache.kafka.common.serialization.Serdes;

uc1-workload-generator/build.gradle

@@ -21,7 +21,7 @@ dependencies {
     testCompile 'junit:junit:4.12'
 }
 
-mainClassName = "uc1.workloadGenerator.LoadGenerator"
+mainClassName = "spesb.uc1.workloadgenerator.LoadGenerator"
 
 eclipse {
     classpath {

uc1-workload-generator/src/main/java/kafkaSender/KafkaRecordSender.java → uc1-workload-generator/src/main/java/spesb/kafkasender/KafkaRecordSender.java

-package kafkaSender;
+package spesb.kafkasender;
 
 import java.util.Properties;
 import java.util.function.Function;

uc1-workload-generator/src/main/java/uc1/workloadGenerator/LoadGenerator.java → uc1-workload-generator/src/main/java/spesb/uc1/workloadgenerator/LoadGenerator.java

-package uc1.workloadGenerator;
+package spesb.uc1.workloadgenerator;
 
 import java.io.IOException;
 import java.util.List;
@@ -11,10 +11,10 @@ import java.util.concurrent.TimeUnit;
 import java.util.regex.Pattern;
 import java.util.stream.Collectors;
 import java.util.stream.IntStream;
-import kafkaSender.KafkaRecordSender;
 import org.apache.kafka.clients.producer.ProducerConfig;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
+import spesb.kafkasender.KafkaRecordSender;
 import titan.ccp.models.records.ActivePowerRecord;
 
 public class LoadGenerator {

uc2-application/build.gradle

@@ -21,7 +21,7 @@ dependencies {
     testCompile 'junit:junit:4.12'
 }
 
-mainClassName = "uc2.application.AggregationService"
+mainClassName = "spesb.uc2.application.AggregationService"
 
 eclipse {
     classpath {

uc2-application/src/main/java/uc2/application/AggregationService.java → uc2-application/src/main/java/spesb/uc2/application/AggregationService.java

-package uc2.application;
+package spesb.uc2.application;
 
 import java.time.Duration;
 import java.util.concurrent.CompletableFuture;
 import org.apache.commons.configuration2.Configuration;
 import org.apache.kafka.streams.KafkaStreams;
+import spesb.uc2.streamprocessing.KafkaStreamsBuilder;
 import titan.ccp.common.configuration.Configurations;
-import uc2.streamprocessing.KafkaStreamsBuilder;
 
 /**
  * A microservice that manages the history and, therefore, stores and aggregates

uc2-application/src/main/java/uc2/application/ConfigurationKeys.java → uc2-application/src/main/java/spesb/uc2/application/ConfigurationKeys.java

-package uc2.application;
+package spesb.uc2.application;
 
 /**
  * Keys to access configuration parameters.

uc2-application/src/main/java/uc2/streamprocessing/ChildParentsTransformer.java → uc2-application/src/main/java/spesb/uc2/streamprocessing/ChildParentsTransformer.java

-package uc2.streamprocessing;
+package spesb.uc2.streamprocessing;
 
 import java.util.Map;
 import java.util.Optional;

uc2-application/src/main/java/uc2/streamprocessing/ChildParentsTransformerFactory.java → uc2-application/src/main/java/spesb/uc2/streamprocessing/ChildParentsTransformerFactory.java

-package uc2.streamprocessing;
+package spesb.uc2.streamprocessing;
 
 import java.util.Map;
 import java.util.Optional;

uc2-application/src/main/java/uc2/streamprocessing/JointFlatTransformer.java → uc2-application/src/main/java/spesb/uc2/streamprocessing/JointFlatTransformer.java

-package uc2.streamprocessing;
+package spesb.uc2.streamprocessing;
 
 import com.google.common.base.MoreObjects;
 import java.util.ArrayList;

uc2-application/src/main/java/uc2/streamprocessing/JointFlatTransformerFactory.java → uc2-application/src/main/java/spesb/uc2/streamprocessing/JointFlatTransformerFactory.java

-package uc2.streamprocessing;
+package spesb.uc2.streamprocessing;
 
 import java.util.Map;
 import java.util.Set;

uc2-application/src/main/java/uc2/streamprocessing/JointRecordParents.java → uc2-application/src/main/java/spesb/uc2/streamprocessing/JointRecordParents.java

-package uc2.streamprocessing;
+package spesb.uc2.streamprocessing;
 
 import java.util.Set;
 import titan.ccp.models.records.ActivePowerRecord;

uc2-application/src/main/java/uc2/streamprocessing/KafkaStreamsBuilder.java → uc2-application/src/main/java/spesb/uc2/streamprocessing/KafkaStreamsBuilder.java

-package uc2.streamprocessing;
+package spesb.uc2.streamprocessing;
 
 import java.time.Duration;
 import java.util.Objects;

uc2-application/src/main/java/uc2/streamprocessing/OptionalParentsSerde.java → uc2-application/src/main/java/spesb/uc2/streamprocessing/OptionalParentsSerde.java

-package uc2.streamprocessing;
+package spesb.uc2.streamprocessing;
 
 import java.util.HashSet;
 import java.util.Optional;

uc2-application/src/main/java/uc2/streamprocessing/ParentsSerde.java → uc2-application/src/main/java/spesb/uc2/streamprocessing/ParentsSerde.java

-package uc2.streamprocessing;
+package spesb.uc2.streamprocessing;
 
 import java.util.HashSet;
 import java.util.Set;

uc2-application/src/main/java/uc2/streamprocessing/RecordAggregator.java → uc2-application/src/main/java/spesb/uc2/streamprocessing/RecordAggregator.java

-package uc2.streamprocessing;
+package spesb.uc2.streamprocessing;
 
 import org.apache.kafka.streams.kstream.Windowed;
 import titan.ccp.models.records.ActivePowerRecord;