From 47ec6dbc55b217b45d62c733fb9a1137f8f16019 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?S=C3=B6ren=20Henning?= <soeren.henning@email.uni-kiel.de>
Date: Mon, 31 Jan 2022 22:30:53 +0100
Subject: [PATCH] Suppress PMD warning
---
.../main/java/theodolite/commons/beam/AbstractPipeline.java | 1 +
.../uc4-beam/src/main/java/application/DuplicateAsFlatMap.java | 3 ++-
.../src/main/java/application/UpdateChildParentPairs.java | 2 +-
3 files changed, 4 insertions(+), 2 deletions(-)
diff --git a/theodolite-benchmarks/beam-commons/src/main/java/theodolite/commons/beam/AbstractPipeline.java b/theodolite-benchmarks/beam-commons/src/main/java/theodolite/commons/beam/AbstractPipeline.java
index 06730588e..3f04bf437 100644
--- a/theodolite-benchmarks/beam-commons/src/main/java/theodolite/commons/beam/AbstractPipeline.java
+++ b/theodolite-benchmarks/beam-commons/src/main/java/theodolite/commons/beam/AbstractPipeline.java
@@ -14,6 +14,7 @@ public class AbstractPipeline extends Pipeline {
private static final String KAFKA_CONFIG_SPECIFIC_AVRO_READER = "specific.avro.reader"; // NOPMD
private static final String KAFKA_CONFIG_SCHEMA_REGISTRY_URL = "schema.registry.url"; // NOPMD
+
protected final String inputTopic;
protected final String bootstrapServer;
// Application Configurations
diff --git a/theodolite-benchmarks/uc4-beam/src/main/java/application/DuplicateAsFlatMap.java b/theodolite-benchmarks/uc4-beam/src/main/java/application/DuplicateAsFlatMap.java
index 16e47f6e1..347d76dfb 100644
--- a/theodolite-benchmarks/uc4-beam/src/main/java/application/DuplicateAsFlatMap.java
+++ b/theodolite-benchmarks/uc4-beam/src/main/java/application/DuplicateAsFlatMap.java
@@ -24,7 +24,8 @@ public class DuplicateAsFlatMap
private static final String STATE_STORE_NAME = "DuplicateParents";
@StateId(STATE_STORE_NAME)
- private final StateSpec<ValueState<Set<String>>> parents = StateSpecs.value();
+ private final StateSpec<ValueState<Set<String>>> parents = StateSpecs.value(); // NOPMD
+
private final PCollectionView<Map<String, Set<String>>> childParentPairMap;
public DuplicateAsFlatMap(final PCollectionView<Map<String, Set<String>>> childParentPairMap) {
diff --git a/theodolite-benchmarks/uc4-beam/src/main/java/application/UpdateChildParentPairs.java b/theodolite-benchmarks/uc4-beam/src/main/java/application/UpdateChildParentPairs.java
index 4a689d3b8..cff04e132 100644
--- a/theodolite-benchmarks/uc4-beam/src/main/java/application/UpdateChildParentPairs.java
+++ b/theodolite-benchmarks/uc4-beam/src/main/java/application/UpdateChildParentPairs.java
@@ -17,7 +17,7 @@ public class UpdateChildParentPairs extends DoFn<KV<String, Set<String>>, KV<Str
private static final long serialVersionUID = 1L;
@StateId(STATE_STORE_NAME)
- private final StateSpec<ValueState<Set<String>>> parents = StateSpecs.value();
+ private final StateSpec<ValueState<Set<String>>> parents = StateSpecs.value(); // NOPMD
/**
* Match the changes accordingly.
--
GitLab