Fix code quality issues

theodolite-benchmarks/uc3-beam/src/main/java/rocks/theodolite/benchmarks/uc3/beam/LogWriter.java

@@ -4,19 +4,19 @@ import org.apache.beam.sdk.transforms.DoFn;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
+/**
+ * Simple {@link DoFn} that simply logs all incoming objects.
+ *
+ * @param <T> Type of objects to be logged.
+ */
 public class LogWriter<T> extends DoFn<T, Void> {
 
   private static final long serialVersionUID = -5263671231838353742L; // NOPMD
 
   private static final Logger LOGGER = LoggerFactory.getLogger(LogWriter.class);
 
-  public LogWriter() {
-    super();
-  }
-
   @ProcessElement
   public void processElement(@Element final T record, final OutputReceiver<Void> out) {
-    System.out.println(record);
     LOGGER.info("Record: {}", record);
   }
 

theodolite-benchmarks/uc3-beam/src/main/java/rocks/theodolite/benchmarks/uc3/beam/SimplePipelineFactory.java

@@ -44,9 +44,6 @@ public class SimplePipelineFactory extends AbstractPipelineFactory {
     final Duration aggregationAdvanceDuration =
         Duration.standardSeconds(this.config.getInt(ConfigurationKeys.AGGREGATION_ADVANCE_SECONDS));
 
-    System.out.println(duration);
-    System.out.println(aggregationAdvanceDuration);
-
     // Read from Kafka
     // TODO allow for pubsub
     final KafkaActivePowerTimestampReader kafkaReader = super.buildKafkaReader();