Repository: nifi Updated Branches: refs/heads/master 202eb5ccb -> 1e7eceee8
NIFI-4126 - Add SupportBatching, SideEffectFree and EventDriven annotations to ExtractGrok Signed-off-by: Pierre Villard <[email protected]> This closes #1950. Project: http://git-wip-us.apache.org/repos/asf/nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/1e7eceee Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/1e7eceee Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/1e7eceee Branch: refs/heads/master Commit: 1e7eceee8433d59904551d14856d66498785fdf2 Parents: 202eb5c Author: Andre F de Miranda <[email protected]> Authored: Tue Jun 27 11:49:29 2017 +1000 Committer: Pierre Villard <[email protected]> Committed: Tue Jun 27 20:56:56 2017 +0200 ---------------------------------------------------------------------- .../java/org/apache/nifi/processors/standard/ExtractGrok.java | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/nifi/blob/1e7eceee/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ExtractGrok.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ExtractGrok.java b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ExtractGrok.java index 6b56638..8e20b9e 100644 --- a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ExtractGrok.java +++ b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ExtractGrok.java @@ -21,6 +21,9 @@ import com.fasterxml.jackson.databind.ObjectMapper; import io.thekraken.grok.api.Grok; import io.thekraken.grok.api.Match; import io.thekraken.grok.api.exception.GrokException; +import org.apache.nifi.annotation.behavior.EventDriven; +import org.apache.nifi.annotation.behavior.SideEffectFree; +import org.apache.nifi.annotation.behavior.SupportsBatching; import org.apache.nifi.annotation.behavior.WritesAttribute; import org.apache.nifi.annotation.behavior.WritesAttributes; import org.apache.nifi.annotation.documentation.CapabilityDescription; @@ -61,7 +64,9 @@ import java.util.concurrent.BlockingQueue; import java.util.concurrent.LinkedBlockingQueue; import java.util.concurrent.TimeUnit; - +@EventDriven +@SupportsBatching +@SideEffectFree @Tags({"grok", "log", "text", "parse", "delimit", "extract"}) @CapabilityDescription("Evaluates one or more Grok Expressions against the content of a FlowFile, " + "adding the results as attributes or replacing the content of the FlowFile with a JSON " +
