Skip to content
Snippets Groups Projects
Commit 47ec6dbc authored by Sören Henning's avatar Sören Henning
Browse files

Suppress PMD warning

parent a78f5df9
No related branches found
No related tags found
No related merge requests found
Pipeline #6351 passed
......@@ -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
......
......@@ -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) {
......
......@@ -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.
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment