From b6d305b4e93f0a2302415b8e09d6599de8712fb6 Mon Sep 17 00:00:00 2001
From: lorenz <stu203404@mail.uni-kiel.de>
Date: Tue, 7 Dec 2021 19:58:57 +0100
Subject: [PATCH] Remove unnecessary SuppressWarnings beam-commons
---
.../commons/beam/kafka/KafkaActivePowerRecordReader.java | 1 -
.../commons/beam/kafka/KafkaActivePowerTimestampReader.java | 3 +--
.../java/theodolite/commons/beam/kafka/KafkaGenericReader.java | 3 +--
3 files changed, 2 insertions(+), 5 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 3c6274bc5..4af9053be 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
@@ -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();
diff --git a/theodolite-benchmarks/beam-commons/src/main/java/theodolite/commons/beam/kafka/KafkaActivePowerTimestampReader.java b/theodolite-benchmarks/beam-commons/src/main/java/theodolite/commons/beam/kafka/KafkaActivePowerTimestampReader.java
index fdb15865d..732afe9a0 100644
--- a/theodolite-benchmarks/beam-commons/src/main/java/theodolite/commons/beam/kafka/KafkaActivePowerTimestampReader.java
+++ b/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
diff --git a/theodolite-benchmarks/beam-commons/src/main/java/theodolite/commons/beam/kafka/KafkaGenericReader.java b/theodolite-benchmarks/beam-commons/src/main/java/theodolite/commons/beam/kafka/KafkaGenericReader.java
index 3ec03cbcc..83336b5a4 100644
--- a/theodolite-benchmarks/beam-commons/src/main/java/theodolite/commons/beam/kafka/KafkaGenericReader.java
+++ b/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,
--
GitLab