Skip to content
Snippets Groups Projects
Commit a528aa31 authored by Sören Henning's avatar Sören Henning
Browse files

Add clarifying comments

parent 71cad78f
No related branches found
No related tags found
No related merge requests found
Pipeline #10137 failed
...@@ -49,8 +49,6 @@ public class Uc1PipelineFactory extends PipelineFactory { ...@@ -49,8 +49,6 @@ public class Uc1PipelineFactory extends PipelineFactory {
final StreamStage<String> uc1TopologyProduct = this.extendUc1Topology(kafkaSource); final StreamStage<String> uc1TopologyProduct = this.extendUc1Topology(kafkaSource);
// Add Sink: Logger // 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 DatabaseWriter<String> writer = this.databaseAdapter.getDatabaseWriter();
final Sink<String> sink = SinkBuilder.sinkBuilder( final Sink<String> sink = SinkBuilder.sinkBuilder(
"Sink into database", x -> writer) "Sink into database", x -> writer)
......
...@@ -8,7 +8,7 @@ import org.apache.beam.sdk.values.KV; ...@@ -8,7 +8,7 @@ import org.apache.beam.sdk.values.KV;
import rocks.theodolite.benchmarks.commons.model.records.ActivePowerRecord; 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 public class MapTimeFormat
extends SimpleFunction<KV<String, ActivePowerRecord>, KV<HourOfDayKey, ActivePowerRecord>> { extends SimpleFunction<KV<String, ActivePowerRecord>, KV<HourOfDayKey, ActivePowerRecord>> {
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment