From 67bcfc6f0d02e8572ba38bb4319fa21172f56850 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?S=C3=B6ren=20Henning?= <soeren.henning@email.uni-kiel.de>
Date: Thu, 24 Nov 2022 14:58:15 +0100
Subject: [PATCH] Fix typos
---
.../benchmarks/uc3/kstreams/HistoryService.java | 2 +-
.../benchmarks/uc3/kstreams/TopologyBuilder.java | 8 ++++----
.../uc3/kstreams/Uc3KafkaStreamsBuilder.java | 10 +++++-----
3 files changed, 10 insertions(+), 10 deletions(-)
diff --git a/theodolite-benchmarks/uc3-kstreams/src/main/java/rocks/theodolite/benchmarks/uc3/kstreams/HistoryService.java b/theodolite-benchmarks/uc3-kstreams/src/main/java/rocks/theodolite/benchmarks/uc3/kstreams/HistoryService.java
index 8776fcda3..2151d0be4 100644
--- a/theodolite-benchmarks/uc3-kstreams/src/main/java/rocks/theodolite/benchmarks/uc3/kstreams/HistoryService.java
+++ b/theodolite-benchmarks/uc3-kstreams/src/main/java/rocks/theodolite/benchmarks/uc3/kstreams/HistoryService.java
@@ -34,7 +34,7 @@ public class HistoryService {
final Uc3KafkaStreamsBuilder uc3KafkaStreamsBuilder = new Uc3KafkaStreamsBuilder(this.config);
uc3KafkaStreamsBuilder
.outputTopic(this.config.getString(ConfigurationKeys.KAFKA_OUTPUT_TOPIC))
- .aggregtionDuration(
+ .aggregationDuration(
Duration.ofDays(this.config.getInt(ConfigurationKeys.AGGREGATION_DURATION_DAYS)))
.aggregationAdvance(
Duration.ofDays(this.config.getInt(ConfigurationKeys.AGGREGATION_ADVANCE_DAYS)));
diff --git a/theodolite-benchmarks/uc3-kstreams/src/main/java/rocks/theodolite/benchmarks/uc3/kstreams/TopologyBuilder.java b/theodolite-benchmarks/uc3-kstreams/src/main/java/rocks/theodolite/benchmarks/uc3/kstreams/TopologyBuilder.java
index f2825ca81..d6e000d81 100644
--- a/theodolite-benchmarks/uc3-kstreams/src/main/java/rocks/theodolite/benchmarks/uc3/kstreams/TopologyBuilder.java
+++ b/theodolite-benchmarks/uc3-kstreams/src/main/java/rocks/theodolite/benchmarks/uc3/kstreams/TopologyBuilder.java
@@ -34,7 +34,7 @@ public class TopologyBuilder {
private final String inputTopic;
private final String outputTopic;
private final SchemaRegistryAvroSerdeFactory srAvroSerdeFactory;
- private final Duration aggregtionDuration;
+ private final Duration aggregationDuration;
private final Duration aggregationAdvance;
private final StreamsBuilder builder = new StreamsBuilder();
@@ -44,11 +44,11 @@ public class TopologyBuilder {
*/
public TopologyBuilder(final String inputTopic, final String outputTopic,
final SchemaRegistryAvroSerdeFactory srAvroSerdeFactory,
- final Duration aggregtionDuration, final Duration aggregationAdvance) {
+ final Duration aggregationDuration, final Duration aggregationAdvance) {
this.inputTopic = inputTopic;
this.outputTopic = outputTopic;
this.srAvroSerdeFactory = srAvroSerdeFactory;
- this.aggregtionDuration = aggregtionDuration;
+ this.aggregationDuration = aggregationDuration;
this.aggregationAdvance = aggregationAdvance;
}
@@ -70,7 +70,7 @@ public class TopologyBuilder {
})
.groupByKey(Grouped.with(keySerde, this.srAvroSerdeFactory.forValues()))
.windowedBy(TimeWindows
- .ofSizeWithNoGrace(this.aggregtionDuration)
+ .ofSizeWithNoGrace(this.aggregationDuration)
.advanceBy(this.aggregationAdvance))
.aggregate(
() -> Stats.of(),
diff --git a/theodolite-benchmarks/uc3-kstreams/src/main/java/rocks/theodolite/benchmarks/uc3/kstreams/Uc3KafkaStreamsBuilder.java b/theodolite-benchmarks/uc3-kstreams/src/main/java/rocks/theodolite/benchmarks/uc3/kstreams/Uc3KafkaStreamsBuilder.java
index e05b30f75..d4e55884a 100644
--- a/theodolite-benchmarks/uc3-kstreams/src/main/java/rocks/theodolite/benchmarks/uc3/kstreams/Uc3KafkaStreamsBuilder.java
+++ b/theodolite-benchmarks/uc3-kstreams/src/main/java/rocks/theodolite/benchmarks/uc3/kstreams/Uc3KafkaStreamsBuilder.java
@@ -14,7 +14,7 @@ import rocks.theodolite.benchmarks.commons.kstreams.KafkaStreamsBuilder;
public class Uc3KafkaStreamsBuilder extends KafkaStreamsBuilder {
private String outputTopic; // NOPMD
- private Duration aggregtionDuration; // NOPMD
+ private Duration aggregationDuration; // NOPMD
private Duration aggregationAdvance; // NOPMD
public Uc3KafkaStreamsBuilder(final Configuration config) {
@@ -26,8 +26,8 @@ public class Uc3KafkaStreamsBuilder extends KafkaStreamsBuilder {
return this;
}
- public Uc3KafkaStreamsBuilder aggregtionDuration(final Duration aggregtionDuration) {
- this.aggregtionDuration = aggregtionDuration;
+ public Uc3KafkaStreamsBuilder aggregationDuration(final Duration aggregationDuration) {
+ this.aggregationDuration = aggregationDuration;
return this;
}
@@ -40,14 +40,14 @@ public class Uc3KafkaStreamsBuilder extends KafkaStreamsBuilder {
protected Topology buildTopology(final Properties properties) {
Objects.requireNonNull(this.inputTopic, "Input topic has not been set.");
Objects.requireNonNull(this.outputTopic, "Output topic has not been set.");
- Objects.requireNonNull(this.aggregtionDuration, "Aggregation duration has not been set.");
+ Objects.requireNonNull(this.aggregationDuration, "Aggregation duration has not been set.");
Objects.requireNonNull(this.aggregationAdvance, "Aggregation advance period has not been set.");
final TopologyBuilder topologyBuilder = new TopologyBuilder(
this.inputTopic,
this.outputTopic,
new SchemaRegistryAvroSerdeFactory(this.schemaRegistryUrl),
- this.aggregtionDuration,
+ this.aggregationDuration,
this.aggregationAdvance);
return topologyBuilder.build(properties);
--
GitLab