Github user trixpan commented on a diff in the pull request:
https://github.com/apache/nifi/pull/496#discussion_r72592679
--- Diff:
nifi-nar-bundles/nifi-enrich-bundle/nifi-enrich-processors/src/main/java/org/apache/nifi/processors/enrich/AbstractEnrichProcessor.java
---
@@ -0,0 +1,151 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.nifi.processors.enrich;
+
+
+import org.apache.nifi.components.AllowableValue;
+import org.apache.nifi.components.PropertyDescriptor;
+import org.apache.nifi.components.ValidationContext;
+import org.apache.nifi.components.ValidationResult;
+import org.apache.nifi.processor.AbstractProcessor;
+import org.apache.nifi.processor.Relationship;
+import org.apache.nifi.processor.util.StandardValidators;
+
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.regex.Matcher;
+import java.util.regex.Pattern;
+
+public abstract class AbstractEnrichProcessor extends AbstractProcessor {
+ public static final PropertyDescriptor QUERY_INPUT = new
PropertyDescriptor.Builder()
+ .name("Format the query should be to be executed ")
+ .required(true)
+ .description("The value that should be used to populate the
query")
+ .expressionLanguageSupported(true)
+ .addValidator(StandardValidators.NON_EMPTY_VALIDATOR)
+ .build();
+
+ public static final AllowableValue SPLIT= new AllowableValue("Split",
"Split",
+ "String.splitUse a delimiter character or RegEx to split the
results into attributes");
+ public static final AllowableValue REGEX = new AllowableValue("RegEx",
"RegEx",
+ "Use a regular expression to split the results into attributes
");
+ public static final AllowableValue NONE = new AllowableValue("None",
"None",
+ "Do not split results");
+
+ public static final PropertyDescriptor QUERY_PARSER = new
PropertyDescriptor.Builder()
+ .name("Results Parser")
+ .description("The method used to slice the results into
attribute groups")
+ .allowableValues(SPLIT, REGEX, NONE)
+ .required(true)
+ .defaultValue(NONE.getValue())
+ .build();
+
+ public static final PropertyDescriptor QUERY_PARSER_INPUT = new
PropertyDescriptor.Builder()
+ .name("Parser RegEx")
+ .description("Choice between a splitter and regex matcher used
to parse the results of the query into attribute groups")
+ .expressionLanguageSupported(false)
+ .required(false)
+ .addValidator(StandardValidators.NON_EMPTY_VALIDATOR)
+ .build();
+
+
+ public static final Relationship REL_FOUND = new Relationship.Builder()
+ .name("found")
+ .description("Where to route flow files after successfully
enriching attributes with data")
+ .build();
+
+ public static final Relationship REL_NOT_FOUND = new
Relationship.Builder()
+ .name("not found")
+ .description("Where to route flow if data enrichment query
rendered no results")
--- End diff --
addressed
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---
