From 60863606bd5480e0d70403568576c6bdf7ef8e0c Mon Sep 17 00:00:00 2001
From: lorenz <stu203404@mail.uni-kiel.de>
Date: Fri, 12 Nov 2021 16:41:58 +0100
Subject: [PATCH] Add missing renaming of AggregatedRecord to ActiveRecord
---
.../src/main/java/application/Uc1ApplicationBeam.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/theodolite-benchmarks/uc1-beam-flink/src/main/java/application/Uc1ApplicationBeam.java b/theodolite-benchmarks/uc1-beam-flink/src/main/java/application/Uc1ApplicationBeam.java
index e8707fcdf..b794146c0 100644
--- a/theodolite-benchmarks/uc1-beam-flink/src/main/java/application/Uc1ApplicationBeam.java
+++ b/theodolite-benchmarks/uc1-beam-flink/src/main/java/application/Uc1ApplicationBeam.java
@@ -18,7 +18,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import theodolite.commons.beam.AbstractBeamService;
import theodolite.commons.beam.ConfigurationKeys;
-import theodolite.commons.beam.kafka.KafkaAggregatedPowerRecordReader;
+import theodolite.commons.beam.kafka.KafkaActivePowerRecordReader;
import titan.ccp.model.records.ActivePowerRecord;
@@ -66,7 +66,7 @@ public final class Uc1ApplicationBeam extends AbstractBeamService {
// Create Pipeline transformations
final PTransform<PBegin, PCollection<KV<String, ActivePowerRecord>>> kafka =
- new KafkaAggregatedPowerRecordReader(uc1.bootstrapServer, uc1.inputTopic, consumerConfig);
+ new KafkaActivePowerRecordReader(uc1.bootstrapServer, uc1.inputTopic, consumerConfig);
final LogKeyValue logKeyValue = new LogKeyValue();
--
GitLab