You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nifi.apache.org by pv...@apache.org on 2017/07/28 15:12:54 UTC
nifi git commit: NIFI-4052 Add DynamicProperty annotation for
LookupRecord
Repository: nifi
Updated Branches:
refs/heads/master 1d6b486b6 -> 70878fe6d
NIFI-4052 Add DynamicProperty annotation for LookupRecord
Signed-off-by: Pierre Villard <pi...@gmail.com>
This closes #2032.
Project: http://git-wip-us.apache.org/repos/asf/nifi/repo
Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/70878fe6
Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/70878fe6
Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/70878fe6
Branch: refs/heads/master
Commit: 70878fe6d63798b50c3f3ae5440833462e1ec43a
Parents: 1d6b486
Author: Leah Anderson <an...@gmail.com>
Authored: Sun Jul 23 10:46:05 2017 -0400
Committer: Pierre Villard <pi...@gmail.com>
Committed: Fri Jul 28 17:12:06 2017 +0200
----------------------------------------------------------------------
.../java/org/apache/nifi/processors/standard/LookupRecord.java | 3 +++
1 file changed, 3 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/nifi/blob/70878fe6/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/LookupRecord.java
----------------------------------------------------------------------
diff --git a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/LookupRecord.java b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/LookupRecord.java
index 4658c95..10539bc 100644
--- a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/LookupRecord.java
+++ b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/LookupRecord.java
@@ -29,6 +29,7 @@ import java.util.Optional;
import java.util.Set;
import java.util.stream.Collectors;
+import org.apache.nifi.annotation.behavior.DynamicProperty;
import org.apache.nifi.annotation.behavior.EventDriven;
import org.apache.nifi.annotation.behavior.InputRequirement;
import org.apache.nifi.annotation.behavior.InputRequirement.Requirement;
@@ -80,6 +81,8 @@ import org.apache.nifi.util.Tuple;
+ "that match will be updated. If there is no match in the configured LookupService, then no fields will be updated. I.e., it will not overwrite an existing value in the Record "
+ "with a null value. Please note, however, that if the results returned by the LookupService are not accounted for in your schema (specifically, "
+ "the schema that is configured for your Record Writer) then the fields will not be written out to the FlowFile.")
+@DynamicProperty(name = "Value To Lookup", value = "Valid Record Path", supportsExpressionLanguage = true, description = "A RecordPath that points to the field whose value will be "
+ + "looked up in the configured Lookup Service")
@SeeAlso(value = {ConvertRecord.class, SplitRecord.class}, classNames = {"org.apache.nifi.lookup.SimpleKeyValueLookupService", "org.apache.nifi.lookup.maxmind.IPLookupService"})
public class LookupRecord extends AbstractRouteRecord<Tuple<Map<String, RecordPath>, RecordPath>> {