diff --git a/theodolite-benchmarks/uc1-hazelcastjet/src/main/java/rocks/theodolite/benchmarks/uc1/hazelcastjet/HistoryService.java b/theodolite-benchmarks/uc1-hazelcastjet/src/main/java/rocks/theodolite/benchmarks/uc1/hazelcastjet/HistoryService.java index 9e7581abe9847ccb3f3500e9561279d52c2b5e09..4795c9e33bce4e2b9d6f6878204e9e31a3b7063d 100644 --- a/theodolite-benchmarks/uc1-hazelcastjet/src/main/java/rocks/theodolite/benchmarks/uc1/hazelcastjet/HistoryService.java +++ b/theodolite-benchmarks/uc1-hazelcastjet/src/main/java/rocks/theodolite/benchmarks/uc1/hazelcastjet/HistoryService.java @@ -9,17 +9,18 @@ import org.slf4j.LoggerFactory; */ public class HistoryService { - // Default Values of data used in UC1 - // -- (default) kafkaPropeties data - private static final String SCHEMA_REGISTRY_URL_DEFAULT = "http://localhost:8081"; - private static final String KAFKA_BOOTSTRAP_SERVERS_DEFAULT = "localhost:19092"; // NOPMD - // -- (default) JetInstance data - private static final String HZ_KUBERNETES_SERVICE_DNS_KEY = "service-dns"; private static final Logger LOGGER = LoggerFactory.getLogger(HistoryService.class); + + // Hazelcast settings (default) + private static final String HZ_KUBERNETES_SERVICE_DNS_KEY = "service-dns"; private static final String BOOTSTRAP_SERVER_DEFAULT = "localhost:5701"; - // -- (default) Kafka input topic data + + // Kafka settings (default) + private static final String KAFKA_BOOTSTRAP_DEFAULT = "localhost:9092"; + private static final String SCHEMA_REGISTRY_URL_DEFAULT = "http://localhost:8081"; private static final String KAFKA_TOPIC_DEFAULT = "input"; - // -- (default) job name for this history serivce + + // Job name (default) private static final String JOB_NAME = "uc1-hazelcastjet"; @@ -53,7 +54,7 @@ public class HistoryService { */ private void createHazelcastJetApplication() throws Exception { // NOPMD new Uc1HazelcastJetFactory() - .setPropertiesFromEnv(KAFKA_BOOTSTRAP_SERVERS_DEFAULT, SCHEMA_REGISTRY_URL_DEFAULT) + .setPropertiesFromEnv(KAFKA_BOOTSTRAP_DEFAULT, SCHEMA_REGISTRY_URL_DEFAULT) .setKafkaInputTopicFromEnv(KAFKA_TOPIC_DEFAULT) .buildUc1Pipeline() .buildUc1JetInstanceFromEnv(LOGGER, BOOTSTRAP_SERVER_DEFAULT, HZ_KUBERNETES_SERVICE_DNS_KEY) diff --git a/theodolite-benchmarks/uc2-hazelcastjet/src/main/java/rocks/theodolite/benchmarks/uc2/hazelcastjet/HistoryService.java b/theodolite-benchmarks/uc2-hazelcastjet/src/main/java/rocks/theodolite/benchmarks/uc2/hazelcastjet/HistoryService.java index 2bea05454a35dafa697d59b166ac35acae016066..ea2056ce0eb47515db1ebdf6c4fe0d270b861969 100644 --- a/theodolite-benchmarks/uc2-hazelcastjet/src/main/java/rocks/theodolite/benchmarks/uc2/hazelcastjet/HistoryService.java +++ b/theodolite-benchmarks/uc2-hazelcastjet/src/main/java/rocks/theodolite/benchmarks/uc2/hazelcastjet/HistoryService.java @@ -10,16 +10,21 @@ import org.slf4j.LoggerFactory; public class HistoryService { private static final Logger LOGGER = LoggerFactory.getLogger(HistoryService.class); - // General Information (default) + + // Hazelcast settings (default) private static final String HZ_KUBERNETES_SERVICE_DNS_KEY = "service-dns"; private static final String BOOTSTRAP_SERVER_DEFAULT = "localhost:5701"; + + // Kafka settings (default) + private static final String KAFKA_BOOTSTRAP_DEFAULT = "localhost:9092"; private static final String SCHEMA_REGISTRY_URL_DEFAULT = "http://localhost:8081"; private static final String KAFKA_INPUT_TOPIC_DEFAULT = "input"; private static final String KAFKA_OUTPUT_TOPIC_DEFAULT = "output"; - private static final String KAFKA_BSERVER_DEFAULT = "localhost:19092"; + // UC2 specific (default) - private static final String DOWNSAMPLE_INTERVAL_DEFAULT_MS = "5000"; - // -- (default) job name for this history serivce + private static final String DOWNSAMPLE_INTERVAL_DEFAULT_MS = "60000"; + + // Job name (default) private static final String JOB_NAME = "uc2-hazelcastjet"; /** @@ -52,8 +57,8 @@ public class HistoryService { */ private void createHazelcastJetApplication() throws Exception { // NOPMD new Uc2HazelcastJetFactory() - .setReadPropertiesFromEnv(KAFKA_BSERVER_DEFAULT, SCHEMA_REGISTRY_URL_DEFAULT) - .setWritePropertiesFromEnv(KAFKA_BSERVER_DEFAULT) + .setReadPropertiesFromEnv(KAFKA_BOOTSTRAP_DEFAULT, SCHEMA_REGISTRY_URL_DEFAULT) + .setWritePropertiesFromEnv(KAFKA_BOOTSTRAP_DEFAULT) .setKafkaInputTopicFromEnv(KAFKA_INPUT_TOPIC_DEFAULT) .setKafkaOutputTopicFromEnv(KAFKA_OUTPUT_TOPIC_DEFAULT) .setDownsampleIntervalFromEnv(DOWNSAMPLE_INTERVAL_DEFAULT_MS) diff --git a/theodolite-benchmarks/uc3-hazelcastjet/src/main/java/rocks/theodolite/benchmarks/uc3/hazelcastjet/HistoryService.java b/theodolite-benchmarks/uc3-hazelcastjet/src/main/java/rocks/theodolite/benchmarks/uc3/hazelcastjet/HistoryService.java index 18a275cc7dc222d9f9130d0a613ebae5cccc0d70..9b02da5b69a3b4f7ecbfb048cd2b9cc198d51c77 100644 --- a/theodolite-benchmarks/uc3-hazelcastjet/src/main/java/rocks/theodolite/benchmarks/uc3/hazelcastjet/HistoryService.java +++ b/theodolite-benchmarks/uc3-hazelcastjet/src/main/java/rocks/theodolite/benchmarks/uc3/hazelcastjet/HistoryService.java @@ -11,17 +11,21 @@ public class HistoryService { private static final Logger LOGGER = LoggerFactory.getLogger(HistoryService.class); - // General Information + // Hazelcast settings (default) private static final String HZ_KUBERNETES_SERVICE_DNS_KEY = "service-dns"; private static final String BOOTSTRAP_SERVER_DEFAULT = "localhost:5701"; + + // Kafka settings (default) + private static final String KAFKA_BOOTSTRAP_DEFAULT = "localhost:9092"; private static final String SCHEMA_REGISTRY_URL_DEFAULT = "http://localhost:8081"; private static final String KAFKA_INPUT_TOPIC_DEFAULT = "input"; private static final String KAFKA_OUTPUT_TOPIC_DEFAULT = "output"; - private static final String KAFKA_BSERVERS_DEFAULT = "localhost:19092"; - // UC3 specific - private static final String WINDOW_SIZE_IN_SECONDS_DEFAULT = "50"; - private static final String HOPSIZE_IN_SEC_DEFAULT = "1"; - // -- (default) job name for this history serivce + + // UC3 specific (default) + private static final String WINDOW_SIZE_IN_SECONDS_DEFAULT = "2629800"; + private static final String HOPSIZE_IN_SEC_DEFAULT = "86400"; + + // Job name (default) private static final String JOB_NAME = "uc3-hazelcastjet"; /** @@ -54,8 +58,8 @@ public class HistoryService { */ private void createHazelcastJetApplication() throws Exception { // NOPMD new Uc3HazelcastJetFactory() - .setReadPropertiesFromEnv(KAFKA_BSERVERS_DEFAULT, SCHEMA_REGISTRY_URL_DEFAULT) - .setWritePropertiesFromEnv(KAFKA_BSERVERS_DEFAULT) + .setReadPropertiesFromEnv(KAFKA_BOOTSTRAP_DEFAULT, SCHEMA_REGISTRY_URL_DEFAULT) + .setWritePropertiesFromEnv(KAFKA_BOOTSTRAP_DEFAULT) .setKafkaInputTopicFromEnv(KAFKA_INPUT_TOPIC_DEFAULT) .setKafkaOutputTopicFromEnv(KAFKA_OUTPUT_TOPIC_DEFAULT) .setWindowSizeInSecondsFromEnv(WINDOW_SIZE_IN_SECONDS_DEFAULT) diff --git a/theodolite-benchmarks/uc4-hazelcastjet/src/main/java/rocks/theodolite/benchmarks/uc4/hazelcastjet/HistoryService.java b/theodolite-benchmarks/uc4-hazelcastjet/src/main/java/rocks/theodolite/benchmarks/uc4/hazelcastjet/HistoryService.java index 88dd311bb1c1cdb971bf8133f65a75362fcf2f55..cd0b961c7bd75b5e754c16ceda573e47e085d80d 100644 --- a/theodolite-benchmarks/uc4-hazelcastjet/src/main/java/rocks/theodolite/benchmarks/uc4/hazelcastjet/HistoryService.java +++ b/theodolite-benchmarks/uc4-hazelcastjet/src/main/java/rocks/theodolite/benchmarks/uc4/hazelcastjet/HistoryService.java @@ -10,19 +10,23 @@ import org.slf4j.LoggerFactory; public class HistoryService { private static final Logger LOGGER = LoggerFactory.getLogger(HistoryService.class); - // General Information (default) + + // Hazelcast settings (default) private static final String HZ_KUBERNETES_SERVICE_DNS_KEY = "service-dns"; private static final String BOOTSTRAP_SERVER_DEFAULT = "localhost:5701"; + + // Kafka settings (default) + private static final String KAFKA_BOOTSTRAP_DEFAULT = "localhost:9092"; private static final String SCHEMA_REGISTRY_URL_DEFAULT = "http://localhost:8081"; private static final String KAFKA_INPUT_TOPIC_DEFAULT = "input"; - private static final String KAFKA_OUTPUT_TOPIC_DEFAULT = "output"; - private static final String KAFKA_BSERVER_DEFAULT = "localhost:19092"; - // UC4 specific (default) private static final String KAFKA_CONFIG_TOPIC_DEFAULT = "configuration"; private static final String KAFKA_FEEDBACK_TOPIC_DEFAULT = "aggregation-feedback"; + private static final String KAFKA_OUTPUT_TOPIC_DEFAULT = "output"; + + // UC4 specific (default) private static final String WINDOW_SIZE_DEFAULT_MS = "5000"; - // -- (default) job name for this history serivce + // Job name (default) private static final String JOB_NAME = "uc4-hazelcastjet"; /** @@ -55,8 +59,8 @@ public class HistoryService { */ private void createHazelcastJetApplication() throws Exception { // NOPMD new Uc4HazelcastJetFactory() - .setReadPropertiesFromEnv(KAFKA_BSERVER_DEFAULT, SCHEMA_REGISTRY_URL_DEFAULT) - .setWritePropertiesFromEnv(KAFKA_BSERVER_DEFAULT, SCHEMA_REGISTRY_URL_DEFAULT) + .setReadPropertiesFromEnv(KAFKA_BOOTSTRAP_DEFAULT, SCHEMA_REGISTRY_URL_DEFAULT) + .setWritePropertiesFromEnv(KAFKA_BOOTSTRAP_DEFAULT, SCHEMA_REGISTRY_URL_DEFAULT) .setKafkaInputTopicFromEnv(KAFKA_INPUT_TOPIC_DEFAULT) .setKafkaOutputTopicFromEnv(KAFKA_OUTPUT_TOPIC_DEFAULT) .setKafkaConfigurationTopicFromEnv(KAFKA_CONFIG_TOPIC_DEFAULT)