public class org.apache.nifi.processors.standard.ExtractGrok extends org.apache.nifi.processor.AbstractProcessor
{
public static final java.lang.String FLOWFILE_ATTRIBUTE;
public static final java.lang.String FLOWFILE_CONTENT;
private static final java.lang.String APPLICATION_JSON;
private static final java.lang.String DEFAULT_PATTERN_NAME;
public static final org.apache.nifi.components.PropertyDescriptor GROK_EXPRESSION;
public static final org.apache.nifi.components.PropertyDescriptor GROK_PATTERNS;
public static final org.apache.nifi.components.PropertyDescriptor KEEP_EMPTY_CAPTURES;
public static final org.apache.nifi.components.PropertyDescriptor DESTINATION;
public static final org.apache.nifi.components.PropertyDescriptor CHARACTER_SET;
public static final org.apache.nifi.components.PropertyDescriptor MAX_BUFFER_SIZE;
public static final org.apache.nifi.components.PropertyDescriptor NAMED_CAPTURES_ONLY;
public static final org.apache.nifi.processor.Relationship REL_MATCH;
public static final org.apache.nifi.processor.Relationship REL_NO_MATCH;
private static final java.util.List descriptors;
private static final java.util.Set relationships;
private volatile io.krakens.grok.api.Grok grok;
private final java.util.concurrent.BlockingQueue bufferQueue;
private final java.util.concurrent.atomic.AtomicBoolean keepEmptyCaputures;
public void <init>()
{
java.util.concurrent.atomic.AtomicBoolean v;
org.apache.nifi.processors.standard.ExtractGrok v;
java.util.concurrent.LinkedBlockingQueue v;
v := @this: org.apache.nifi.processors.standard.ExtractGrok;
specialinvoke v.<org.apache.nifi.processor.AbstractProcessor: void <init>()>();
v = new java.util.concurrent.LinkedBlockingQueue;
specialinvoke v.<java.util.concurrent.LinkedBlockingQueue: void <init>()>();
v.<org.apache.nifi.processors.standard.ExtractGrok: java.util.concurrent.BlockingQueue bufferQueue> = v;
v = new java.util.concurrent.atomic.AtomicBoolean;
specialinvoke v.<java.util.concurrent.atomic.AtomicBoolean: void <init>(boolean)>(1);
v.<org.apache.nifi.processors.standard.ExtractGrok: java.util.concurrent.atomic.AtomicBoolean keepEmptyCaputures> = v;
return;
}
public java.util.Set getRelationships()
{
java.util.Set v;
org.apache.nifi.processors.standard.ExtractGrok v;
v := @this: org.apache.nifi.processors.standard.ExtractGrok;
v = <org.apache.nifi.processors.standard.ExtractGrok: java.util.Set relationships>;
return v;
}
public final java.util.List getSupportedPropertyDescriptors()
{
java.util.List v;
org.apache.nifi.processors.standard.ExtractGrok v;
v := @this: org.apache.nifi.processors.standard.ExtractGrok;
v = <org.apache.nifi.processors.standard.ExtractGrok: java.util.List descriptors>;
return v;
}
public void onStopped()
{
java.util.concurrent.BlockingQueue v;
org.apache.nifi.processors.standard.ExtractGrok v;
v := @this: org.apache.nifi.processors.standard.ExtractGrok;
v = v.<org.apache.nifi.processors.standard.ExtractGrok: java.util.concurrent.BlockingQueue bufferQueue>;
interfaceinvoke v.<java.util.concurrent.BlockingQueue: void clear()>();
return;
}
protected java.util.Collection customValidate(org.apache.nifi.components.ValidationContext)
{
org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v;
org.apache.nifi.components.PropertyValue v, v, v, v, v;
org.apache.nifi.components.resource.ResourceReference v;
boolean v, v, v;
org.apache.nifi.components.ValidationResult$Builder v, v, v, v, v, v, v, v, v;
org.apache.nifi.processors.standard.ExtractGrok v;
java.lang.Exception v;
io.krakens.grok.api.Grok v;
java.lang.Throwable v, v;
org.apache.nifi.components.ValidationContext v;
java.util.ArrayList v;
java.lang.Boolean v;
java.lang.String v, v, v, v;
org.apache.nifi.components.ValidationResult v, v;
java.lang.Class v;
io.krakens.grok.api.GrokCompiler v;
java.io.InputStream v, v;
v := @this: org.apache.nifi.processors.standard.ExtractGrok;
v := @parameter: org.apache.nifi.components.ValidationContext;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = 0;
v = <org.apache.nifi.processors.standard.ExtractGrok: org.apache.nifi.components.PropertyDescriptor NAMED_CAPTURES_ONLY>;
v = interfaceinvoke v.<org.apache.nifi.components.ValidationContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: boolean isSet()>();
if v == 0 goto label;
v = <org.apache.nifi.processors.standard.ExtractGrok: org.apache.nifi.components.PropertyDescriptor NAMED_CAPTURES_ONLY>;
v = interfaceinvoke v.<org.apache.nifi.components.ValidationContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.Boolean asBoolean()>();
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
label:
v = staticinvoke <io.krakens.grok.api.GrokCompiler: io.krakens.grok.api.GrokCompiler newInstance()>();
v = <org.apache.nifi.processors.standard.ExtractGrok: org.apache.nifi.components.PropertyDescriptor GROK_EXPRESSION>;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor: java.lang.String getName()>();
v = <org.apache.nifi.processors.standard.ExtractGrok: org.apache.nifi.components.PropertyDescriptor GROK_EXPRESSION>;
v = interfaceinvoke v.<org.apache.nifi.components.ValidationContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.String getValue()>();
label:
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = virtualinvoke v.<java.lang.Class: java.io.InputStream getResourceAsStream(java.lang.String)>("/default-grok-patterns.txt");
label:
virtualinvoke v.<io.krakens.grok.api.GrokCompiler: void register(java.io.InputStream)>(v);
label:
if v == null goto label;
virtualinvoke v.<java.io.InputStream: void close()>();
goto label;
label:
v := @caughtexception;
throw v;
label:
v = <org.apache.nifi.processors.standard.ExtractGrok: org.apache.nifi.components.PropertyDescriptor GROK_PATTERNS>;
v = interfaceinvoke v.<org.apache.nifi.components.ValidationContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: boolean isSet()>();
if v == 0 goto label;
v = <org.apache.nifi.processors.standard.ExtractGrok: org.apache.nifi.components.PropertyDescriptor GROK_PATTERNS>;
v = interfaceinvoke v.<org.apache.nifi.components.ValidationContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: org.apache.nifi.components.resource.ResourceReference asResource()>();
v = interfaceinvoke v.<org.apache.nifi.components.resource.ResourceReference: java.io.InputStream read()>();
label:
virtualinvoke v.<io.krakens.grok.api.GrokCompiler: void register(java.io.InputStream)>(v);
label:
if v == null goto label;
virtualinvoke v.<java.io.InputStream: void close()>();
goto label;
label:
v := @caughtexception;
throw v;
label:
v = virtualinvoke v.<io.krakens.grok.api.GrokCompiler: io.krakens.grok.api.Grok compile(java.lang.String,boolean)>(v, v);
v.<org.apache.nifi.processors.standard.ExtractGrok: io.krakens.grok.api.Grok grok> = v;
label:
goto label;
label:
v := @caughtexception;
v = new org.apache.nifi.components.ValidationResult$Builder;
specialinvoke v.<org.apache.nifi.components.ValidationResult$Builder: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.components.ValidationResult$Builder: org.apache.nifi.components.ValidationResult$Builder subject(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.nifi.components.ValidationResult$Builder: org.apache.nifi.components.ValidationResult$Builder input(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.nifi.components.ValidationResult$Builder: org.apache.nifi.components.ValidationResult$Builder valid(boolean)>(0);
v = virtualinvoke v.<java.lang.Exception: java.lang.String getMessage()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Not a valid Grok Expression - \u0001");
v = virtualinvoke v.<org.apache.nifi.components.ValidationResult$Builder: org.apache.nifi.components.ValidationResult$Builder explanation(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.nifi.components.ValidationResult$Builder: org.apache.nifi.components.ValidationResult build()>();
interfaceinvoke v.<java.util.Collection: boolean add(java.lang.Object)>(v);
return v;
label:
v = new org.apache.nifi.components.ValidationResult$Builder;
specialinvoke v.<org.apache.nifi.components.ValidationResult$Builder: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.components.ValidationResult$Builder: org.apache.nifi.components.ValidationResult$Builder subject(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.nifi.components.ValidationResult$Builder: org.apache.nifi.components.ValidationResult$Builder input(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.nifi.components.ValidationResult$Builder: org.apache.nifi.components.ValidationResult$Builder valid(boolean)>(1);
v = virtualinvoke v.<org.apache.nifi.components.ValidationResult$Builder: org.apache.nifi.components.ValidationResult build()>();
interfaceinvoke v.<java.util.Collection: boolean add(java.lang.Object)>(v);
return v;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.lang.Exception from label to label with label;
}
public void onScheduled(org.apache.nifi.processor.ProcessContext) throws io.krakens.grok.api.exception.GrokException, java.io.IOException
{
byte[] v;
org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v;
org.apache.nifi.components.PropertyValue v, v, v, v, v, v;
org.apache.nifi.components.resource.ResourceReference v;
boolean v, v, v;
java.util.concurrent.BlockingQueue v;
org.apache.nifi.processors.standard.ExtractGrok v;
io.krakens.grok.api.Grok v;
org.apache.nifi.processor.DataUnit v;
java.lang.Throwable v, v;
java.lang.Double v;
java.util.concurrent.atomic.AtomicBoolean v;
int v, v, v;
java.lang.Boolean v, v;
java.lang.String v;
org.apache.nifi.processor.ProcessContext v;
java.lang.Class v;
io.krakens.grok.api.GrokCompiler v;
java.io.InputStream v, v;
v := @this: org.apache.nifi.processors.standard.ExtractGrok;
v := @parameter: org.apache.nifi.processor.ProcessContext;
v = v.<org.apache.nifi.processors.standard.ExtractGrok: java.util.concurrent.atomic.AtomicBoolean keepEmptyCaputures>;
v = <org.apache.nifi.processors.standard.ExtractGrok: org.apache.nifi.components.PropertyDescriptor KEEP_EMPTY_CAPTURES>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.Boolean asBoolean()>();
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: void set(boolean)>(v);
v = 0;
label:
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: int getMaxConcurrentTasks()>();
if v >= v goto label;
v = <org.apache.nifi.processors.standard.ExtractGrok: org.apache.nifi.components.PropertyDescriptor MAX_BUFFER_SIZE>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = <org.apache.nifi.processor.DataUnit: org.apache.nifi.processor.DataUnit B>;
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.Double asDataSize(org.apache.nifi.processor.DataUnit)>(v);
v = virtualinvoke v.<java.lang.Double: int intValue()>();
v = newarray (byte)[v];
v = v.<org.apache.nifi.processors.standard.ExtractGrok: java.util.concurrent.BlockingQueue bufferQueue>;
interfaceinvoke v.<java.util.concurrent.BlockingQueue: boolean add(java.lang.Object)>(v);
v = v + 1;
goto label;
label:
v = staticinvoke <io.krakens.grok.api.GrokCompiler: io.krakens.grok.api.GrokCompiler newInstance()>();
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = virtualinvoke v.<java.lang.Class: java.io.InputStream getResourceAsStream(java.lang.String)>("/default-grok-patterns.txt");
label:
virtualinvoke v.<io.krakens.grok.api.GrokCompiler: void register(java.io.InputStream)>(v);
label:
if v == null goto label;
virtualinvoke v.<java.io.InputStream: void close()>();
goto label;
label:
v := @caughtexception;
throw v;
label:
v = <org.apache.nifi.processors.standard.ExtractGrok: org.apache.nifi.components.PropertyDescriptor GROK_PATTERNS>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: boolean isSet()>();
if v == 0 goto label;
v = <org.apache.nifi.processors.standard.ExtractGrok: org.apache.nifi.components.PropertyDescriptor GROK_PATTERNS>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: org.apache.nifi.components.resource.ResourceReference asResource()>();
v = interfaceinvoke v.<org.apache.nifi.components.resource.ResourceReference: java.io.InputStream read()>();
label:
virtualinvoke v.<io.krakens.grok.api.GrokCompiler: void register(java.io.InputStream)>(v);
label:
if v == null goto label;
virtualinvoke v.<java.io.InputStream: void close()>();
goto label;
label:
v := @caughtexception;
throw v;
label:
v = <org.apache.nifi.processors.standard.ExtractGrok: org.apache.nifi.components.PropertyDescriptor GROK_EXPRESSION>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.String getValue()>();
v = <org.apache.nifi.processors.standard.ExtractGrok: org.apache.nifi.components.PropertyDescriptor NAMED_CAPTURES_ONLY>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.Boolean asBoolean()>();
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
v = virtualinvoke v.<io.krakens.grok.api.GrokCompiler: io.krakens.grok.api.Grok compile(java.lang.String,boolean)>(v, v);
v.<org.apache.nifi.processors.standard.ExtractGrok: io.krakens.grok.api.Grok grok> = v;
return;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
}
public void onTrigger(org.apache.nifi.processor.ProcessContext, org.apache.nifi.processor.ProcessSession) throws org.apache.nifi.processor.exception.ProcessException
{
org.apache.nifi.processor.io.OutputStreamCallback v;
java.lang.Integer v;
org.apache.nifi.components.PropertyDescriptor v, v, v;
byte v;
java.util.Map v;
io.krakens.grok.api.Match v;
java.util.Set v;
java.util.concurrent.BlockingQueue v, v, v;
org.apache.nifi.util.StopWatch v;
org.apache.nifi.processor.DataUnit v;
java.lang.Throwable v;
java.lang.Object[] v, v;
java.lang.Double v;
long v, v, v;
org.apache.nifi.provenance.ProvenanceReporter v, v;
org.apache.nifi.processor.Relationship v, v, v;
java.lang.String v, v, v, v, v, v;
org.apache.nifi.processor.ProcessSession v;
org.apache.nifi.flowfile.attributes.CoreAttributes v;
org.apache.nifi.components.PropertyValue v, v, v;
org.apache.nifi.processor.io.InputStreamCallback v;
boolean v, v, v, v, v;
org.apache.nifi.flowfile.FlowFile v, v, v, v;
org.apache.nifi.processors.standard.ExtractGrok v;
io.krakens.grok.api.Grok v;
java.util.concurrent.atomic.AtomicBoolean v;
java.util.HashMap v;
org.apache.nifi.logging.ComponentLog v, v;
java.nio.charset.Charset v;
int v, v, v, v;
java.util.Iterator v;
com.fasterxml.jackson.databind.ObjectMapper v;
org.apache.nifi.processor.ProcessContext v;
java.util.concurrent.TimeUnit v;
java.lang.Object v, v, v, v, v;
v := @this: org.apache.nifi.processors.standard.ExtractGrok;
v := @parameter: org.apache.nifi.processor.ProcessContext;
v := @parameter: org.apache.nifi.processor.ProcessSession;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile get()>();
if v != null goto label;
return;
label:
v = new org.apache.nifi.util.StopWatch;
specialinvoke v.<org.apache.nifi.util.StopWatch: void <init>(boolean)>(1);
v = <org.apache.nifi.processors.standard.ExtractGrok: org.apache.nifi.components.PropertyDescriptor CHARACTER_SET>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.String getValue()>();
v = staticinvoke <java.nio.charset.Charset: java.nio.charset.Charset forName(java.lang.String)>(v);
v = v.<org.apache.nifi.processors.standard.ExtractGrok: java.util.concurrent.BlockingQueue bufferQueue>;
v = interfaceinvoke v.<java.util.concurrent.BlockingQueue: java.lang.Object poll()>();
if v != null goto label;
v = <org.apache.nifi.processors.standard.ExtractGrok: org.apache.nifi.components.PropertyDescriptor MAX_BUFFER_SIZE>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = <org.apache.nifi.processor.DataUnit: org.apache.nifi.processor.DataUnit B>;
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.Double asDataSize(org.apache.nifi.processor.DataUnit)>(v);
v = virtualinvoke v.<java.lang.Double: int intValue()>();
v = newarray (byte)[v];
label:
v = staticinvoke <org.apache.nifi.processors.standard.ExtractGrok$lambda_onTrigger_0__77: org.apache.nifi.processor.io.InputStreamCallback bootstrap$(byte[])>(v);
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void read(org.apache.nifi.flowfile.FlowFile,org.apache.nifi.processor.io.InputStreamCallback)>(v, v);
v = lengthof v;
v = interfaceinvoke v.<org.apache.nifi.flowfile.FlowFile: long getSize()>();
v = staticinvoke <java.lang.Math: long min(long,long)>(v, v);
v = new java.lang.String;
specialinvoke v.<java.lang.String: void <init>(byte[],int,int,java.nio.charset.Charset)>(v, 0, v, v);
label:
v = v.<org.apache.nifi.processors.standard.ExtractGrok: java.util.concurrent.BlockingQueue bufferQueue>;
interfaceinvoke v.<java.util.concurrent.BlockingQueue: boolean offer(java.lang.Object)>(v);
goto label;
label:
v := @caughtexception;
v = v.<org.apache.nifi.processors.standard.ExtractGrok: java.util.concurrent.BlockingQueue bufferQueue>;
interfaceinvoke v.<java.util.concurrent.BlockingQueue: boolean offer(java.lang.Object)>(v);
throw v;
label:
v = v.<org.apache.nifi.processors.standard.ExtractGrok: io.krakens.grok.api.Grok grok>;
v = virtualinvoke v.<io.krakens.grok.api.Grok: io.krakens.grok.api.Match match(java.lang.CharSequence)>(v);
v = v.<org.apache.nifi.processors.standard.ExtractGrok: java.util.concurrent.atomic.AtomicBoolean keepEmptyCaputures>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: boolean get()>();
virtualinvoke v.<io.krakens.grok.api.Match: void setKeepEmptyCaptures(boolean)>(v);
v = virtualinvoke v.<io.krakens.grok.api.Match: java.util.Map capture()>();
v = interfaceinvoke v.<java.util.Map: boolean isEmpty()>();
if v == 0 goto label;
v = <org.apache.nifi.processors.standard.ExtractGrok: org.apache.nifi.processor.Relationship REL_NO_MATCH>;
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void transfer(org.apache.nifi.flowfile.FlowFile,org.apache.nifi.processor.Relationship)>(v, v);
v = virtualinvoke v.<org.apache.nifi.processors.standard.ExtractGrok: org.apache.nifi.logging.ComponentLog getLogger()>();
v = newarray (java.lang.Object)[1];
v[0] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void info(java.lang.String,java.lang.Object[])>("Did not match any Grok Expressions for FlowFile {}", v);
return;
label:
v = new com.fasterxml.jackson.databind.ObjectMapper;
specialinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: void <init>()>();
v = <org.apache.nifi.processors.standard.ExtractGrok: org.apache.nifi.components.PropertyDescriptor DESTINATION>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.String getValue()>();
v = -1;
v = virtualinvoke v.<java.lang.String: int hashCode()>();
lookupswitch(v)
{
case -1375719367: goto label;
case -1029800618: goto label;
default: goto label;
};
label:
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>("flowfile-attribute");
if v == 0 goto label;
v = 0;
goto label;
label:
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>("flowfile-content");
if v == 0 goto label;
v = 1;
label:
lookupswitch(v)
{
case 0: goto label;
case 1: goto label;
default: goto label;
};
label:
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v = interfaceinvoke v.<java.util.Map: java.util.Set entrySet()>();
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
if null == v goto label;
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getKey()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.Object)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("grok.\u0001");
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
v = virtualinvoke v.<java.lang.Object: java.lang.String toString()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
goto label;
label:
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile putAllAttributes(org.apache.nifi.flowfile.FlowFile,java.util.Map)>(v, v);
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.provenance.ProvenanceReporter getProvenanceReporter()>();
interfaceinvoke v.<org.apache.nifi.provenance.ProvenanceReporter: void modifyAttributes(org.apache.nifi.flowfile.FlowFile)>(v);
v = <org.apache.nifi.processors.standard.ExtractGrok: org.apache.nifi.processor.Relationship REL_MATCH>;
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void transfer(org.apache.nifi.flowfile.FlowFile,org.apache.nifi.processor.Relationship)>(v, v);
v = virtualinvoke v.<org.apache.nifi.processors.standard.ExtractGrok: org.apache.nifi.logging.ComponentLog getLogger()>();
v = newarray (java.lang.Object)[2];
v = interfaceinvoke v.<java.util.Map: int size()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[0] = v;
v[1] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void info(java.lang.String,java.lang.Object[])>("Matched {} Grok Expressions and added attributes to FlowFile {}", v);
goto label;
label:
v = staticinvoke <org.apache.nifi.processors.standard.ExtractGrok$lambda_onTrigger_1__78: org.apache.nifi.processor.io.OutputStreamCallback bootstrap$(com.fasterxml.jackson.databind.ObjectMapper,java.util.Map)>(v, v);
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile write(org.apache.nifi.flowfile.FlowFile,org.apache.nifi.processor.io.OutputStreamCallback)>(v, v);
v = <org.apache.nifi.flowfile.attributes.CoreAttributes: org.apache.nifi.flowfile.attributes.CoreAttributes MIME_TYPE>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.CoreAttributes: java.lang.String key()>();
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile putAttribute(org.apache.nifi.flowfile.FlowFile,java.lang.String,java.lang.String)>(v, v, "application/json");
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.provenance.ProvenanceReporter getProvenanceReporter()>();
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit MILLISECONDS>;
v = virtualinvoke v.<org.apache.nifi.util.StopWatch: long getElapsed(java.util.concurrent.TimeUnit)>(v);
interfaceinvoke v.<org.apache.nifi.provenance.ProvenanceReporter: void modifyContent(org.apache.nifi.flowfile.FlowFile,java.lang.String,long)>(v, "Replaced content with parsed Grok fields and values", v);
v = <org.apache.nifi.processors.standard.ExtractGrok: org.apache.nifi.processor.Relationship REL_MATCH>;
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void transfer(org.apache.nifi.flowfile.FlowFile,org.apache.nifi.processor.Relationship)>(v, v);
label:
return;
catch java.lang.Throwable from label to label with label;
}
static void <clinit>()
{
org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.util.Set v;
java.util.ArrayList v;
org.apache.nifi.processor.Relationship v, v, v, v;
org.apache.nifi.components.resource.ResourceType[] v;
org.apache.nifi.components.PropertyDescriptor$Builder v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.nifi.components.resource.ResourceCardinality v;
org.apache.nifi.components.resource.ResourceType v, v, v;
java.util.List v;
java.lang.String[] v, v, v;
java.util.HashSet v;
org.apache.nifi.components.Validator v, v, v, v, v, v;
org.apache.nifi.processor.Relationship$Builder v, v, v, v, v, v;
v = new org.apache.nifi.components.PropertyDescriptor$Builder;
specialinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder name(java.lang.String)>("Grok Expression");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("Grok expression. If other Grok expressions are referenced in this expression, they must be provided in the Grok Pattern File if set or exist in the default Grok patterns");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder required(boolean)>(1);
v = <org.apache.nifi.processor.util.StandardValidators: org.apache.nifi.components.Validator NON_BLANK_VALIDATOR>;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder addValidator(org.apache.nifi.components.Validator)>(v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.ExtractGrok: org.apache.nifi.components.PropertyDescriptor GROK_EXPRESSION> = v;
v = new org.apache.nifi.components.PropertyDescriptor$Builder;
specialinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder name(java.lang.String)>("Grok Pattern file");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder displayName(java.lang.String)>("Grok Patterns");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("Custom Grok pattern definitions. These definitions will be loaded after the default Grok patterns. The Grok Parser will use the default Grok patterns when this property is not configured.");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder required(boolean)>(0);
v = <org.apache.nifi.components.resource.ResourceCardinality: org.apache.nifi.components.resource.ResourceCardinality SINGLE>;
v = <org.apache.nifi.components.resource.ResourceType: org.apache.nifi.components.resource.ResourceType FILE>;
v = newarray (org.apache.nifi.components.resource.ResourceType)[2];
v = <org.apache.nifi.components.resource.ResourceType: org.apache.nifi.components.resource.ResourceType TEXT>;
v[0] = v;
v = <org.apache.nifi.components.resource.ResourceType: org.apache.nifi.components.resource.ResourceType URL>;
v[1] = v;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder identifiesExternalResource(org.apache.nifi.components.resource.ResourceCardinality,org.apache.nifi.components.resource.ResourceType,org.apache.nifi.components.resource.ResourceType[])>(v, v, v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.ExtractGrok: org.apache.nifi.components.PropertyDescriptor GROK_PATTERNS> = v;
v = new org.apache.nifi.components.PropertyDescriptor$Builder;
specialinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder name(java.lang.String)>("Keep Empty Captures");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("If true, then empty capture values will be included in the returned capture map.");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder required(boolean)>(1);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder defaultValue(java.lang.String)>("true");
v = newarray (java.lang.String)[2];
v[0] = "true";
v[1] = "false";
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder allowableValues(java.lang.String[])>(v);
v = <org.apache.nifi.processor.util.StandardValidators: org.apache.nifi.components.Validator BOOLEAN_VALIDATOR>;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder addValidator(org.apache.nifi.components.Validator)>(v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.ExtractGrok: org.apache.nifi.components.PropertyDescriptor KEEP_EMPTY_CAPTURES> = v;
v = new org.apache.nifi.components.PropertyDescriptor$Builder;
specialinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder name(java.lang.String)>("Destination");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("Control if Grok output value is written as a new flowfile attributes, in this case each of the Grok identifier that is matched in the flowfile will be added as an attribute, prefixed with \"grok.\" or written in the flowfile content. Writing to flowfile content will overwrite any existing flowfile content.");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder required(boolean)>(1);
v = newarray (java.lang.String)[2];
v[0] = "flowfile-attribute";
v[1] = "flowfile-content";
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder allowableValues(java.lang.String[])>(v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder defaultValue(java.lang.String)>("flowfile-attribute");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.ExtractGrok: org.apache.nifi.components.PropertyDescriptor DESTINATION> = v;
v = new org.apache.nifi.components.PropertyDescriptor$Builder;
specialinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder name(java.lang.String)>("Character Set");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("The Character Set in which the file is encoded");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder required(boolean)>(1);
v = <org.apache.nifi.processor.util.StandardValidators: org.apache.nifi.components.Validator CHARACTER_SET_VALIDATOR>;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder addValidator(org.apache.nifi.components.Validator)>(v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder defaultValue(java.lang.String)>("UTF-8");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.ExtractGrok: org.apache.nifi.components.PropertyDescriptor CHARACTER_SET> = v;
v = new org.apache.nifi.components.PropertyDescriptor$Builder;
specialinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder name(java.lang.String)>("Maximum Buffer Size");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("Specifies the maximum amount of data to buffer (per file) in order to apply the Grok expressions. Files larger than the specified maximum will not be fully evaluated.");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder required(boolean)>(1);
v = <org.apache.nifi.processor.util.StandardValidators: org.apache.nifi.components.Validator DATA_SIZE_VALIDATOR>;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder addValidator(org.apache.nifi.components.Validator)>(v);
v = staticinvoke <org.apache.nifi.processor.util.StandardValidators: org.apache.nifi.components.Validator createDataSizeBoundsValidator(long,long)>(0L, 2147483647L);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder addValidator(org.apache.nifi.components.Validator)>(v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder defaultValue(java.lang.String)>("1 MB");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.ExtractGrok: org.apache.nifi.components.PropertyDescriptor MAX_BUFFER_SIZE> = v;
v = new org.apache.nifi.components.PropertyDescriptor$Builder;
specialinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder name(java.lang.String)>("Named captures only");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("Only store named captures from grok");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder required(boolean)>(1);
v = newarray (java.lang.String)[2];
v[0] = "true";
v[1] = "false";
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder allowableValues(java.lang.String[])>(v);
v = <org.apache.nifi.processor.util.StandardValidators: org.apache.nifi.components.Validator BOOLEAN_VALIDATOR>;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder addValidator(org.apache.nifi.components.Validator)>(v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder defaultValue(java.lang.String)>("false");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.ExtractGrok: org.apache.nifi.components.PropertyDescriptor NAMED_CAPTURES_ONLY> = v;
v = new org.apache.nifi.processor.Relationship$Builder;
specialinvoke v.<org.apache.nifi.processor.Relationship$Builder: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship$Builder name(java.lang.String)>("matched");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship$Builder description(java.lang.String)>("FlowFiles are routed to this relationship when the Grok Expression is successfully evaluated and the FlowFile is modified as a result");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship build()>();
<org.apache.nifi.processors.standard.ExtractGrok: org.apache.nifi.processor.Relationship REL_MATCH> = v;
v = new org.apache.nifi.processor.Relationship$Builder;
specialinvoke v.<org.apache.nifi.processor.Relationship$Builder: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship$Builder name(java.lang.String)>("unmatched");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship$Builder description(java.lang.String)>("FlowFiles are routed to this relationship when no provided Grok Expression matches the content of the FlowFile");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship build()>();
<org.apache.nifi.processors.standard.ExtractGrok: org.apache.nifi.processor.Relationship REL_NO_MATCH> = v;
v = new java.util.HashSet;
specialinvoke v.<java.util.HashSet: void <init>()>();
v = <org.apache.nifi.processors.standard.ExtractGrok: org.apache.nifi.processor.Relationship REL_MATCH>;
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.ExtractGrok: org.apache.nifi.processor.Relationship REL_NO_MATCH>;
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
v = staticinvoke <java.util.Collections: java.util.Set unmodifiableSet(java.util.Set)>(v);
<org.apache.nifi.processors.standard.ExtractGrok: java.util.Set relationships> = v;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = <org.apache.nifi.processors.standard.ExtractGrok: org.apache.nifi.components.PropertyDescriptor GROK_EXPRESSION>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.ExtractGrok: org.apache.nifi.components.PropertyDescriptor GROK_PATTERNS>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.ExtractGrok: org.apache.nifi.components.PropertyDescriptor DESTINATION>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.ExtractGrok: org.apache.nifi.components.PropertyDescriptor CHARACTER_SET>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.ExtractGrok: org.apache.nifi.components.PropertyDescriptor MAX_BUFFER_SIZE>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.ExtractGrok: org.apache.nifi.components.PropertyDescriptor NAMED_CAPTURES_ONLY>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.ExtractGrok: org.apache.nifi.components.PropertyDescriptor KEEP_EMPTY_CAPTURES>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = staticinvoke <java.util.Collections: java.util.List unmodifiableList(java.util.List)>(v);
<org.apache.nifi.processors.standard.ExtractGrok: java.util.List descriptors> = v;
return;
}
}