Remove unnecessary SuppressWarnings beam-commons

theodolite-benchmarks/beam-commons/src/main/java/theodolite/commons/beam/kafka/KafkaActivePowerRecordReader.java

@@ -24,7 +24,6 @@ public class KafkaActivePowerRecordReader extends
   /**
    * Instantiates a {@link PTransform} that reads from Kafka with the given Configuration.
    */
-  @SuppressWarnings({"unchecked", "rawtypes"})
   public KafkaActivePowerRecordReader(final String bootstrapServer, final String inputTopic,
                                       final Map<String, Object> consumerConfig) {
     super();

theodolite-benchmarks/beam-commons/src/main/java/theodolite/commons/beam/kafka/KafkaActivePowerTimestampReader.java

@@ -25,9 +25,8 @@ public class KafkaActivePowerTimestampReader extends
   /**
    * Instantiates a {@link PTransform} that reads from Kafka with the given Configuration.
    */
-  @SuppressWarnings({"unchecked", "rawtypes"})
   public KafkaActivePowerTimestampReader(final String bootstrapServer, final String inputTopic,
-                                         final Map consumerConfig) {
+                                         final Map<String, Object> consumerConfig) {
     super();
 
     // Check if boostrap server and inputTopic are defined

theodolite-benchmarks/beam-commons/src/main/java/theodolite/commons/beam/kafka/KafkaGenericReader.java

@@ -22,9 +22,8 @@ public class KafkaGenericReader<K, V> extends
   /**
    * Instantiates a {@link PTransform} that reads from Kafka with the given Configuration.
    */
-  @SuppressWarnings({"unchecked", "rawtypes"})
   public KafkaGenericReader(final String bootstrapServer, final String inputTopic,
-                            final Map consumerConfig,
+                            final Map<String, Object> consumerConfig,
                             final Class<? extends
                                 org.apache.kafka.common.serialization.Deserializer<K>>
                                   keyDeserializer,