public class org.apache.nifi.processors.standard.ReplaceTextWithMapping extends org.apache.nifi.processor.AbstractProcessor
{
public static final org.apache.nifi.components.PropertyDescriptor REGEX;
public static final org.apache.nifi.components.PropertyDescriptor MATCHING_GROUP_FOR_LOOKUP_KEY;
public static final org.apache.nifi.components.PropertyDescriptor MAPPING_FILE;
public static final org.apache.nifi.components.PropertyDescriptor MAPPING_FILE_REFRESH_INTERVAL;
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.processor.Relationship REL_SUCCESS;
public static final org.apache.nifi.processor.Relationship REL_FAILURE;
private final java.util.regex.Pattern backReferencePattern;
private java.util.List properties;
private java.util.Set relationships;
private final java.util.concurrent.locks.ReentrantLock processorLock;
private final java.util.concurrent.atomic.AtomicLong lastModified;
final java.util.concurrent.atomic.AtomicLong mappingTestTime;
private final java.util.concurrent.atomic.AtomicReference configurationStateRef;
public void <init>()
{
java.util.concurrent.atomic.AtomicLong v, v;
java.util.concurrent.locks.ReentrantLock v;
org.apache.nifi.processors.standard.ReplaceTextWithMapping v;
org.apache.nifi.processors.standard.ReplaceTextWithMapping$ConfigurationState v;
java.util.regex.Pattern v;
java.util.concurrent.atomic.AtomicReference v;
v := @this: org.apache.nifi.processors.standard.ReplaceTextWithMapping;
specialinvoke v.<org.apache.nifi.processor.AbstractProcessor: void <init>()>();
v = staticinvoke <java.util.regex.Pattern: java.util.regex.Pattern compile(java.lang.String)>("[^\\\\]\\$(\\d+)");
v.<org.apache.nifi.processors.standard.ReplaceTextWithMapping: java.util.regex.Pattern backReferencePattern> = v;
v = new java.util.concurrent.locks.ReentrantLock;
specialinvoke v.<java.util.concurrent.locks.ReentrantLock: void <init>()>();
v.<org.apache.nifi.processors.standard.ReplaceTextWithMapping: java.util.concurrent.locks.ReentrantLock processorLock> = v;
v = new java.util.concurrent.atomic.AtomicLong;
specialinvoke v.<java.util.concurrent.atomic.AtomicLong: void <init>(long)>(0L);
v.<org.apache.nifi.processors.standard.ReplaceTextWithMapping: java.util.concurrent.atomic.AtomicLong lastModified> = v;
v = new java.util.concurrent.atomic.AtomicLong;
specialinvoke v.<java.util.concurrent.atomic.AtomicLong: void <init>(long)>(0L);
v.<org.apache.nifi.processors.standard.ReplaceTextWithMapping: java.util.concurrent.atomic.AtomicLong mappingTestTime> = v;
v = new java.util.concurrent.atomic.AtomicReference;
v = new org.apache.nifi.processors.standard.ReplaceTextWithMapping$ConfigurationState;
specialinvoke v.<org.apache.nifi.processors.standard.ReplaceTextWithMapping$ConfigurationState: void <init>(java.util.Map)>(null);
specialinvoke v.<java.util.concurrent.atomic.AtomicReference: void <init>(java.lang.Object)>(v);
v.<org.apache.nifi.processors.standard.ReplaceTextWithMapping: java.util.concurrent.atomic.AtomicReference configurationStateRef> = v;
return;
}
protected java.util.Collection customValidate(org.apache.nifi.components.ValidationContext)
{
org.apache.nifi.processors.standard.ReplaceTextWithMapping v;
org.apache.nifi.components.ValidationContext v;
java.lang.Integer v;
org.apache.nifi.components.PropertyDescriptor v, v;
java.util.ArrayList v;
org.apache.nifi.components.PropertyValue v, v, v, v;
java.util.regex.Matcher v;
int v, v;
java.lang.String v;
org.apache.nifi.components.ValidationResult v;
org.apache.nifi.components.ValidationResult$Builder v, v, v, v;
java.util.Collection v;
java.util.regex.Pattern v;
v := @this: org.apache.nifi.processors.standard.ReplaceTextWithMapping;
v := @parameter: org.apache.nifi.components.ValidationContext;
v = new java.util.ArrayList;
v = specialinvoke v.<org.apache.nifi.processor.AbstractProcessor: java.util.Collection customValidate(org.apache.nifi.components.ValidationContext)>(v);
specialinvoke v.<java.util.ArrayList: void <init>(java.util.Collection)>(v);
v = <org.apache.nifi.processors.standard.ReplaceTextWithMapping: org.apache.nifi.components.PropertyDescriptor REGEX>;
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.PropertyValue evaluateAttributeExpressions()>();
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.String getValue()>();
v = staticinvoke <java.util.regex.Pattern: java.util.regex.Pattern compile(java.lang.String)>(v);
v = virtualinvoke v.<java.util.regex.Pattern: java.util.regex.Matcher matcher(java.lang.CharSequence)>("");
v = virtualinvoke v.<java.util.regex.Matcher: int groupCount()>();
v = <org.apache.nifi.processors.standard.ReplaceTextWithMapping: org.apache.nifi.components.PropertyDescriptor MATCHING_GROUP_FOR_LOOKUP_KEY>;
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.PropertyValue evaluateAttributeExpressions()>();
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.Integer asInteger()>();
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
if v <= v goto 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)>("Insufficient Matching Groups");
v = virtualinvoke v.<org.apache.nifi.components.ValidationResult$Builder: org.apache.nifi.components.ValidationResult$Builder valid(boolean)>(0);
v = virtualinvoke v.<org.apache.nifi.components.ValidationResult$Builder: org.apache.nifi.components.ValidationResult$Builder explanation(java.lang.String)>("The specified matching group does not exist for the regular expression provided");
v = virtualinvoke v.<org.apache.nifi.components.ValidationResult$Builder: org.apache.nifi.components.ValidationResult build()>();
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
label:
return v;
}
protected void init(org.apache.nifi.processor.ProcessorInitializationContext)
{
org.apache.nifi.processors.standard.ReplaceTextWithMapping v;
java.util.Set v;
org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v;
java.util.ArrayList v;
java.util.HashSet v;
java.util.List v;
org.apache.nifi.processor.Relationship v, v;
org.apache.nifi.processor.ProcessorInitializationContext v;
v := @this: org.apache.nifi.processors.standard.ReplaceTextWithMapping;
v := @parameter: org.apache.nifi.processor.ProcessorInitializationContext;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = <org.apache.nifi.processors.standard.ReplaceTextWithMapping: org.apache.nifi.components.PropertyDescriptor REGEX>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.ReplaceTextWithMapping: org.apache.nifi.components.PropertyDescriptor MATCHING_GROUP_FOR_LOOKUP_KEY>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.ReplaceTextWithMapping: org.apache.nifi.components.PropertyDescriptor MAPPING_FILE>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.ReplaceTextWithMapping: org.apache.nifi.components.PropertyDescriptor MAPPING_FILE_REFRESH_INTERVAL>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.ReplaceTextWithMapping: org.apache.nifi.components.PropertyDescriptor CHARACTER_SET>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.ReplaceTextWithMapping: org.apache.nifi.components.PropertyDescriptor MAX_BUFFER_SIZE>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = staticinvoke <java.util.Collections: java.util.List unmodifiableList(java.util.List)>(v);
v.<org.apache.nifi.processors.standard.ReplaceTextWithMapping: java.util.List properties> = v;
v = new java.util.HashSet;
specialinvoke v.<java.util.HashSet: void <init>()>();
v = <org.apache.nifi.processors.standard.ReplaceTextWithMapping: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.ReplaceTextWithMapping: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
v = staticinvoke <java.util.Collections: java.util.Set unmodifiableSet(java.util.Set)>(v);
v.<org.apache.nifi.processors.standard.ReplaceTextWithMapping: java.util.Set relationships> = v;
return;
}
protected java.util.List getSupportedPropertyDescriptors()
{
java.util.List v;
org.apache.nifi.processors.standard.ReplaceTextWithMapping v;
v := @this: org.apache.nifi.processors.standard.ReplaceTextWithMapping;
v = v.<org.apache.nifi.processors.standard.ReplaceTextWithMapping: java.util.List properties>;
return v;
}
public java.util.Set getRelationships()
{
java.util.Set v;
org.apache.nifi.processors.standard.ReplaceTextWithMapping v;
v := @this: org.apache.nifi.processors.standard.ReplaceTextWithMapping;
v = v.<org.apache.nifi.processors.standard.ReplaceTextWithMapping: java.util.Set relationships>;
return v;
}
public void onTrigger(org.apache.nifi.processor.ProcessContext, org.apache.nifi.processor.ProcessSession) throws org.apache.nifi.processor.exception.ProcessException
{
java.lang.Object[] v;
java.lang.Double v;
org.apache.nifi.processors.standard.ReplaceTextWithMapping v;
long v, v;
org.apache.nifi.logging.ComponentLog v;
org.apache.nifi.components.PropertyDescriptor v;
org.apache.nifi.components.PropertyValue v;
org.apache.nifi.provenance.ProvenanceReporter v;
byte v;
org.apache.nifi.processor.Relationship v, v;
int v;
boolean v, v;
java.util.Iterator v;
org.apache.nifi.flowfile.FlowFile v;
org.apache.nifi.processor.ProcessContext v;
org.apache.nifi.processor.ProcessSession v;
org.apache.nifi.processors.standard.ReplaceTextWithMapping$ReplaceTextCallback v;
java.util.concurrent.TimeUnit v;
java.util.List v;
org.apache.nifi.util.StopWatch v;
java.lang.Object v;
org.apache.nifi.processor.DataUnit v;
v := @this: org.apache.nifi.processors.standard.ReplaceTextWithMapping;
v := @parameter: org.apache.nifi.processor.ProcessContext;
v := @parameter: org.apache.nifi.processor.ProcessSession;
specialinvoke v.<org.apache.nifi.processors.standard.ReplaceTextWithMapping: void updateMapping(org.apache.nifi.processor.ProcessContext)>(v);
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: java.util.List get(int)>(5);
v = interfaceinvoke v.<java.util.List: boolean isEmpty()>();
if v == 0 goto label;
return;
label:
v = virtualinvoke v.<org.apache.nifi.processors.standard.ReplaceTextWithMapping: org.apache.nifi.logging.ComponentLog getLogger()>();
v = <org.apache.nifi.processors.standard.ReplaceTextWithMapping: 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 = interfaceinvoke v.<java.util.List: 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.<org.apache.nifi.flowfile.FlowFile: long getSize()>();
v = v cmp v;
if v <= 0 goto label;
v = <org.apache.nifi.processors.standard.ReplaceTextWithMapping: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void transfer(org.apache.nifi.flowfile.FlowFile,org.apache.nifi.processor.Relationship)>(v, v);
goto label;
label:
v = new org.apache.nifi.util.StopWatch;
specialinvoke v.<org.apache.nifi.util.StopWatch: void <init>(boolean)>(1);
v = new org.apache.nifi.processors.standard.ReplaceTextWithMapping$ReplaceTextCallback;
specialinvoke v.<org.apache.nifi.processors.standard.ReplaceTextWithMapping$ReplaceTextCallback: void <init>(org.apache.nifi.processors.standard.ReplaceTextWithMapping,org.apache.nifi.processor.ProcessContext,org.apache.nifi.flowfile.FlowFile,int)>(v, v, 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.StreamCallback)>(v, v);
v = newarray (java.lang.Object)[1];
v[0] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void info(java.lang.String,java.lang.Object[])>("Transferred {} to \'success\'", v);
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,long)>(v, v);
v = <org.apache.nifi.processors.standard.ReplaceTextWithMapping: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void transfer(org.apache.nifi.flowfile.FlowFile,org.apache.nifi.processor.Relationship)>(v, v);
goto label;
label:
return;
}
protected java.lang.String fillReplacementValueBackReferences(java.lang.String, int)
{
org.apache.nifi.processors.standard.ReplaceTextWithMapping v;
java.util.regex.Matcher v;
int v, v, v, v, v, v, v, v, v, v;
java.lang.String v, v, v, v, v, v;
boolean v;
java.lang.StringBuilder v;
java.util.regex.Pattern v;
v := @this: org.apache.nifi.processors.standard.ReplaceTextWithMapping;
v := @parameter: java.lang.String;
v := @parameter: int;
v = v;
v = v.<org.apache.nifi.processors.standard.ReplaceTextWithMapping: java.util.regex.Pattern backReferencePattern>;
v = virtualinvoke v.<java.util.regex.Pattern: java.util.regex.Matcher matcher(java.lang.CharSequence)>(v);
v = 0;
label:
v = virtualinvoke v.<java.util.regex.Matcher: boolean find()>();
if v == 0 goto label;
v = virtualinvoke v.<java.util.regex.Matcher: java.lang.String group(int)>(1);
v = staticinvoke <java.lang.Integer: int parseInt(java.lang.String)>(v);
if v > v goto label;
if v >= 0 goto label;
label:
v = new java.lang.StringBuilder;
v = virtualinvoke v.<java.lang.String: int length()>();
v = v + 1;
specialinvoke v.<java.lang.StringBuilder: void <init>(int)>(v);
v = virtualinvoke v.<java.util.regex.Matcher: int start(int)>(1);
v = v;
v = v + 1;
v = v + v;
v = v - 1;
v = virtualinvoke v.<java.lang.String: java.lang.String substring(int,int)>(0, v);
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>("\\");
v = v - 1;
v = virtualinvoke v.<java.lang.String: java.lang.String substring(int)>(v);
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.String toString()>();
goto label;
label:
v = virtualinvoke v.<java.lang.String: java.lang.String replaceAll(java.lang.String,java.lang.String)>("(\\$\\D)", "\\\\$1");
return v;
}
private void updateMapping(org.apache.nifi.processor.ProcessContext)
{
org.apache.nifi.processors.standard.ReplaceTextWithMapping v;
org.apache.nifi.processors.standard.ReplaceTextWithMapping$ConfigurationState v;
org.apache.nifi.components.PropertyDescriptor v, v;
org.apache.nifi.components.PropertyValue v, v;
byte v, v;
java.lang.Long v;
java.util.Map v;
boolean v, v, v, v, v;
java.lang.Exception v;
java.lang.Throwable v, v;
java.lang.Object[] v, v, v, v;
long v, v, v, v, v, v, v, v, v, v;
org.apache.nifi.logging.ComponentLog v;
java.util.concurrent.atomic.AtomicReference v;
java.lang.String v, v, v;
java.util.concurrent.locks.ReentrantLock v, v, v, v;
org.apache.nifi.processor.ProcessContext v;
java.io.IOException v;
java.io.FileInputStream v;
java.io.File v;
java.util.concurrent.TimeUnit v;
java.util.concurrent.atomic.AtomicLong v, v, v, v;
v := @this: org.apache.nifi.processors.standard.ReplaceTextWithMapping;
v := @parameter: org.apache.nifi.processor.ProcessContext;
v = v.<org.apache.nifi.processors.standard.ReplaceTextWithMapping: java.util.concurrent.locks.ReentrantLock processorLock>;
v = virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: boolean tryLock()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.nifi.processors.standard.ReplaceTextWithMapping: org.apache.nifi.logging.ComponentLog getLogger()>();
label:
v = staticinvoke <java.lang.System: long currentTimeMillis()>();
v = v / 1000L;
v = <org.apache.nifi.processors.standard.ReplaceTextWithMapping: org.apache.nifi.components.PropertyDescriptor MAPPING_FILE_REFRESH_INTERVAL>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit SECONDS>;
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.Long asTimePeriod(java.util.concurrent.TimeUnit)>(v);
v = virtualinvoke v.<java.lang.Long: long longValue()>();
v = v.<org.apache.nifi.processors.standard.ReplaceTextWithMapping: java.util.concurrent.atomic.AtomicLong mappingTestTime>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicLong: long get()>();
v = v + v;
v = v cmp v;
if v <= 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
if v == 0 goto label;
v = v.<org.apache.nifi.processors.standard.ReplaceTextWithMapping: java.util.concurrent.atomic.AtomicLong mappingTestTime>;
v = staticinvoke <java.lang.System: long currentTimeMillis()>();
v = v / 1000L;
virtualinvoke v.<java.util.concurrent.atomic.AtomicLong: void set(long)>(v);
v = <org.apache.nifi.processors.standard.ReplaceTextWithMapping: org.apache.nifi.components.PropertyDescriptor MAPPING_FILE>;
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 = new java.io.File;
specialinvoke v.<java.io.File: void <init>(java.lang.String)>(v);
v = virtualinvoke v.<java.io.File: boolean exists()>();
if v == 0 goto label;
v = virtualinvoke v.<java.io.File: boolean isFile()>();
if v == 0 goto label;
v = virtualinvoke v.<java.io.File: boolean canRead()>();
if v == 0 goto label;
v = virtualinvoke v.<java.io.File: long lastModified()>();
v = v.<org.apache.nifi.processors.standard.ReplaceTextWithMapping: java.util.concurrent.atomic.AtomicLong lastModified>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicLong: long get()>();
v = v cmp v;
if v <= 0 goto label;
v = v.<org.apache.nifi.processors.standard.ReplaceTextWithMapping: java.util.concurrent.atomic.AtomicLong lastModified>;
v = virtualinvoke v.<java.io.File: long lastModified()>();
virtualinvoke v.<java.util.concurrent.atomic.AtomicLong: long getAndSet(long)>(v);
label:
v = new java.io.FileInputStream;
specialinvoke v.<java.io.FileInputStream: void <init>(java.io.File)>(v);
label:
v = newarray (java.lang.Object)[1];
v[0] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void info(java.lang.String,java.lang.Object[])>("Reloading mapping file: {}", v);
v = virtualinvoke v.<org.apache.nifi.processors.standard.ReplaceTextWithMapping: java.util.Map loadMappingFile(java.io.InputStream)>(v);
v = new org.apache.nifi.processors.standard.ReplaceTextWithMapping$ConfigurationState;
specialinvoke v.<org.apache.nifi.processors.standard.ReplaceTextWithMapping$ConfigurationState: void <init>(java.util.Map)>(v);
v = v.<org.apache.nifi.processors.standard.ReplaceTextWithMapping: java.util.concurrent.atomic.AtomicReference configurationStateRef>;
virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: void set(java.lang.Object)>(v);
label:
virtualinvoke v.<java.io.FileInputStream: void close()>();
goto label;
label:
v := @caughtexception;
throw v;
label:
v := @caughtexception;
v = newarray (java.lang.Object)[1];
v = virtualinvoke v.<java.io.IOException: java.lang.String getMessage()>();
v[0] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void error(java.lang.String,java.lang.Object[])>("Error reading mapping file: {}", v);
goto label;
label:
v = newarray (java.lang.Object)[1];
v[0] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void error(java.lang.String,java.lang.Object[])>("Mapping file does not exist or is not readable: {}", v);
label:
v = v.<org.apache.nifi.processors.standard.ReplaceTextWithMapping: java.util.concurrent.locks.ReentrantLock processorLock>;
virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: void unlock()>();
goto label;
label:
v := @caughtexception;
v = newarray (java.lang.Object)[1];
v = virtualinvoke v.<java.lang.Exception: java.lang.String getMessage()>();
v[0] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void error(java.lang.String,java.lang.Object[])>("Error loading mapping file: {}", v);
label:
v = v.<org.apache.nifi.processors.standard.ReplaceTextWithMapping: java.util.concurrent.locks.ReentrantLock processorLock>;
virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: void unlock()>();
goto label;
label:
v := @caughtexception;
v = v.<org.apache.nifi.processors.standard.ReplaceTextWithMapping: java.util.concurrent.locks.ReentrantLock processorLock>;
virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: void unlock()>();
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
catch java.io.IOException from label to label with label;
catch java.lang.Exception from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
}
protected java.util.Map loadMappingFile(java.io.InputStream) throws java.io.IOException
{
org.apache.nifi.processors.standard.ReplaceTextWithMapping v;
java.lang.String[] v;
java.util.HashMap v;
java.io.InputStreamReader v;
int v, v;
java.io.BufferedReader v;
java.lang.String v, v, v, v, v, v, v;
java.io.InputStream v;
v := @this: org.apache.nifi.processors.standard.ReplaceTextWithMapping;
v := @parameter: java.io.InputStream;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v = new java.io.BufferedReader;
v = new java.io.InputStreamReader;
specialinvoke v.<java.io.InputStreamReader: void <init>(java.io.InputStream)>(v);
specialinvoke v.<java.io.BufferedReader: void <init>(java.io.Reader)>(v);
label:
v = virtualinvoke v.<java.io.BufferedReader: java.lang.String readLine()>();
if v == null goto label;
v = staticinvoke <org.apache.commons.lang.StringUtils: java.lang.String[] split(java.lang.String,java.lang.String,int)>(v, "\t ", 2);
v = lengthof v;
if v != 1 goto label;
v = v[0];
v = virtualinvoke v.<java.lang.String: java.lang.String trim()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, "");
goto label;
label:
v = lengthof v;
if v != 2 goto label;
v = v[0];
v = virtualinvoke v.<java.lang.String: java.lang.String trim()>();
v = v[1];
v = virtualinvoke v.<java.lang.String: java.lang.String trim()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
goto label;
label:
return v;
}
static void <clinit>()
{
org.apache.nifi.components.resource.ResourceType[] v;
org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, 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;
org.apache.nifi.components.resource.ResourceCardinality v;
org.apache.nifi.components.resource.ResourceType v;
org.apache.nifi.expression.ExpressionLanguageScope v, v;
org.apache.nifi.processor.Relationship v, v;
org.apache.nifi.components.Validator 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)>("Regular Expression");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("The Regular Expression to search for in the FlowFile content");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder required(boolean)>(1);
v = staticinvoke <org.apache.nifi.processor.util.StandardValidators: org.apache.nifi.components.Validator createRegexValidator(int,int,boolean)>(0, 2147483647, 1);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder addValidator(org.apache.nifi.components.Validator)>(v);
v = <org.apache.nifi.expression.ExpressionLanguageScope: org.apache.nifi.expression.ExpressionLanguageScope FLOWFILE_ATTRIBUTES>;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder expressionLanguageSupported(org.apache.nifi.expression.ExpressionLanguageScope)>(v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder defaultValue(java.lang.String)>("\\S+");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.ReplaceTextWithMapping: org.apache.nifi.components.PropertyDescriptor REGEX> = 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)>("Matching Group");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("The number of the matching group of the provided regex to replace with the corresponding value from the mapping file (if it exists).");
v = <org.apache.nifi.processor.util.StandardValidators: org.apache.nifi.components.Validator INTEGER_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 required(boolean)>(1);
v = <org.apache.nifi.expression.ExpressionLanguageScope: org.apache.nifi.expression.ExpressionLanguageScope VARIABLE_REGISTRY>;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder expressionLanguageSupported(org.apache.nifi.expression.ExpressionLanguageScope)>(v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder defaultValue(java.lang.String)>("0");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.ReplaceTextWithMapping: org.apache.nifi.components.PropertyDescriptor MATCHING_GROUP_FOR_LOOKUP_KEY> = 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)>("Mapping File");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("The name of the file (including the full path) containing the Mappings.");
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)[0];
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$Builder required(boolean)>(1);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.ReplaceTextWithMapping: org.apache.nifi.components.PropertyDescriptor MAPPING_FILE> = 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)>("Mapping File Refresh Interval");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("The polling interval in seconds to check for updates to the mapping file. The default is 60s.");
v = <org.apache.nifi.processor.util.StandardValidators: org.apache.nifi.components.Validator TIME_PERIOD_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 required(boolean)>(1);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder defaultValue(java.lang.String)>("60s");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.ReplaceTextWithMapping: org.apache.nifi.components.PropertyDescriptor MAPPING_FILE_REFRESH_INTERVAL> = 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.ReplaceTextWithMapping: 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 regular expressions. If a FlowFile is larger than this value, the FlowFile will be routed to \'failure\'");
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 = 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.ReplaceTextWithMapping: org.apache.nifi.components.PropertyDescriptor MAX_BUFFER_SIZE> = 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)>("success");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship$Builder description(java.lang.String)>("FlowFiles that have been successfully updated are routed to this relationship, as well as FlowFiles whose content does not match the given Regular Expression");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship build()>();
<org.apache.nifi.processors.standard.ReplaceTextWithMapping: org.apache.nifi.processor.Relationship REL_SUCCESS> = 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)>("failure");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship$Builder description(java.lang.String)>("FlowFiles that could not be updated are routed to this relationship");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship build()>();
<org.apache.nifi.processors.standard.ReplaceTextWithMapping: org.apache.nifi.processor.Relationship REL_FAILURE> = v;
return;
}
}