Apache
/
nifi
mirror of https://github.com/apache/nifi.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

NIFI-4126 - Add SupportBatching, SideEffectFree and EventDriven annotations to ExtractGrok 

Signed-off-by: Pierre Villard <pierre.villard.fr@gmail.com>

This closes #1950.
This commit is contained in:
Andre F de Miranda 2017-06-27 11:49:29 +10:00 committed by Pierre Villard
parent 202eb5ccbe
commit 1e7eceee84
1 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ExtractGrok.java
View File

@ -21,6 +21,9 @@ import com.fasterxml.jackson.databind.ObjectMapper;
import io.thekraken.grok.api.Grok; import io.thekraken.grok.api.Grok;
import io.thekraken.grok.api.Match; import io.thekraken.grok.api.Match;
import io.thekraken.grok.api.exception.GrokException; 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.WritesAttribute;
import org.apache.nifi.annotation.behavior.WritesAttributes; import org.apache.nifi.annotation.behavior.WritesAttributes;
import org.apache.nifi.annotation.documentation.CapabilityDescription; 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.LinkedBlockingQueue;
import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeUnit;
@EventDriven
@SupportsBatching
@SideEffectFree
@Tags({"grok", "log", "text", "parse", "delimit", "extract"}) @Tags({"grok", "log", "text", "parse", "delimit", "extract"})
@CapabilityDescription("Evaluates one or more Grok Expressions against the content of a FlowFile, " + @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 " + "adding the results as attributes or replacing the content of the FlowFile with a JSON " +