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 c987e3ada01f955c4f3507eb8ca4d64130302126..a373537b3358a396071d6542ce4aaaf4b3d25c3f 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 0cad038141bd7b30d765520403529e9184bbcb86..d6429d758e7eba67f6d4ecd0335067c840a42b2e 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>> {