From 917a3f654c1041429d74c367bb41c6650187988c Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?S=C3=B6ren=20Henning?= <soeren.henning@email.uni-kiel.de>
Date: Sat, 26 Nov 2022 19:41:45 +0100
Subject: [PATCH] Unify logging for UC3
---
.../benchmarks/uc3/hazelcastjet/Uc3PipelineFactory.java | 3 +--
.../theodolite/benchmarks/uc3/kstreams/TopologyBuilder.java | 4 +---
2 files changed, 2 insertions(+), 5 deletions(-)
diff --git a/theodolite-benchmarks/uc3-hazelcastjet/src/main/java/rocks/theodolite/benchmarks/uc3/hazelcastjet/Uc3PipelineFactory.java b/theodolite-benchmarks/uc3-hazelcastjet/src/main/java/rocks/theodolite/benchmarks/uc3/hazelcastjet/Uc3PipelineFactory.java
index d5dae2bde..1bf2bb4ce 100644
--- a/theodolite-benchmarks/uc3-hazelcastjet/src/main/java/rocks/theodolite/benchmarks/uc3/hazelcastjet/Uc3PipelineFactory.java
+++ b/theodolite-benchmarks/uc3-hazelcastjet/src/main/java/rocks/theodolite/benchmarks/uc3/hazelcastjet/Uc3PipelineFactory.java
@@ -3,7 +3,6 @@ package rocks.theodolite.benchmarks.uc3.hazelcastjet;
import com.hazelcast.jet.kafka.KafkaSinks;
import com.hazelcast.jet.kafka.KafkaSources;
import com.hazelcast.jet.pipeline.Pipeline;
-import com.hazelcast.jet.pipeline.Sinks;
import com.hazelcast.jet.pipeline.StreamSource;
import com.hazelcast.jet.pipeline.StreamStage;
import com.hazelcast.jet.pipeline.WindowDefinition;
@@ -77,7 +76,7 @@ public class Uc3PipelineFactory extends PipelineFactory {
this.extendUc3Topology(kafkaSource);
// Add Sink1: Logger
- uc3Product.writeTo(Sinks.logger());
+ // uc3Product.writeTo(Sinks.logger());
// Add Sink2: Write back to kafka for the final benchmark
uc3Product.writeTo(KafkaSinks.<String, String>kafka(
this.kafkaWritePropsForPipeline, this.kafkaOutputTopic));
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 d6e000d81..5c946cc28 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
@@ -81,9 +81,7 @@ public class TopologyBuilder {
.map((key, stats) -> KeyValue.pair(
keyFactory.getSensorId(key.key()),
stats.toString()))
- // TODO
- // statsRecordFactory.create(key, value)))
- // .peek((k, v) -> LOGGER.info("{}: {}", k, v)) // TODO Temp logging
+ // .peek((k, v) -> LOGGER.info("{}: {}", k, v))
.to(
this.outputTopic,
Produced.with(
--
GitLab