From 034c17c77ce8b809d1fd38a9549161ca100397f2 Mon Sep 17 00:00:00 2001
From: lorenz <stu203404@mail.uni-kiel.de>
Date: Thu, 25 Nov 2021 15:54:53 +0100
Subject: [PATCH] Refactor uc4-beam AggregatedActivePowerRecordSerializer.java
---
.../AggregatedActivePowerRecordSerializer.java | 12 ++----------
1 file changed, 2 insertions(+), 10 deletions(-)
diff --git a/theodolite-benchmarks/uc4-beam/src/main/java/serialization/AggregatedActivePowerRecordSerializer.java b/theodolite-benchmarks/uc4-beam/src/main/java/serialization/AggregatedActivePowerRecordSerializer.java
index 287faf524..319fca931 100644
--- a/theodolite-benchmarks/uc4-beam/src/main/java/serialization/AggregatedActivePowerRecordSerializer.java
+++ b/theodolite-benchmarks/uc4-beam/src/main/java/serialization/AggregatedActivePowerRecordSerializer.java
@@ -2,7 +2,6 @@ package serialization;
import java.io.ByteArrayOutputStream;
import java.io.IOException;
-
import org.apache.beam.sdk.coders.AvroCoder;
import org.apache.kafka.common.serialization.Serializer;
import org.slf4j.Logger;
@@ -17,15 +16,8 @@ public class AggregatedActivePowerRecordSerializer
private static final Logger LOGGER =
LoggerFactory.getLogger(AggregatedActivePowerRecordSerializer.class);
- private final transient AvroCoder avroEnCoder = AvroCoder.of(AggregatedActivePowerRecord.class);
-
- // Gab
- // Fehler:/home/jan/jan-bensien-bsc/uc2-application-samza/src/main
- // /java/serialization/AggregatedActivePowerRecordSerializer.java:9:
- // error: AggregatedActivePowerRecordSerializer is not abstract and does not override abstract
- // method close() in Serializer
- // public class AggregatedActivePowerRecordSerializer implements Serializer
- // <AggregatedActivePowerRecord>{
+ private final transient AvroCoder<AggregatedActivePowerRecord>
+ avroEnCoder = AvroCoder.of(AggregatedActivePowerRecord.class);
@Override
public byte[] serialize(final String topic, final AggregatedActivePowerRecord data) {
--
GitLab