final class org.apache.nifi.processors.standard.ReplaceTextWithMapping$ReplaceTextCallback extends java.lang.Object implements org.apache.nifi.processor.io.StreamCallback
{
private final java.nio.charset.Charset charset;
private final byte[] buffer;
private final java.lang.String regex;
private final org.apache.nifi.flowfile.FlowFile flowFile;
private final int numCapturingGroups;
private final int groupToMatch;
private final org.apache.nifi.expression.AttributeValueDecorator quotedAttributeDecorator;
final org.apache.nifi.processors.standard.ReplaceTextWithMapping this$0;
private void <init>(org.apache.nifi.processors.standard.ReplaceTextWithMapping, org.apache.nifi.processor.ProcessContext, org.apache.nifi.flowfile.FlowFile, int)
{
byte[] v;
org.apache.nifi.processors.standard.ReplaceTextWithMapping v;
org.apache.nifi.processors.standard.ReplaceTextWithMapping$ReplaceTextCallback$1 v;
java.lang.Integer v;
org.apache.nifi.components.PropertyDescriptor v, v, v, v;
org.apache.nifi.components.PropertyValue v, v, v, v, v, v, v;
java.util.regex.Matcher v;
java.nio.charset.Charset v;
int v, v, v;
java.lang.String v, v, v;
org.apache.nifi.flowfile.FlowFile v;
org.apache.nifi.processor.ProcessContext v;
org.apache.nifi.expression.AttributeValueDecorator v;
org.apache.nifi.processors.standard.ReplaceTextWithMapping$ReplaceTextCallback v;
java.util.regex.Pattern v;
v := @this: org.apache.nifi.processors.standard.ReplaceTextWithMapping$ReplaceTextCallback;
v := @parameter: org.apache.nifi.processors.standard.ReplaceTextWithMapping;
v := @parameter: org.apache.nifi.processor.ProcessContext;
v := @parameter: org.apache.nifi.flowfile.FlowFile;
v := @parameter: int;
v.<org.apache.nifi.processors.standard.ReplaceTextWithMapping$ReplaceTextCallback: org.apache.nifi.processors.standard.ReplaceTextWithMapping this$0> = v;
specialinvoke v.<java.lang.Object: void <init>()>();
v = new org.apache.nifi.processors.standard.ReplaceTextWithMapping$ReplaceTextCallback$1;
specialinvoke v.<org.apache.nifi.processors.standard.ReplaceTextWithMapping$ReplaceTextCallback$1: void <init>(org.apache.nifi.processors.standard.ReplaceTextWithMapping$ReplaceTextCallback)>(v);
v.<org.apache.nifi.processors.standard.ReplaceTextWithMapping$ReplaceTextCallback: org.apache.nifi.expression.AttributeValueDecorator quotedAttributeDecorator> = v;
v = <org.apache.nifi.processors.standard.ReplaceTextWithMapping: org.apache.nifi.components.PropertyDescriptor REGEX>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = v.<org.apache.nifi.processors.standard.ReplaceTextWithMapping$ReplaceTextCallback: org.apache.nifi.expression.AttributeValueDecorator quotedAttributeDecorator>;
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: org.apache.nifi.components.PropertyValue evaluateAttributeExpressions(org.apache.nifi.flowfile.FlowFile,org.apache.nifi.expression.AttributeValueDecorator)>(v, v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.String getValue()>();
v.<org.apache.nifi.processors.standard.ReplaceTextWithMapping$ReplaceTextCallback: java.lang.String regex> = v;
v.<org.apache.nifi.processors.standard.ReplaceTextWithMapping$ReplaceTextCallback: org.apache.nifi.flowfile.FlowFile flowFile> = v;
v = <org.apache.nifi.processors.standard.ReplaceTextWithMapping: 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.<org.apache.nifi.processors.standard.ReplaceTextWithMapping$ReplaceTextCallback: java.nio.charset.Charset charset> = v;
v = <org.apache.nifi.processors.standard.ReplaceTextWithMapping: org.apache.nifi.components.PropertyDescriptor REGEX>;
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.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$ReplaceTextCallback: int numCapturingGroups> = v;
v = newarray (byte)[v];
v.<org.apache.nifi.processors.standard.ReplaceTextWithMapping$ReplaceTextCallback: byte[] buffer> = v;
v = <org.apache.nifi.processors.standard.ReplaceTextWithMapping: org.apache.nifi.components.PropertyDescriptor MATCHING_GROUP_FOR_LOOKUP_KEY>;
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.PropertyValue evaluateAttributeExpressions()>();
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.Integer asInteger()>();
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v.<org.apache.nifi.processors.standard.ReplaceTextWithMapping$ReplaceTextCallback: int groupToMatch> = v;
return;
}
public void process(java.io.InputStream, java.io.OutputStream) throws java.io.IOException
{
byte[] v, v, v, v;
org.apache.nifi.processors.standard.ReplaceTextWithMapping v, v;
java.util.regex.Matcher v;
java.util.Map v;
boolean v, v;
org.apache.nifi.flowfile.FlowFile v;
org.apache.nifi.processors.standard.ReplaceTextWithMapping$ReplaceTextCallback v;
java.lang.StringBuilder v;
java.util.regex.Pattern v;
long v;
java.util.concurrent.atomic.AtomicReference v;
java.nio.charset.Charset v, v, v;
java.lang.StringBuffer v;
int v, v, v, v, v, v, v, v, v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.io.OutputStream v;
java.lang.Object v, v;
java.io.InputStream v;
v := @this: org.apache.nifi.processors.standard.ReplaceTextWithMapping$ReplaceTextCallback;
v := @parameter: java.io.InputStream;
v := @parameter: java.io.OutputStream;
v = v.<org.apache.nifi.processors.standard.ReplaceTextWithMapping$ReplaceTextCallback: org.apache.nifi.processors.standard.ReplaceTextWithMapping this$0>;
v = v.<org.apache.nifi.processors.standard.ReplaceTextWithMapping: java.util.concurrent.atomic.AtomicReference configurationStateRef>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: java.lang.Object get()>();
v = virtualinvoke v.<org.apache.nifi.processors.standard.ReplaceTextWithMapping$ConfigurationState: java.util.Map getMapping()>();
v = v.<org.apache.nifi.processors.standard.ReplaceTextWithMapping$ReplaceTextCallback: byte[] buffer>;
staticinvoke <org.apache.nifi.stream.io.StreamUtils: int fillBuffer(java.io.InputStream,byte[],boolean)>(v, v, 0);
v = v.<org.apache.nifi.processors.standard.ReplaceTextWithMapping$ReplaceTextCallback: org.apache.nifi.flowfile.FlowFile flowFile>;
v = interfaceinvoke v.<org.apache.nifi.flowfile.FlowFile: long getSize()>();
v = new java.lang.String;
v = v.<org.apache.nifi.processors.standard.ReplaceTextWithMapping$ReplaceTextCallback: byte[] buffer>;
v = v.<org.apache.nifi.processors.standard.ReplaceTextWithMapping$ReplaceTextCallback: java.nio.charset.Charset charset>;
specialinvoke v.<java.lang.String: void <init>(byte[],int,int,java.nio.charset.Charset)>(v, 0, v, v);
v = v.<org.apache.nifi.processors.standard.ReplaceTextWithMapping$ReplaceTextCallback: java.lang.String regex>;
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: java.util.regex.Matcher reset()>();
v = virtualinvoke v.<java.util.regex.Matcher: boolean find()>();
if v == 0 goto label;
v = new java.lang.StringBuffer;
specialinvoke v.<java.lang.StringBuffer: void <init>()>();
label:
v = v.<org.apache.nifi.processors.standard.ReplaceTextWithMapping$ReplaceTextCallback: int groupToMatch>;
v = virtualinvoke v.<java.util.regex.Matcher: java.lang.String group(int)>(v);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
if v != null goto label;
v = virtualinvoke v.<java.util.regex.Matcher: java.lang.String group()>();
v = virtualinvoke v.<java.lang.String: java.lang.String replace(java.lang.CharSequence,java.lang.CharSequence)>("$", "\\$");
virtualinvoke v.<java.util.regex.Matcher: java.util.regex.Matcher appendReplacement(java.lang.StringBuffer,java.lang.String)>(v, v);
goto label;
label:
v = virtualinvoke v.<java.util.regex.Matcher: java.lang.String group()>();
v = v.<org.apache.nifi.processors.standard.ReplaceTextWithMapping$ReplaceTextCallback: int groupToMatch>;
v = virtualinvoke v.<java.util.regex.Matcher: int start(int)>(v);
v = virtualinvoke v.<java.util.regex.Matcher: int start()>();
v = v - v;
v = v.<org.apache.nifi.processors.standard.ReplaceTextWithMapping$ReplaceTextCallback: int groupToMatch>;
v = virtualinvoke v.<java.util.regex.Matcher: java.lang.String group(int)>(v);
v = virtualinvoke v.<java.lang.String: int length()>();
v = v + v;
v = new java.lang.StringBuilder;
specialinvoke v.<java.lang.StringBuilder: void <init>()>();
v = virtualinvoke v.<java.lang.String: java.lang.String substring(int,int)>(0, v);
v = virtualinvoke v.<java.lang.String: java.lang.String replace(java.lang.CharSequence,java.lang.CharSequence)>("$", "\\$");
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
v = v.<org.apache.nifi.processors.standard.ReplaceTextWithMapping$ReplaceTextCallback: org.apache.nifi.processors.standard.ReplaceTextWithMapping this$0>;
v = v.<org.apache.nifi.processors.standard.ReplaceTextWithMapping$ReplaceTextCallback: int numCapturingGroups>;
v = virtualinvoke v.<org.apache.nifi.processors.standard.ReplaceTextWithMapping: java.lang.String fillReplacementValueBackReferences(java.lang.String,int)>(v, v);
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
v = virtualinvoke v.<java.lang.String: java.lang.String substring(int)>(v);
v = virtualinvoke v.<java.lang.String: java.lang.String replace(java.lang.CharSequence,java.lang.CharSequence)>("$", "\\$");
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.String toString()>();
virtualinvoke v.<java.util.regex.Matcher: java.util.regex.Matcher appendReplacement(java.lang.StringBuffer,java.lang.String)>(v, v);
label:
v = virtualinvoke v.<java.util.regex.Matcher: boolean find()>();
if v != 0 goto label;
virtualinvoke v.<java.util.regex.Matcher: java.lang.StringBuffer appendTail(java.lang.StringBuffer)>(v);
v = virtualinvoke v.<java.lang.StringBuffer: java.lang.String toString()>();
v = v.<org.apache.nifi.processors.standard.ReplaceTextWithMapping$ReplaceTextCallback: java.nio.charset.Charset charset>;
v = virtualinvoke v.<java.lang.String: byte[] getBytes(java.nio.charset.Charset)>(v);
virtualinvoke v.<java.io.OutputStream: void write(byte[])>(v);
return;
label:
v = v.<org.apache.nifi.processors.standard.ReplaceTextWithMapping$ReplaceTextCallback: java.nio.charset.Charset charset>;
v = virtualinvoke v.<java.lang.String: byte[] getBytes(java.nio.charset.Charset)>(v);
virtualinvoke v.<java.io.OutputStream: void write(byte[])>(v);
return;
}
}