From e56bde84a2037559d568ec643446c0c5424ab743 Mon Sep 17 00:00:00 2001
From: ben <stu126940@mail.uni-kiel.de>
Date: Mon, 16 Mar 2020 13:16:17 +0100
Subject: [PATCH] renaming
---
.../ccp/aggregation/AggregationService.java | 62 -------------------
.../uc2/application/AggregationService.java | 59 ++++++++++++++++++
.../application}/ConfigurationKeys.java | 2 +-
.../ChildParentsTransformer.java | 2 +-
.../ChildParentsTransformerFactory.java | 2 +-
.../JointFlatTransformer.java | 2 +-
.../JointFlatTransformerFactory.java | 2 +-
.../streamprocessing/JointRecordParents.java | 2 +-
.../streamprocessing/KafkaStreamsBuilder.java | 2 +-
.../OptionalParentsSerde.java | 2 +-
.../streamprocessing/ParentsSerde.java | 2 +-
.../streamprocessing/RecordAggregator.java | 2 +-
.../streamprocessing/SensorParentKey.java | 2 +-
.../SensorParentKeySerde.java | 2 +-
.../streamprocessing/TopologyBuilder.java | 2 +-
.../OptionalParentsSerdeTest.java | 2 +-
.../streamprocessing/ParentsSerdeTest.java | 2 +-
.../SensorParentKeySerdeTest.java | 4 +-
.../KafkaRecordSender.java | 0
.../workloadGenerator}/ConfigPublisher.java | 0
.../ExperimentorBigData.java | 0
.../workloadGenerator}/LoadCounter.java | 0
.../workloadGenerator}/LoadGenerator.java | 0
.../LoadGeneratorExtrem.java | 0
24 files changed, 76 insertions(+), 79 deletions(-)
delete mode 100644 uc2-application/src/main/java/titan/ccp/aggregation/AggregationService.java
create mode 100644 uc2-application/src/main/java/uc2/application/AggregationService.java
rename uc2-application/src/main/java/{titan/ccp/aggregation => uc2/application}/ConfigurationKeys.java (96%)
rename uc2-application/src/main/java/{titan/ccp/aggregation => uc2}/streamprocessing/ChildParentsTransformer.java (98%)
rename uc2-application/src/main/java/{titan/ccp/aggregation => uc2}/streamprocessing/ChildParentsTransformerFactory.java (97%)
rename uc2-application/src/main/java/{titan/ccp/aggregation => uc2}/streamprocessing/JointFlatTransformer.java (98%)
rename uc2-application/src/main/java/{titan/ccp/aggregation => uc2}/streamprocessing/JointFlatTransformerFactory.java (96%)
rename uc2-application/src/main/java/{titan/ccp/aggregation => uc2}/streamprocessing/JointRecordParents.java (92%)
rename uc2-application/src/main/java/{titan/ccp/aggregation => uc2}/streamprocessing/KafkaStreamsBuilder.java (99%)
rename uc2-application/src/main/java/{titan/ccp/aggregation => uc2}/streamprocessing/OptionalParentsSerde.java (96%)
rename uc2-application/src/main/java/{titan/ccp/aggregation => uc2}/streamprocessing/ParentsSerde.java (95%)
rename uc2-application/src/main/java/{titan/ccp/aggregation => uc2}/streamprocessing/RecordAggregator.java (97%)
rename uc2-application/src/main/java/{titan/ccp/aggregation => uc2}/streamprocessing/SensorParentKey.java (93%)
rename uc2-application/src/main/java/{titan/ccp/aggregation => uc2}/streamprocessing/SensorParentKeySerde.java (95%)
rename uc2-application/src/main/java/{titan/ccp/aggregation => uc2}/streamprocessing/TopologyBuilder.java (99%)
rename uc2-workload-generator/src/main/java/{titan/ccp/kiekerbridge => kafkaSender}/KafkaRecordSender.java (100%)
rename uc2-workload-generator/src/main/java/{titan/ccp/kiekerbridge/expbigdata19 => uc2/workloadGenerator}/ConfigPublisher.java (100%)
rename uc2-workload-generator/src/main/java/{titan/ccp/kiekerbridge/expbigdata19 => uc2/workloadGenerator}/ExperimentorBigData.java (100%)
rename uc2-workload-generator/src/main/java/{titan/ccp/kiekerbridge/expbigdata19 => uc2/workloadGenerator}/LoadCounter.java (100%)
rename uc2-workload-generator/src/main/java/{titan/ccp/kiekerbridge/expbigdata19 => uc2/workloadGenerator}/LoadGenerator.java (100%)
rename uc2-workload-generator/src/main/java/{titan/ccp/kiekerbridge/expbigdata19 => uc2/workloadGenerator}/LoadGeneratorExtrem.java (100%)
diff --git a/uc2-application/src/main/java/titan/ccp/aggregation/AggregationService.java b/uc2-application/src/main/java/titan/ccp/aggregation/AggregationService.java
deleted file mode 100644
index 0058e939b..000000000
--- a/uc2-application/src/main/java/titan/ccp/aggregation/AggregationService.java
+++ /dev/null
@@ -1,62 +0,0 @@
-package titan.ccp.aggregation;
-
-import java.time.Duration;
-import java.util.concurrent.CompletableFuture;
-import org.apache.commons.configuration2.Configuration;
-import org.apache.kafka.streams.KafkaStreams;
-import titan.ccp.aggregation.streamprocessing.KafkaStreamsBuilder;
-import titan.ccp.common.configuration.Configurations;
-
-/**
- * A microservice that manages the history and, therefore, stores and aggregates incoming
- * measurements.
- *
- */
-public class AggregationService {
-
- private final Configuration config = Configurations.create();
-
- private final CompletableFuture<Void> stopEvent = new CompletableFuture<>();
-
-
- /**
- * Start the service.
- */
- public void run() {
- this.createKafkaStreamsApplication();
- }
-
- public static void main(final String[] args) {
- new AggregationService().run();
- }
-
-
- /**
- * Build and start the underlying Kafka Streams Application of the service.
- *
- * @param clusterSession the database session which the application should use.
- */
- private void createKafkaStreamsApplication() {
- final KafkaStreams kafkaStreams = new KafkaStreamsBuilder()
- .bootstrapServers(this.config.getString(ConfigurationKeys.KAFKA_BOOTSTRAP_SERVERS))
- .inputTopic(this.config.getString(ConfigurationKeys.KAFKA_INPUT_TOPIC))
- .outputTopic(this.config.getString(ConfigurationKeys.KAFKA_OUTPUT_TOPIC))
- .configurationTopic(this.config.getString(ConfigurationKeys.CONFIGURATION_KAFKA_TOPIC))
- .windowSize(Duration.ofMillis(this.config.getLong(ConfigurationKeys.WINDOW_SIZE_MS)))
- .gracePeriod(Duration.ofMillis(this.config.getLong(ConfigurationKeys.WINDOW_GRACE_MS)))
- .numThreads(this.config.getInt(ConfigurationKeys.NUM_THREADS))
- .commitIntervalMs(this.config.getInt(ConfigurationKeys.COMMIT_INTERVAL_MS))
- .cacheMaxBytesBuffering(this.config.getInt(ConfigurationKeys.CACHE_MAX_BYTES_BUFFERING))
- .build();
- this.stopEvent.thenRun(kafkaStreams::close);
- kafkaStreams.start();
- }
-
- /**
- * Stop the service.
- */
- public void stop() {
- this.stopEvent.complete(null);
- }
-
-}
diff --git a/uc2-application/src/main/java/uc2/application/AggregationService.java b/uc2-application/src/main/java/uc2/application/AggregationService.java
new file mode 100644
index 000000000..696b13f48
--- /dev/null
+++ b/uc2-application/src/main/java/uc2/application/AggregationService.java
@@ -0,0 +1,59 @@
+package uc2.application;
+
+import java.time.Duration;
+import java.util.concurrent.CompletableFuture;
+import org.apache.commons.configuration2.Configuration;
+import org.apache.kafka.streams.KafkaStreams;
+import titan.ccp.common.configuration.Configurations;
+import uc2.streamprocessing.KafkaStreamsBuilder;
+
+/**
+ * A microservice that manages the history and, therefore, stores and aggregates
+ * incoming measurements.
+ *
+ */
+public class AggregationService {
+
+ private final Configuration config = Configurations.create();
+
+ private final CompletableFuture<Void> stopEvent = new CompletableFuture<>();
+
+ /**
+ * Start the service.
+ */
+ public void run() {
+ this.createKafkaStreamsApplication();
+ }
+
+ public static void main(final String[] args) {
+ new AggregationService().run();
+ }
+
+ /**
+ * Build and start the underlying Kafka Streams Application of the service.
+ *
+ * @param clusterSession the database session which the application should use.
+ */
+ private void createKafkaStreamsApplication() {
+ final KafkaStreams kafkaStreams = new KafkaStreamsBuilder()
+ .bootstrapServers(this.config.getString(ConfigurationKeys.KAFKA_BOOTSTRAP_SERVERS))
+ .inputTopic(this.config.getString(ConfigurationKeys.KAFKA_INPUT_TOPIC))
+ .outputTopic(this.config.getString(ConfigurationKeys.KAFKA_OUTPUT_TOPIC))
+ .configurationTopic(this.config.getString(ConfigurationKeys.CONFIGURATION_KAFKA_TOPIC))
+ .windowSize(Duration.ofMillis(this.config.getLong(ConfigurationKeys.WINDOW_SIZE_MS)))
+ .gracePeriod(Duration.ofMillis(this.config.getLong(ConfigurationKeys.WINDOW_GRACE_MS)))
+ .numThreads(this.config.getInt(ConfigurationKeys.NUM_THREADS))
+ .commitIntervalMs(this.config.getInt(ConfigurationKeys.COMMIT_INTERVAL_MS))
+ .cacheMaxBytesBuffering(this.config.getInt(ConfigurationKeys.CACHE_MAX_BYTES_BUFFERING)).build();
+ this.stopEvent.thenRun(kafkaStreams::close);
+ kafkaStreams.start();
+ }
+
+ /**
+ * Stop the service.
+ */
+ public void stop() {
+ this.stopEvent.complete(null);
+ }
+
+}
diff --git a/uc2-application/src/main/java/titan/ccp/aggregation/ConfigurationKeys.java b/uc2-application/src/main/java/uc2/application/ConfigurationKeys.java
similarity index 96%
rename from uc2-application/src/main/java/titan/ccp/aggregation/ConfigurationKeys.java
rename to uc2-application/src/main/java/uc2/application/ConfigurationKeys.java
index fd6286fea..08d5e1eb2 100644
--- a/uc2-application/src/main/java/titan/ccp/aggregation/ConfigurationKeys.java
+++ b/uc2-application/src/main/java/uc2/application/ConfigurationKeys.java
@@ -1,4 +1,4 @@
-package titan.ccp.aggregation;
+package uc2.application;
/**
* Keys to access configuration parameters.
diff --git a/uc2-application/src/main/java/titan/ccp/aggregation/streamprocessing/ChildParentsTransformer.java b/uc2-application/src/main/java/uc2/streamprocessing/ChildParentsTransformer.java
similarity index 98%
rename from uc2-application/src/main/java/titan/ccp/aggregation/streamprocessing/ChildParentsTransformer.java
rename to uc2-application/src/main/java/uc2/streamprocessing/ChildParentsTransformer.java
index 8422a5c93..4315aad5b 100644
--- a/uc2-application/src/main/java/titan/ccp/aggregation/streamprocessing/ChildParentsTransformer.java
+++ b/uc2-application/src/main/java/uc2/streamprocessing/ChildParentsTransformer.java
@@ -1,4 +1,4 @@
-package titan.ccp.aggregation.streamprocessing;
+package uc2.streamprocessing;
import java.util.Map;
import java.util.Optional;
diff --git a/uc2-application/src/main/java/titan/ccp/aggregation/streamprocessing/ChildParentsTransformerFactory.java b/uc2-application/src/main/java/uc2/streamprocessing/ChildParentsTransformerFactory.java
similarity index 97%
rename from uc2-application/src/main/java/titan/ccp/aggregation/streamprocessing/ChildParentsTransformerFactory.java
rename to uc2-application/src/main/java/uc2/streamprocessing/ChildParentsTransformerFactory.java
index 942858ec7..5029c0244 100644
--- a/uc2-application/src/main/java/titan/ccp/aggregation/streamprocessing/ChildParentsTransformerFactory.java
+++ b/uc2-application/src/main/java/uc2/streamprocessing/ChildParentsTransformerFactory.java
@@ -1,4 +1,4 @@
-package titan.ccp.aggregation.streamprocessing;
+package uc2.streamprocessing;
import java.util.Map;
import java.util.Optional;
diff --git a/uc2-application/src/main/java/titan/ccp/aggregation/streamprocessing/JointFlatTransformer.java b/uc2-application/src/main/java/uc2/streamprocessing/JointFlatTransformer.java
similarity index 98%
rename from uc2-application/src/main/java/titan/ccp/aggregation/streamprocessing/JointFlatTransformer.java
rename to uc2-application/src/main/java/uc2/streamprocessing/JointFlatTransformer.java
index aa39a5632..87a1d9967 100644
--- a/uc2-application/src/main/java/titan/ccp/aggregation/streamprocessing/JointFlatTransformer.java
+++ b/uc2-application/src/main/java/uc2/streamprocessing/JointFlatTransformer.java
@@ -1,4 +1,4 @@
-package titan.ccp.aggregation.streamprocessing;
+package uc2.streamprocessing;
import com.google.common.base.MoreObjects;
import java.util.ArrayList;
diff --git a/uc2-application/src/main/java/titan/ccp/aggregation/streamprocessing/JointFlatTransformerFactory.java b/uc2-application/src/main/java/uc2/streamprocessing/JointFlatTransformerFactory.java
similarity index 96%
rename from uc2-application/src/main/java/titan/ccp/aggregation/streamprocessing/JointFlatTransformerFactory.java
rename to uc2-application/src/main/java/uc2/streamprocessing/JointFlatTransformerFactory.java
index adfca6cb6..5ddb07850 100644
--- a/uc2-application/src/main/java/titan/ccp/aggregation/streamprocessing/JointFlatTransformerFactory.java
+++ b/uc2-application/src/main/java/uc2/streamprocessing/JointFlatTransformerFactory.java
@@ -1,4 +1,4 @@
-package titan.ccp.aggregation.streamprocessing;
+package uc2.streamprocessing;
import java.util.Map;
import java.util.Set;
diff --git a/uc2-application/src/main/java/titan/ccp/aggregation/streamprocessing/JointRecordParents.java b/uc2-application/src/main/java/uc2/streamprocessing/JointRecordParents.java
similarity index 92%
rename from uc2-application/src/main/java/titan/ccp/aggregation/streamprocessing/JointRecordParents.java
rename to uc2-application/src/main/java/uc2/streamprocessing/JointRecordParents.java
index 6bbf0aad6..74fb5441f 100644
--- a/uc2-application/src/main/java/titan/ccp/aggregation/streamprocessing/JointRecordParents.java
+++ b/uc2-application/src/main/java/uc2/streamprocessing/JointRecordParents.java
@@ -1,4 +1,4 @@
-package titan.ccp.aggregation.streamprocessing;
+package uc2.streamprocessing;
import java.util.Set;
import titan.ccp.models.records.ActivePowerRecord;
diff --git a/uc2-application/src/main/java/titan/ccp/aggregation/streamprocessing/KafkaStreamsBuilder.java b/uc2-application/src/main/java/uc2/streamprocessing/KafkaStreamsBuilder.java
similarity index 99%
rename from uc2-application/src/main/java/titan/ccp/aggregation/streamprocessing/KafkaStreamsBuilder.java
rename to uc2-application/src/main/java/uc2/streamprocessing/KafkaStreamsBuilder.java
index 0ae0d399d..eb0643d63 100644
--- a/uc2-application/src/main/java/titan/ccp/aggregation/streamprocessing/KafkaStreamsBuilder.java
+++ b/uc2-application/src/main/java/uc2/streamprocessing/KafkaStreamsBuilder.java
@@ -1,4 +1,4 @@
-package titan.ccp.aggregation.streamprocessing;
+package uc2.streamprocessing;
import java.time.Duration;
import java.util.Objects;
diff --git a/uc2-application/src/main/java/titan/ccp/aggregation/streamprocessing/OptionalParentsSerde.java b/uc2-application/src/main/java/uc2/streamprocessing/OptionalParentsSerde.java
similarity index 96%
rename from uc2-application/src/main/java/titan/ccp/aggregation/streamprocessing/OptionalParentsSerde.java
rename to uc2-application/src/main/java/uc2/streamprocessing/OptionalParentsSerde.java
index a310b3a68..e4624d953 100644
--- a/uc2-application/src/main/java/titan/ccp/aggregation/streamprocessing/OptionalParentsSerde.java
+++ b/uc2-application/src/main/java/uc2/streamprocessing/OptionalParentsSerde.java
@@ -1,4 +1,4 @@
-package titan.ccp.aggregation.streamprocessing;
+package uc2.streamprocessing;
import java.util.HashSet;
import java.util.Optional;
diff --git a/uc2-application/src/main/java/titan/ccp/aggregation/streamprocessing/ParentsSerde.java b/uc2-application/src/main/java/uc2/streamprocessing/ParentsSerde.java
similarity index 95%
rename from uc2-application/src/main/java/titan/ccp/aggregation/streamprocessing/ParentsSerde.java
rename to uc2-application/src/main/java/uc2/streamprocessing/ParentsSerde.java
index 478b8bcf3..327f33a10 100644
--- a/uc2-application/src/main/java/titan/ccp/aggregation/streamprocessing/ParentsSerde.java
+++ b/uc2-application/src/main/java/uc2/streamprocessing/ParentsSerde.java
@@ -1,4 +1,4 @@
-package titan.ccp.aggregation.streamprocessing;
+package uc2.streamprocessing;
import java.util.HashSet;
import java.util.Set;
diff --git a/uc2-application/src/main/java/titan/ccp/aggregation/streamprocessing/RecordAggregator.java b/uc2-application/src/main/java/uc2/streamprocessing/RecordAggregator.java
similarity index 97%
rename from uc2-application/src/main/java/titan/ccp/aggregation/streamprocessing/RecordAggregator.java
rename to uc2-application/src/main/java/uc2/streamprocessing/RecordAggregator.java
index ae7a167c9..0b3e23462 100644
--- a/uc2-application/src/main/java/titan/ccp/aggregation/streamprocessing/RecordAggregator.java
+++ b/uc2-application/src/main/java/uc2/streamprocessing/RecordAggregator.java
@@ -1,4 +1,4 @@
-package titan.ccp.aggregation.streamprocessing;
+package uc2.streamprocessing;
import org.apache.kafka.streams.kstream.Windowed;
import titan.ccp.models.records.ActivePowerRecord;
diff --git a/uc2-application/src/main/java/titan/ccp/aggregation/streamprocessing/SensorParentKey.java b/uc2-application/src/main/java/uc2/streamprocessing/SensorParentKey.java
similarity index 93%
rename from uc2-application/src/main/java/titan/ccp/aggregation/streamprocessing/SensorParentKey.java
rename to uc2-application/src/main/java/uc2/streamprocessing/SensorParentKey.java
index 32d77c402..4cb3bc9c6 100644
--- a/uc2-application/src/main/java/titan/ccp/aggregation/streamprocessing/SensorParentKey.java
+++ b/uc2-application/src/main/java/uc2/streamprocessing/SensorParentKey.java
@@ -1,4 +1,4 @@
-package titan.ccp.aggregation.streamprocessing;
+package uc2.streamprocessing;
/**
* A key consisting of the identifier of a sensor and an identifier of parent sensor.
diff --git a/uc2-application/src/main/java/titan/ccp/aggregation/streamprocessing/SensorParentKeySerde.java b/uc2-application/src/main/java/uc2/streamprocessing/SensorParentKeySerde.java
similarity index 95%
rename from uc2-application/src/main/java/titan/ccp/aggregation/streamprocessing/SensorParentKeySerde.java
rename to uc2-application/src/main/java/uc2/streamprocessing/SensorParentKeySerde.java
index 2646c7d04..1a2688c2b 100644
--- a/uc2-application/src/main/java/titan/ccp/aggregation/streamprocessing/SensorParentKeySerde.java
+++ b/uc2-application/src/main/java/uc2/streamprocessing/SensorParentKeySerde.java
@@ -1,4 +1,4 @@
-package titan.ccp.aggregation.streamprocessing;
+package uc2.streamprocessing;
import org.apache.kafka.common.serialization.Serde;
import titan.ccp.common.kafka.simpleserdes.BufferSerde;
diff --git a/uc2-application/src/main/java/titan/ccp/aggregation/streamprocessing/TopologyBuilder.java b/uc2-application/src/main/java/uc2/streamprocessing/TopologyBuilder.java
similarity index 99%
rename from uc2-application/src/main/java/titan/ccp/aggregation/streamprocessing/TopologyBuilder.java
rename to uc2-application/src/main/java/uc2/streamprocessing/TopologyBuilder.java
index 7a67c7837..a6b377b0e 100644
--- a/uc2-application/src/main/java/titan/ccp/aggregation/streamprocessing/TopologyBuilder.java
+++ b/uc2-application/src/main/java/uc2/streamprocessing/TopologyBuilder.java
@@ -1,4 +1,4 @@
-package titan.ccp.aggregation.streamprocessing;
+package uc2.streamprocessing;
import com.google.common.math.StatsAccumulator;
import java.time.Duration;
diff --git a/uc2-application/src/test/java/titan/ccp/aggregation/streamprocessing/OptionalParentsSerdeTest.java b/uc2-application/src/test/java/titan/ccp/aggregation/streamprocessing/OptionalParentsSerdeTest.java
index 1bffdaa3e..f92af2b5a 100644
--- a/uc2-application/src/test/java/titan/ccp/aggregation/streamprocessing/OptionalParentsSerdeTest.java
+++ b/uc2-application/src/test/java/titan/ccp/aggregation/streamprocessing/OptionalParentsSerdeTest.java
@@ -3,7 +3,7 @@ package titan.ccp.aggregation.streamprocessing;
import java.util.Optional;
import java.util.Set;
import org.junit.Test;
-import titan.ccp.aggregation.streamprocessing.OptionalParentsSerde;
+import uc2.streamprocessing.OptionalParentsSerde;
public class OptionalParentsSerdeTest {
diff --git a/uc2-application/src/test/java/titan/ccp/aggregation/streamprocessing/ParentsSerdeTest.java b/uc2-application/src/test/java/titan/ccp/aggregation/streamprocessing/ParentsSerdeTest.java
index 12301031c..715a14f47 100644
--- a/uc2-application/src/test/java/titan/ccp/aggregation/streamprocessing/ParentsSerdeTest.java
+++ b/uc2-application/src/test/java/titan/ccp/aggregation/streamprocessing/ParentsSerdeTest.java
@@ -2,7 +2,7 @@ package titan.ccp.aggregation.streamprocessing;
import java.util.Set;
import org.junit.Test;
-import titan.ccp.aggregation.streamprocessing.ParentsSerde;
+import uc2.streamprocessing.ParentsSerde;
public class ParentsSerdeTest {
diff --git a/uc2-application/src/test/java/titan/ccp/aggregation/streamprocessing/SensorParentKeySerdeTest.java b/uc2-application/src/test/java/titan/ccp/aggregation/streamprocessing/SensorParentKeySerdeTest.java
index 51b2a052e..3090c9efb 100644
--- a/uc2-application/src/test/java/titan/ccp/aggregation/streamprocessing/SensorParentKeySerdeTest.java
+++ b/uc2-application/src/test/java/titan/ccp/aggregation/streamprocessing/SensorParentKeySerdeTest.java
@@ -1,8 +1,8 @@
package titan.ccp.aggregation.streamprocessing;
import org.junit.Test;
-import titan.ccp.aggregation.streamprocessing.SensorParentKey;
-import titan.ccp.aggregation.streamprocessing.SensorParentKeySerde;
+import uc2.streamprocessing.SensorParentKey;
+import uc2.streamprocessing.SensorParentKeySerde;
public class SensorParentKeySerdeTest {
diff --git a/uc2-workload-generator/src/main/java/titan/ccp/kiekerbridge/KafkaRecordSender.java b/uc2-workload-generator/src/main/java/kafkaSender/KafkaRecordSender.java
similarity index 100%
rename from uc2-workload-generator/src/main/java/titan/ccp/kiekerbridge/KafkaRecordSender.java
rename to uc2-workload-generator/src/main/java/kafkaSender/KafkaRecordSender.java
diff --git a/uc2-workload-generator/src/main/java/titan/ccp/kiekerbridge/expbigdata19/ConfigPublisher.java b/uc2-workload-generator/src/main/java/uc2/workloadGenerator/ConfigPublisher.java
similarity index 100%
rename from uc2-workload-generator/src/main/java/titan/ccp/kiekerbridge/expbigdata19/ConfigPublisher.java
rename to uc2-workload-generator/src/main/java/uc2/workloadGenerator/ConfigPublisher.java
diff --git a/uc2-workload-generator/src/main/java/titan/ccp/kiekerbridge/expbigdata19/ExperimentorBigData.java b/uc2-workload-generator/src/main/java/uc2/workloadGenerator/ExperimentorBigData.java
similarity index 100%
rename from uc2-workload-generator/src/main/java/titan/ccp/kiekerbridge/expbigdata19/ExperimentorBigData.java
rename to uc2-workload-generator/src/main/java/uc2/workloadGenerator/ExperimentorBigData.java
diff --git a/uc2-workload-generator/src/main/java/titan/ccp/kiekerbridge/expbigdata19/LoadCounter.java b/uc2-workload-generator/src/main/java/uc2/workloadGenerator/LoadCounter.java
similarity index 100%
rename from uc2-workload-generator/src/main/java/titan/ccp/kiekerbridge/expbigdata19/LoadCounter.java
rename to uc2-workload-generator/src/main/java/uc2/workloadGenerator/LoadCounter.java
diff --git a/uc2-workload-generator/src/main/java/titan/ccp/kiekerbridge/expbigdata19/LoadGenerator.java b/uc2-workload-generator/src/main/java/uc2/workloadGenerator/LoadGenerator.java
similarity index 100%
rename from uc2-workload-generator/src/main/java/titan/ccp/kiekerbridge/expbigdata19/LoadGenerator.java
rename to uc2-workload-generator/src/main/java/uc2/workloadGenerator/LoadGenerator.java
diff --git a/uc2-workload-generator/src/main/java/titan/ccp/kiekerbridge/expbigdata19/LoadGeneratorExtrem.java b/uc2-workload-generator/src/main/java/uc2/workloadGenerator/LoadGeneratorExtrem.java
similarity index 100%
rename from uc2-workload-generator/src/main/java/titan/ccp/kiekerbridge/expbigdata19/LoadGeneratorExtrem.java
rename to uc2-workload-generator/src/main/java/uc2/workloadGenerator/LoadGeneratorExtrem.java
--
GitLab