From a528aa31d300f2ffda642cc1dfbdcd66f4dc9dcc Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?S=C3=B6ren=20Henning?= <soeren.henning@email.uni-kiel.de>
Date: Fri, 25 Nov 2022 18:57:34 +0100
Subject: [PATCH] Add clarifying comments
---
.../benchmarks/uc1/hazelcastjet/Uc1PipelineFactory.java | 2 --
.../rocks/theodolite/benchmarks/uc3/beam/MapTimeFormat.java | 2 +-
2 files changed, 1 insertion(+), 3 deletions(-)
diff --git a/theodolite-benchmarks/uc1-hazelcastjet/src/main/java/rocks/theodolite/benchmarks/uc1/hazelcastjet/Uc1PipelineFactory.java b/theodolite-benchmarks/uc1-hazelcastjet/src/main/java/rocks/theodolite/benchmarks/uc1/hazelcastjet/Uc1PipelineFactory.java
index c987e3ada..a373537b3 100644
--- a/theodolite-benchmarks/uc1-hazelcastjet/src/main/java/rocks/theodolite/benchmarks/uc1/hazelcastjet/Uc1PipelineFactory.java
+++ b/theodolite-benchmarks/uc1-hazelcastjet/src/main/java/rocks/theodolite/benchmarks/uc1/hazelcastjet/Uc1PipelineFactory.java
@@ -49,8 +49,6 @@ public class Uc1PipelineFactory extends PipelineFactory {
final StreamStage<String> uc1TopologyProduct = this.extendUc1Topology(kafkaSource);
// Add Sink: Logger
- // Do not refactor this to just use the call
- // (There is a problem with static calls in functions in hazelcastjet)
final DatabaseWriter<String> writer = this.databaseAdapter.getDatabaseWriter();
final Sink<String> sink = SinkBuilder.sinkBuilder(
"Sink into database", x -> writer)
diff --git a/theodolite-benchmarks/uc3-beam/src/main/java/rocks/theodolite/benchmarks/uc3/beam/MapTimeFormat.java b/theodolite-benchmarks/uc3-beam/src/main/java/rocks/theodolite/benchmarks/uc3/beam/MapTimeFormat.java
index 0cad03814..d6429d758 100644
--- a/theodolite-benchmarks/uc3-beam/src/main/java/rocks/theodolite/benchmarks/uc3/beam/MapTimeFormat.java
+++ b/theodolite-benchmarks/uc3-beam/src/main/java/rocks/theodolite/benchmarks/uc3/beam/MapTimeFormat.java
@@ -8,7 +8,7 @@ import org.apache.beam.sdk.values.KV;
import rocks.theodolite.benchmarks.commons.model.records.ActivePowerRecord;
/**
- * Changes the time format to us Europe/Paris time.
+ * Maps the key of incoming records from pure sensor ID strings to {@link HourOfDayKey}s.
*/
public class MapTimeFormat
extends SimpleFunction<KV<String, ActivePowerRecord>, KV<HourOfDayKey, ActivePowerRecord>> {
--
GitLab