From ad1cdc098c0af378a41f1202f1f46e57eda65c8f Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?S=C3=B6ren=20Henning?= <post@soeren-henning.de>
Date: Sat, 2 May 2020 11:59:16 +0200
Subject: [PATCH] Add initial logging statements to load generators
---
.../src/main/java/uc1/workloadGenerator/LoadGenerator.java | 3 ++-
.../src/main/java/uc2/workloadGenerator/LoadGenerator.java | 5 +++++
.../src/main/java/uc3/workloadGenerator/LoadGenerator.java | 5 +++++
.../src/main/java/uc4/workloadGenerator/LoadGenerator.java | 5 +++++
4 files changed, 17 insertions(+), 1 deletion(-)
diff --git a/uc1-workload-generator/src/main/java/uc1/workloadGenerator/LoadGenerator.java b/uc1-workload-generator/src/main/java/uc1/workloadGenerator/LoadGenerator.java
index 7597a595d..9581b167c 100644
--- a/uc1-workload-generator/src/main/java/uc1/workloadGenerator/LoadGenerator.java
+++ b/uc1-workload-generator/src/main/java/uc1/workloadGenerator/LoadGenerator.java
@@ -19,12 +19,13 @@ import titan.ccp.models.records.ActivePowerRecord;
public class LoadGenerator {
- private static Logger LOGGER = LoggerFactory.getLogger(LoadGenerator.class);
+ private static final Logger LOGGER = LoggerFactory.getLogger(LoadGenerator.class);
private static final int WL_MAX_RECORDS = 150_000;
public static void main(final String[] args) throws InterruptedException, IOException {
// uc1
+ LOGGER.info("Start workload generator for use case UC1.");
final int numSensors =
Integer.parseInt(Objects.requireNonNullElse(System.getenv("NUM_SENSORS"), "10"));
diff --git a/uc2-workload-generator/src/main/java/uc2/workloadGenerator/LoadGenerator.java b/uc2-workload-generator/src/main/java/uc2/workloadGenerator/LoadGenerator.java
index 5fef681aa..1f6b581a3 100644
--- a/uc2-workload-generator/src/main/java/uc2/workloadGenerator/LoadGenerator.java
+++ b/uc2-workload-generator/src/main/java/uc2/workloadGenerator/LoadGenerator.java
@@ -11,6 +11,8 @@ import java.util.concurrent.TimeUnit;
import java.util.stream.Collectors;
import kafkaSender.KafkaRecordSender;
import org.apache.kafka.clients.producer.ProducerConfig;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
import titan.ccp.configuration.events.Event;
import titan.ccp.model.sensorregistry.MutableAggregatedSensor;
import titan.ccp.model.sensorregistry.MutableSensorRegistry;
@@ -18,7 +20,10 @@ import titan.ccp.models.records.ActivePowerRecord;
public class LoadGenerator {
+ private static final Logger LOGGER = LoggerFactory.getLogger(LoadGenerator.class);
+
public static void main(final String[] args) throws InterruptedException, IOException {
+ LOGGER.info("Start workload generator for use case UC2.");
final String hierarchy = Objects.requireNonNullElse(System.getenv("HIERARCHY"), "deep");
final int numNestedGroups = Integer
diff --git a/uc3-workload-generator/src/main/java/uc3/workloadGenerator/LoadGenerator.java b/uc3-workload-generator/src/main/java/uc3/workloadGenerator/LoadGenerator.java
index 659b958c8..e3b614538 100644
--- a/uc3-workload-generator/src/main/java/uc3/workloadGenerator/LoadGenerator.java
+++ b/uc3-workload-generator/src/main/java/uc3/workloadGenerator/LoadGenerator.java
@@ -11,14 +11,19 @@ import java.util.concurrent.TimeUnit;
import java.util.stream.Collectors;
import kafkaSender.KafkaRecordSender;
import org.apache.kafka.clients.producer.ProducerConfig;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
import titan.ccp.model.sensorregistry.MutableAggregatedSensor;
import titan.ccp.model.sensorregistry.MutableSensorRegistry;
import titan.ccp.models.records.ActivePowerRecord;
public class LoadGenerator {
+ private static final Logger LOGGER = LoggerFactory.getLogger(LoadGenerator.class);
+
public static void main(final String[] args) throws InterruptedException, IOException {
// uc3
+ LOGGER.info("Start workload generator for use case UC3.");
final int numSensor =
Integer.parseInt(Objects.requireNonNullElse(System.getenv("NUM_SENSORS"), "10"));
diff --git a/uc4-workload-generator/src/main/java/uc4/workloadGenerator/LoadGenerator.java b/uc4-workload-generator/src/main/java/uc4/workloadGenerator/LoadGenerator.java
index b7685a081..eb38464c9 100644
--- a/uc4-workload-generator/src/main/java/uc4/workloadGenerator/LoadGenerator.java
+++ b/uc4-workload-generator/src/main/java/uc4/workloadGenerator/LoadGenerator.java
@@ -12,12 +12,17 @@ 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 titan.ccp.models.records.ActivePowerRecord;
public class LoadGenerator {
+ private static final Logger LOGGER = LoggerFactory.getLogger(LoadGenerator.class);
+
public static void main(final String[] args) throws InterruptedException, IOException {
// uc4
+ LOGGER.info("Start workload generator for use case UC4.");
final int numSensor =
Integer.parseInt(Objects.requireNonNullElse(System.getenv("NUM_SENSORS"), "10"));
--
GitLab