From cfab15932655842def68acd84a48a30bbc63e4c2 Mon Sep 17 00:00:00 2001
From: lorenz <stu203404@mail.uni-kiel.de>
Date: Fri, 12 Nov 2021 15:43:35 +0100
Subject: [PATCH] Renaming KafkaAggregatedPowerRecordReader to
KafkaActivePowerRecordReader
---
.../commons/beam/kafka/KafkaActivePowerRecordReader.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git a/theodolite-benchmarks/beam-commons/src/main/java/theodolite/commons/beam/kafka/KafkaActivePowerRecordReader.java b/theodolite-benchmarks/beam-commons/src/main/java/theodolite/commons/beam/kafka/KafkaActivePowerRecordReader.java
index 1e97ec57c..453b5c7eb 100644
--- a/theodolite-benchmarks/beam-commons/src/main/java/theodolite/commons/beam/kafka/KafkaActivePowerRecordReader.java
+++ b/theodolite-benchmarks/beam-commons/src/main/java/theodolite/commons/beam/kafka/KafkaActivePowerRecordReader.java
@@ -14,7 +14,7 @@ import titan.ccp.model.records.ActivePowerRecord;
/**
* Simple {@link PTransform} that read from Kafka using {@link KafkaIO}.
*/
-public class KafkaAggregatedPowerRecordReader extends
+public class KafkaActivePowerRecordReader extends
PTransform<PBegin, PCollection<KV<String, ActivePowerRecord>>> {
private static final long serialVersionUID = 2603286150183186115L;
@@ -25,8 +25,8 @@ public class KafkaAggregatedPowerRecordReader extends
* Instantiates a {@link PTransform} that reads from Kafka with the given Configuration.
*/
@SuppressWarnings({"unchecked", "rawtypes"})
- public KafkaAggregatedPowerRecordReader(final String bootstrapServer, final String inputTopic,
- final Properties consumerConfig) {
+ public KafkaActivePowerRecordReader(final String bootstrapServer, final String inputTopic,
+ final Properties consumerConfig) {
super();
// Check if boostrap server and inputTopic are defined
--
GitLab