public class org.apache.nifi.processors.standard.LogAttribute extends org.apache.nifi.processor.AbstractProcessor
{
private static final org.apache.nifi.components.AllowableValue OUTPUT_FORMAT_LINE_PER_ATTRIBUTE;
private static final org.apache.nifi.components.AllowableValue OUTPUT_FORMAT_SINGLE_LINE;
public static final org.apache.nifi.components.PropertyDescriptor LOG_LEVEL;
public static final org.apache.nifi.components.PropertyDescriptor ATTRIBUTES_TO_LOG_CSV;
public static final org.apache.nifi.components.PropertyDescriptor ATTRIBUTES_TO_LOG_REGEX;
public static final org.apache.nifi.components.PropertyDescriptor ATTRIBUTES_TO_IGNORE_CSV;
public static final org.apache.nifi.components.PropertyDescriptor ATTRIBUTES_TO_IGNORE_REGEX;
public static final org.apache.nifi.components.PropertyDescriptor OUTPUT_FORMAT;
public static final org.apache.nifi.components.PropertyDescriptor LOG_PAYLOAD;
static final org.apache.nifi.components.PropertyDescriptor LOG_FLOWFILE_PROPERTIES;
public static final org.apache.nifi.components.PropertyDescriptor LOG_PREFIX;
public static final org.apache.nifi.components.PropertyDescriptor CHARSET;
public static final java.lang.String FIFTY_DASHES;
public static final long ONE_MB;
private java.util.Set relationships;
private java.util.List supportedDescriptors;
public static final org.apache.nifi.processor.Relationship REL_SUCCESS;
public void <init>()
{
org.apache.nifi.processors.standard.LogAttribute v;
v := @this: org.apache.nifi.processors.standard.LogAttribute;
specialinvoke v.<org.apache.nifi.processor.AbstractProcessor: void <init>()>();
return;
}
protected void init(org.apache.nifi.processor.ProcessorInitializationContext)
{
org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v, v, v, v, v;
java.util.ArrayList v;
java.util.HashSet v;
org.apache.nifi.processor.Relationship v;
java.util.Set v;
java.util.List v;
org.apache.nifi.processors.standard.LogAttribute v;
org.apache.nifi.processor.ProcessorInitializationContext v;
v := @this: org.apache.nifi.processors.standard.LogAttribute;
v := @parameter: org.apache.nifi.processor.ProcessorInitializationContext;
v = new java.util.HashSet;
specialinvoke v.<java.util.HashSet: void <init>()>();
v = <org.apache.nifi.processors.standard.LogAttribute: org.apache.nifi.processor.Relationship REL_SUCCESS>;
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.LogAttribute: java.util.Set relationships> = v;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = <org.apache.nifi.processors.standard.LogAttribute: org.apache.nifi.components.PropertyDescriptor LOG_LEVEL>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.LogAttribute: org.apache.nifi.components.PropertyDescriptor LOG_PAYLOAD>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.LogAttribute: org.apache.nifi.components.PropertyDescriptor ATTRIBUTES_TO_LOG_CSV>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.LogAttribute: org.apache.nifi.components.PropertyDescriptor ATTRIBUTES_TO_LOG_REGEX>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.LogAttribute: org.apache.nifi.components.PropertyDescriptor ATTRIBUTES_TO_IGNORE_CSV>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.LogAttribute: org.apache.nifi.components.PropertyDescriptor ATTRIBUTES_TO_IGNORE_REGEX>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.LogAttribute: org.apache.nifi.components.PropertyDescriptor LOG_FLOWFILE_PROPERTIES>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.LogAttribute: org.apache.nifi.components.PropertyDescriptor OUTPUT_FORMAT>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.LogAttribute: org.apache.nifi.components.PropertyDescriptor LOG_PREFIX>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.LogAttribute: org.apache.nifi.components.PropertyDescriptor CHARSET>;
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.LogAttribute: java.util.List supportedDescriptors> = v;
return;
}
public java.util.Set getRelationships()
{
java.util.Set v;
org.apache.nifi.processors.standard.LogAttribute v;
v := @this: org.apache.nifi.processors.standard.LogAttribute;
v = v.<org.apache.nifi.processors.standard.LogAttribute: java.util.Set relationships>;
return v;
}
protected java.util.List getSupportedPropertyDescriptors()
{
java.util.List v;
org.apache.nifi.processors.standard.LogAttribute v;
v := @this: org.apache.nifi.processors.standard.LogAttribute;
v = v.<org.apache.nifi.processors.standard.LogAttribute: java.util.List supportedDescriptors>;
return v;
}
protected java.lang.String processFlowFile(org.apache.nifi.logging.ComponentLog, org.apache.nifi.processors.standard.LogAttribute$DebugLevels, org.apache.nifi.flowfile.FlowFile, org.apache.nifi.processor.ProcessSession, org.apache.nifi.processor.ProcessContext)
{
org.apache.nifi.components.PropertyDescriptor v, v, v, v, v;
byte v;
java.lang.Long v;
java.util.Map v;
org.apache.nifi.processors.standard.LogAttribute$FlowFilePayloadCallback v;
java.util.Set v, v;
org.apache.nifi.components.AllowableValue v;
java.lang.StringBuilder v, v, v;
java.lang.Object[] v, v, v, v;
long v, v, v, v, v, v, v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.nifi.processor.ProcessSession v;
java.util.TreeMap v;
org.apache.nifi.processors.standard.LogAttribute v;
java.util.Date v, v, v, v;
org.apache.nifi.components.PropertyValue v, v, v, v, v, v, v;
int[] v;
boolean v, v, v, v, v, v;
org.apache.nifi.flowfile.FlowFile v;
org.apache.nifi.logging.ComponentLog v;
java.nio.charset.Charset v;
int v, v;
java.lang.Boolean v, v;
java.util.Iterator v, v;
org.apache.nifi.processor.ProcessContext v;
org.apache.nifi.processors.standard.LogAttribute$DebugLevels v;
java.lang.Object v, v;
v := @this: org.apache.nifi.processors.standard.LogAttribute;
v := @parameter: org.apache.nifi.logging.ComponentLog;
v := @parameter: org.apache.nifi.processors.standard.LogAttribute$DebugLevels;
v := @parameter: org.apache.nifi.flowfile.FlowFile;
v := @parameter: org.apache.nifi.processor.ProcessSession;
v := @parameter: org.apache.nifi.processor.ProcessContext;
v = interfaceinvoke v.<org.apache.nifi.flowfile.FlowFile: java.util.Map getAttributes()>();
v = interfaceinvoke v.<java.util.Map: java.util.Set keySet()>();
v = specialinvoke v.<org.apache.nifi.processors.standard.LogAttribute: java.util.Set getAttributesToLog(java.util.Set,org.apache.nifi.processor.ProcessContext)>(v, v);
v = <org.apache.nifi.processors.standard.LogAttribute: org.apache.nifi.components.PropertyDescriptor LOG_PREFIX>;
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(org.apache.nifi.flowfile.FlowFile)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.String getValue()>();
v = <org.apache.nifi.processors.standard.LogAttribute: org.apache.nifi.components.PropertyDescriptor CHARSET>;
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(org.apache.nifi.flowfile.FlowFile)>(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 = staticinvoke <org.eclipse.jetty.util.StringUtil: boolean isBlank(java.lang.String)>(v);
if v == 0 goto label;
v = staticinvoke <org.apache.commons.lang.StringUtils: java.lang.String repeat(char,int)>(45, 50);
goto label;
label:
v = staticinvoke <org.apache.commons.lang.StringUtils: java.lang.String abbreviate(java.lang.String,int)>(v, 40);
v = staticinvoke <org.apache.commons.lang.StringUtils: java.lang.String center(java.lang.String,int,char)>(v, 40, 45);
v = staticinvoke <org.apache.commons.lang.StringUtils: java.lang.String repeat(char,int)>(45, 5);
v = staticinvoke <org.apache.commons.lang.StringUtils: java.lang.String repeat(char,int)>(45, 5);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String,java.lang.String)>(v, v, 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[])>("\u0001\u0001\u0001");
label:
v = <org.apache.nifi.processors.standard.LogAttribute: org.apache.nifi.components.PropertyDescriptor OUTPUT_FORMAT>;
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.LogAttribute: org.apache.nifi.components.PropertyDescriptor LOG_FLOWFILE_PROPERTIES>;
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 = new java.lang.StringBuilder;
specialinvoke v.<java.lang.StringBuilder: void <init>()>();
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>("logging for flow file ");
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.Object)>(v);
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>("\n");
v = <org.apache.nifi.processors.standard.LogAttribute: org.apache.nifi.components.AllowableValue OUTPUT_FORMAT_LINE_PER_ATTRIBUTE>;
v = virtualinvoke v.<org.apache.nifi.components.AllowableValue: java.lang.String getValue()>();
v = virtualinvoke v.<java.lang.String: boolean equalsIgnoreCase(java.lang.String)>(v);
if v == 0 goto label;
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
if v == 0 goto label;
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>("\nFlowFile Properties");
v = newarray (java.lang.Object)[2];
v[0] = "entryDate";
v = new java.util.Date;
v = interfaceinvoke v.<org.apache.nifi.flowfile.FlowFile: long getEntryDate()>();
specialinvoke v.<java.util.Date: void <init>(long)>(v);
v[1] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("\nKey: \'%1$s\'\n\tValue: \'%2$s\'", v);
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
v = newarray (java.lang.Object)[2];
v[0] = "lineageStartDate";
v = new java.util.Date;
v = interfaceinvoke v.<org.apache.nifi.flowfile.FlowFile: long getLineageStartDate()>();
specialinvoke v.<java.util.Date: void <init>(long)>(v);
v[1] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("\nKey: \'%1$s\'\n\tValue: \'%2$s\'", v);
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
v = newarray (java.lang.Object)[2];
v[0] = "fileSize";
v = interfaceinvoke v.<org.apache.nifi.flowfile.FlowFile: long getSize()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v[1] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("\nKey: \'%1$s\'\n\tValue: \'%2$s\'", v);
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
label:
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>("\nFlowFile Attribute Map Content");
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 = newarray (java.lang.Object)[2];
v[0] = v;
v = interfaceinvoke v.<org.apache.nifi.flowfile.FlowFile: java.lang.String getAttribute(java.lang.String)>(v);
v[1] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("\nKey: \'%1$s\'\n\tValue: \'%2$s\'", v);
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
goto label;
label:
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>("\n");
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
goto label;
label:
v = new java.util.TreeMap;
specialinvoke v.<java.util.TreeMap: void <init>()>();
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.<org.apache.nifi.flowfile.FlowFile: java.lang.String getAttribute(java.lang.String)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
goto label;
label:
if v == 0 goto label;
v = new java.util.Date;
v = interfaceinvoke v.<org.apache.nifi.flowfile.FlowFile: long getEntryDate()>();
specialinvoke v.<java.util.Date: void <init>(long)>(v);
v = virtualinvoke v.<java.util.Date: java.lang.String toString()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("entryDate", v);
v = new java.util.Date;
v = interfaceinvoke v.<org.apache.nifi.flowfile.FlowFile: long getLineageStartDate()>();
specialinvoke v.<java.util.Date: void <init>(long)>(v);
v = virtualinvoke v.<java.util.Date: java.lang.String toString()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("lineageStartDate", v);
v = interfaceinvoke v.<org.apache.nifi.flowfile.FlowFile: long getSize()>();
v = staticinvoke <java.lang.String: java.lang.String valueOf(long)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("fileSize", v);
label:
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>("FlowFile Properties: ");
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.Object)>(v);
label:
v = <org.apache.nifi.processors.standard.LogAttribute: org.apache.nifi.components.PropertyDescriptor LOG_PAYLOAD>;
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()>();
if v == 0 goto label;
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>("\n");
v = interfaceinvoke v.<org.apache.nifi.flowfile.FlowFile: long getSize()>();
v = v cmp 1048576L;
if v >= 0 goto label;
v = new org.apache.nifi.processors.standard.LogAttribute$FlowFilePayloadCallback;
specialinvoke v.<org.apache.nifi.processors.standard.LogAttribute$FlowFilePayloadCallback: void <init>(java.nio.charset.Charset)>(v);
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void read(org.apache.nifi.flowfile.FlowFile,org.apache.nifi.processor.io.InputStreamCallback)>(v, v);
v = virtualinvoke v.<org.apache.nifi.processors.standard.LogAttribute$FlowFilePayloadCallback: java.lang.String getContents()>();
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
goto label;
label:
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>("\n Not including payload since it is larger than one mb.");
label:
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.String toString()>();
v = virtualinvoke v.<java.lang.String: java.lang.String trim()>();
v = <org.apache.nifi.processors.standard.LogAttribute$1: int[] $SwitchMap$org$apache$nifi$processors$standard$LogAttribute$DebugLevels>;
v = virtualinvoke v.<org.apache.nifi.processors.standard.LogAttribute$DebugLevels: int ordinal()>();
v = v[v];
tableswitch(v)
{
case 1: goto label;
case 2: goto label;
case 3: goto label;
case 4: goto label;
case 5: goto label;
default: goto label;
};
label:
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void info(java.lang.String)>(v);
goto label;
label:
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void debug(java.lang.String)>(v);
goto label;
label:
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void warn(java.lang.String)>(v);
goto label;
label:
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void trace(java.lang.String)>(v);
goto label;
label:
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void error(java.lang.String)>(v);
goto label;
label:
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void debug(java.lang.String)>(v);
label:
return v;
}
private java.util.Set getAttributesToLog(java.util.Set, org.apache.nifi.processor.ProcessContext)
{
org.apache.nifi.components.PropertyDescriptor v, v, v, v, v;
org.apache.nifi.components.PropertyValue v, v, v, v, v;
java.util.stream.Collector v;
boolean v, v;
java.util.function.Predicate v;
java.util.Set v;
java.util.List v, v;
java.util.stream.Stream v, v;
java.util.regex.Pattern v, v;
java.lang.String[] v, v;
java.util.function.Supplier v;
java.util.HashSet v, v, v, v;
java.lang.String v, v, v, v, v;
org.apache.nifi.processor.ProcessContext v;
java.lang.Object v;
org.apache.nifi.processors.standard.LogAttribute v;
v := @this: org.apache.nifi.processors.standard.LogAttribute;
v := @parameter: java.util.Set;
v := @parameter: org.apache.nifi.processor.ProcessContext;
v = <org.apache.nifi.processors.standard.LogAttribute: org.apache.nifi.components.PropertyDescriptor ATTRIBUTES_TO_LOG_CSV>;
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.LogAttribute: org.apache.nifi.components.PropertyDescriptor ATTRIBUTES_TO_IGNORE_CSV>;
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 <org.apache.commons.lang.StringUtils: boolean isBlank(java.lang.CharSequence)>(v);
if v == 0 goto label;
v = new java.util.HashSet;
specialinvoke v.<java.util.HashSet: void <init>(java.util.Collection)>(v);
goto label;
label:
v = new java.util.HashSet;
v = virtualinvoke v.<java.lang.String: java.lang.String[] split(java.lang.String)>("\\s*,\\s*");
v = staticinvoke <java.util.Arrays: java.util.List asList(java.lang.Object[])>(v);
specialinvoke v.<java.util.HashSet: void <init>(java.util.Collection)>(v);
label:
v = v;
v = staticinvoke <org.apache.commons.lang.StringUtils: boolean isBlank(java.lang.CharSequence)>(v);
if v == 0 goto label;
v = new java.util.HashSet;
specialinvoke v.<java.util.HashSet: void <init>()>();
goto label;
label:
v = new java.util.HashSet;
v = virtualinvoke v.<java.lang.String: java.lang.String[] split(java.lang.String)>("\\s*,\\s*");
v = staticinvoke <java.util.Arrays: java.util.List asList(java.lang.Object[])>(v);
specialinvoke v.<java.util.HashSet: void <init>(java.util.Collection)>(v);
label:
v = v;
v = <org.apache.nifi.processors.standard.LogAttribute: org.apache.nifi.components.PropertyDescriptor ATTRIBUTES_TO_LOG_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: java.lang.String getValue()>();
v = staticinvoke <java.util.regex.Pattern: java.util.regex.Pattern compile(java.lang.String)>(v);
v = <org.apache.nifi.processors.standard.LogAttribute: org.apache.nifi.components.PropertyDescriptor ATTRIBUTES_TO_IGNORE_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: java.lang.String getValue()>();
if v != null goto label;
v = null;
goto label;
label:
v = <org.apache.nifi.processors.standard.LogAttribute: org.apache.nifi.components.PropertyDescriptor ATTRIBUTES_TO_IGNORE_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: java.lang.String getValue()>();
v = staticinvoke <java.util.regex.Pattern: java.util.regex.Pattern compile(java.lang.String)>(v);
label:
v = interfaceinvoke v.<java.util.Set: java.util.stream.Stream stream()>();
v = staticinvoke <org.apache.nifi.processors.standard.LogAttribute$lambda_getAttributesToLog_0__135: java.util.function.Predicate bootstrap$(java.util.Set,java.util.regex.Pattern,java.util.Set,java.util.regex.Pattern)>(v, v, v, v);
v = interfaceinvoke v.<java.util.stream.Stream: java.util.stream.Stream filter(java.util.function.Predicate)>(v);
v = staticinvoke <org.apache.nifi.processors.standard.LogAttribute$init__136: java.util.function.Supplier bootstrap$()>();
v = staticinvoke <java.util.stream.Collectors: java.util.stream.Collector toCollection(java.util.function.Supplier)>(v);
v = interfaceinvoke v.<java.util.stream.Stream: java.lang.Object collect(java.util.stream.Collector)>(v);
return v;
}
private void transferChunk(org.apache.nifi.processor.ProcessSession)
{
java.util.List v;
org.apache.nifi.processor.Relationship v;
org.apache.nifi.processor.ProcessSession v;
org.apache.nifi.processors.standard.LogAttribute v;
boolean v;
v := @this: org.apache.nifi.processors.standard.LogAttribute;
v := @parameter: org.apache.nifi.processor.ProcessSession;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: java.util.List get(int)>(50);
v = interfaceinvoke v.<java.util.List: boolean isEmpty()>();
if v != 0 goto label;
v = <org.apache.nifi.processors.standard.LogAttribute: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void transfer(java.util.Collection,org.apache.nifi.processor.Relationship)>(v, v);
label:
return;
}
public void onTrigger(org.apache.nifi.processor.ProcessContext, org.apache.nifi.processor.ProcessSession)
{
org.apache.nifi.logging.ComponentLog v;
org.apache.nifi.components.PropertyDescriptor v;
org.apache.nifi.processor.exception.ProcessException v;
org.apache.nifi.components.PropertyValue v;
int[] v;
org.apache.nifi.processor.Relationship v;
int v, v;
java.lang.String v, v;
boolean v;
org.apache.nifi.flowfile.FlowFile v;
org.apache.nifi.processor.ProcessContext v;
org.apache.nifi.processor.ProcessSession v;
java.lang.Exception v;
org.apache.nifi.processors.standard.LogAttribute$DebugLevels v;
org.apache.nifi.processors.standard.LogAttribute v;
v := @this: org.apache.nifi.processors.standard.LogAttribute;
v := @parameter: org.apache.nifi.processor.ProcessContext;
v := @parameter: org.apache.nifi.processor.ProcessSession;
v = <org.apache.nifi.processors.standard.LogAttribute: org.apache.nifi.components.PropertyDescriptor LOG_LEVEL>;
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 = virtualinvoke v.<java.lang.String: java.lang.String toLowerCase()>();
label:
v = staticinvoke <org.apache.nifi.processors.standard.LogAttribute$DebugLevels: org.apache.nifi.processors.standard.LogAttribute$DebugLevels valueOf(java.lang.String)>(v);
label:
goto label;
label:
v := @caughtexception;
v = new org.apache.nifi.processor.exception.ProcessException;
specialinvoke v.<org.apache.nifi.processor.exception.ProcessException: void <init>(java.lang.Throwable)>(v);
throw v;
label:
v = virtualinvoke v.<org.apache.nifi.processors.standard.LogAttribute: org.apache.nifi.logging.ComponentLog getLogger()>();
v = 0;
v = <org.apache.nifi.processors.standard.LogAttribute$1: int[] $SwitchMap$org$apache$nifi$processors$standard$LogAttribute$DebugLevels>;
v = virtualinvoke v.<org.apache.nifi.processors.standard.LogAttribute$DebugLevels: int ordinal()>();
v = v[v];
tableswitch(v)
{
case 1: goto label;
case 2: goto label;
case 3: goto label;
case 4: goto label;
case 5: goto label;
default: goto label;
};
label:
v = interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: boolean isTraceEnabled()>();
goto label;
label:
v = interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: boolean isDebugEnabled()>();
goto label;
label:
v = interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: boolean isInfoEnabled()>();
goto label;
label:
v = interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: boolean isWarnEnabled()>();
goto label;
label:
v = interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: boolean isErrorEnabled()>();
label:
if v != 0 goto label;
specialinvoke v.<org.apache.nifi.processors.standard.LogAttribute: void transferChunk(org.apache.nifi.processor.ProcessSession)>(v);
return;
label:
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile get()>();
if v != null goto label;
return;
label:
virtualinvoke v.<org.apache.nifi.processors.standard.LogAttribute: java.lang.String processFlowFile(org.apache.nifi.logging.ComponentLog,org.apache.nifi.processors.standard.LogAttribute$DebugLevels,org.apache.nifi.flowfile.FlowFile,org.apache.nifi.processor.ProcessSession,org.apache.nifi.processor.ProcessContext)>(v, v, v, v, v);
v = <org.apache.nifi.processors.standard.LogAttribute: 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);
return;
catch java.lang.Exception from label to label with label;
}
static void <clinit>()
{
org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v, v, v, v, v;
org.apache.nifi.components.AllowableValue v, v, v, v, v;
org.apache.nifi.processors.standard.LogAttribute$DebugLevels[] v;
org.apache.nifi.processor.Relationship v;
java.lang.String 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, 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.expression.ExpressionLanguageScope v, v;
org.apache.nifi.components.AllowableValue[] v;
java.lang.String[] v, v;
java.nio.charset.Charset v;
org.apache.nifi.components.Validator v, v, v, v, v, v;
org.apache.nifi.processor.Relationship$Builder v, v, v;
v = new org.apache.nifi.components.AllowableValue;
specialinvoke v.<org.apache.nifi.components.AllowableValue: void <init>(java.lang.String,java.lang.String,java.lang.String)>("Line per Attribute", "Line per Attribute", "Each FlowFile attribute will be logged using a single line for the attribute name and another line for the attribute value. This format is often most advantageous when looking at the attributes of a single FlowFile.");
<org.apache.nifi.processors.standard.LogAttribute: org.apache.nifi.components.AllowableValue OUTPUT_FORMAT_LINE_PER_ATTRIBUTE> = v;
v = new org.apache.nifi.components.AllowableValue;
specialinvoke v.<org.apache.nifi.components.AllowableValue: void <init>(java.lang.String,java.lang.String,java.lang.String)>("Single Line", "Single Line", "All FlowFile attribute names and values will be logged on a single line. This format is often most advantageous when comparing logs from multiple FlowFiles.");
<org.apache.nifi.processors.standard.LogAttribute: org.apache.nifi.components.AllowableValue OUTPUT_FORMAT_SINGLE_LINE> = 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)>("Log Level");
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 description(java.lang.String)>("The Log Level to use when logging the Attributes");
v = staticinvoke <org.apache.nifi.processors.standard.LogAttribute$DebugLevels: org.apache.nifi.processors.standard.LogAttribute$DebugLevels[] values()>();
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder allowableValues(java.lang.Enum[])>(v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder defaultValue(java.lang.String)>("info");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.LogAttribute: org.apache.nifi.components.PropertyDescriptor LOG_LEVEL> = 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)>("Attributes to Log");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder required(boolean)>(0);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("A comma-separated list of Attributes to Log. If not specified, all attributes will be logged unless `Attributes to Log by Regular Expression` is modified. There\'s an AND relationship between the two properties.");
v = <org.apache.nifi.processor.util.StandardValidators: org.apache.nifi.components.Validator NON_EMPTY_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.LogAttribute: org.apache.nifi.components.PropertyDescriptor ATTRIBUTES_TO_LOG_CSV> = 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)>("attributes-to-log-regex");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder displayName(java.lang.String)>("Attributes to Log by Regular Expression");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder required(boolean)>(0);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder defaultValue(java.lang.String)>(".*");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("A regular expression indicating the Attributes to Log. If not specified, all attributes will be logged unless `Attributes to Log` is modified. There\'s an AND relationship between the two properties.");
v = <org.apache.nifi.processor.util.StandardValidators: org.apache.nifi.components.Validator REGULAR_EXPRESSION_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.LogAttribute: org.apache.nifi.components.PropertyDescriptor ATTRIBUTES_TO_LOG_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)>("Attributes to Ignore");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("A comma-separated list of Attributes to ignore. If not specified, no attributes will be ignored unless `Attributes to Ignore by Regular Expression` is modified. There\'s an OR relationship between the two properties.");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder required(boolean)>(0);
v = <org.apache.nifi.processor.util.StandardValidators: org.apache.nifi.components.Validator NON_EMPTY_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.LogAttribute: org.apache.nifi.components.PropertyDescriptor ATTRIBUTES_TO_IGNORE_CSV> = 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)>("attributes-to-ignore-regex");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder displayName(java.lang.String)>("Attributes to Ignore by Regular Expression");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder required(boolean)>(0);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("A regular expression indicating the Attributes to Ignore. If not specified, no attributes will be ignored unless `Attributes to Ignore` is modified. There\'s an OR relationship between the two properties.");
v = <org.apache.nifi.processor.util.StandardValidators: org.apache.nifi.components.Validator REGULAR_EXPRESSION_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.LogAttribute: org.apache.nifi.components.PropertyDescriptor ATTRIBUTES_TO_IGNORE_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)>("Output Format");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder displayName(java.lang.String)>("Output Format");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("Specifies the format to use for logging FlowFile attributes");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder required(boolean)>(1);
v = newarray (org.apache.nifi.components.AllowableValue)[2];
v = <org.apache.nifi.processors.standard.LogAttribute: org.apache.nifi.components.AllowableValue OUTPUT_FORMAT_LINE_PER_ATTRIBUTE>;
v[0] = v;
v = <org.apache.nifi.processors.standard.LogAttribute: org.apache.nifi.components.AllowableValue OUTPUT_FORMAT_SINGLE_LINE>;
v[1] = v;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder allowableValues(org.apache.nifi.components.AllowableValue[])>(v);
v = <org.apache.nifi.processors.standard.LogAttribute: org.apache.nifi.components.AllowableValue OUTPUT_FORMAT_LINE_PER_ATTRIBUTE>;
v = virtualinvoke v.<org.apache.nifi.components.AllowableValue: java.lang.String getValue()>();
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder defaultValue(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.LogAttribute: org.apache.nifi.components.PropertyDescriptor OUTPUT_FORMAT> = 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)>("Log Payload");
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 description(java.lang.String)>("If true, the FlowFile\'s payload will be logged, in addition to its attributes; otherwise, just the Attributes will be logged.");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder defaultValue(java.lang.String)>("false");
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 = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.LogAttribute: org.apache.nifi.components.PropertyDescriptor LOG_PAYLOAD> = 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)>("Log FlowFile Properties");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder displayName(java.lang.String)>("Log FlowFile Properties");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("Specifies whether or not to log FlowFile \"properties\", such as Entry Date, Lineage Start Date, and content size");
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 = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder defaultValue(java.lang.String)>("true");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.LogAttribute: org.apache.nifi.components.PropertyDescriptor LOG_FLOWFILE_PROPERTIES> = 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)>("Log prefix");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder required(boolean)>(0);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("Log prefix appended to the log lines. It helps to distinguish the output of multiple LogAttribute processors.");
v = <org.apache.nifi.processor.util.StandardValidators: org.apache.nifi.components.Validator NON_EMPTY_VALIDATOR>;
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 build()>();
<org.apache.nifi.processors.standard.LogAttribute: org.apache.nifi.components.PropertyDescriptor LOG_PREFIX> = 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 displayName(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 name of the CharacterSet to use");
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 = <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 = staticinvoke <java.nio.charset.Charset: java.nio.charset.Charset defaultCharset()>();
v = virtualinvoke v.<java.nio.charset.Charset: java.lang.String name()>();
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder defaultValue(java.lang.String)>(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.LogAttribute: org.apache.nifi.components.PropertyDescriptor CHARSET> = 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)>("All FlowFiles 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.LogAttribute: org.apache.nifi.processor.Relationship REL_SUCCESS> = v;
return;
}
}