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 e67c5f60b6401b4ecd1f42b2a184afbc4654f425..3f04bf4373aab0394ff4574b4020065ac356724b 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 @@ -12,8 +12,9 @@ import org.apache.kafka.clients.consumer.ConsumerConfig; */ public class AbstractPipeline extends Pipeline { - private static final String KAFKA_CONFIG_SPECIFIC_AVRO_READER = "specific.avro.reader"; - private static final String KAFKA_CONFIG_SCHEMA_REGISTRY_URL = "schema.registry.url"; + 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 16e47f6e1a82dd7d2c672986d67a65d7e008c20e..347d76dfb3d1d1f09f1091296a322a23bba67ec0 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 4a689d3b801edf539a7a9890759c97550865ff26..cff04e132a93f6c8098c3039232dd48084e6d264 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.