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 7597a595d934c1f7f6a0a61124fb5758032c14d0..9581b167c16484e7b7699434c0750ed7abba6e4b 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 5fef681aa0cb5cc9db8c4dd99fea603152fabc2b..1f6b581a303f625dedf23758c2c1d5fd4f93b866 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 659b958c87192759d86a755227a17d2a35b9be34..e3b61453819b0c7de256318e50e0d7f858e3baba 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 b7685a0815a9c6fe1d39facedcf06f6887063312..eb38464c9829d2ec69ea626221648aba69b5812d 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"));