Refactor uc4-beam AggregatedActivePowerRecordSerializer.java

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) {