Merge branch 'feature/topLevelPackageJava' into 'master'

Add top-level package for Java implementation

Closes #6

See merge request she/spesb!3

uc1-application/build.gradle

-mainClassName = "uc1.application.HistoryService"
+mainClassName = "spesb.uc1.application.HistoryService"

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

-mainClassName = "uc1.workloadGenerator.LoadGenerator"
+mainClassName = "spesb.uc1.workloadgenerator.LoadGenerator"

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

-mainClassName = "uc2.application.AggregationService"
+mainClassName = "spesb.uc2.application.AggregationService"

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;