Repository: nifi Updated Branches: refs/heads/master 1d6b486b6 -> 70878fe6d
NIFI-4052 Add DynamicProperty annotation for LookupRecord Signed-off-by: Pierre Villard <[email protected]> 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 <[email protected]> Authored: Sun Jul 23 10:46:05 2017 -0400 Committer: Pierre Villard <[email protected]> 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>> {
