public class org.apache.nifi.processors.standard.AttributesToCSV extends org.apache.nifi.processor.AbstractProcessor
{
private static final java.lang.String DATA_ATTRIBUTE_NAME;
private static final java.lang.String SCHEMA_ATTRIBUTE_NAME;
private static final java.lang.String OUTPUT_SEPARATOR;
private static final java.lang.String OUTPUT_MIME_TYPE;
private static final java.lang.String SPLIT_REGEX;
static final org.apache.nifi.components.AllowableValue OUTPUT_OVERWRITE_CONTENT;
static final org.apache.nifi.components.AllowableValue OUTPUT_NEW_ATTRIBUTE;
public static final org.apache.nifi.components.PropertyDescriptor ATTRIBUTES_LIST;
public static final org.apache.nifi.components.PropertyDescriptor ATTRIBUTES_REGEX;
public static final org.apache.nifi.components.PropertyDescriptor DESTINATION;
public static final org.apache.nifi.components.PropertyDescriptor INCLUDE_CORE_ATTRIBUTES;
public static final org.apache.nifi.components.PropertyDescriptor NULL_VALUE_FOR_EMPTY_STRING;
public static final org.apache.nifi.components.PropertyDescriptor INCLUDE_SCHEMA;
public static final org.apache.nifi.processor.Relationship REL_SUCCESS;
public static final org.apache.nifi.processor.Relationship REL_FAILURE;
private java.util.List properties;
private java.util.Set relationships;
private volatile java.lang.Boolean includeCoreAttributes;
private volatile java.util.Set coreAttributes;
private volatile boolean destinationContent;
private volatile boolean nullValForEmptyString;
private volatile java.util.regex.Pattern pattern;
private volatile java.lang.Boolean includeSchema;
public void <init>()
{
org.apache.nifi.processors.standard.AttributesToCSV v;
v := @this: org.apache.nifi.processors.standard.AttributesToCSV;
specialinvoke v.<org.apache.nifi.processor.AbstractProcessor: void <init>()>();
return;
}
protected void init(org.apache.nifi.processor.ProcessorInitializationContext)
{
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.processors.standard.AttributesToCSV v;
org.apache.nifi.processor.ProcessorInitializationContext v;
v := @this: org.apache.nifi.processors.standard.AttributesToCSV;
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.AttributesToCSV: org.apache.nifi.components.PropertyDescriptor ATTRIBUTES_LIST>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.AttributesToCSV: org.apache.nifi.components.PropertyDescriptor ATTRIBUTES_REGEX>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.AttributesToCSV: org.apache.nifi.components.PropertyDescriptor DESTINATION>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.AttributesToCSV: org.apache.nifi.components.PropertyDescriptor INCLUDE_CORE_ATTRIBUTES>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.AttributesToCSV: org.apache.nifi.components.PropertyDescriptor NULL_VALUE_FOR_EMPTY_STRING>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.AttributesToCSV: org.apache.nifi.components.PropertyDescriptor INCLUDE_SCHEMA>;
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.AttributesToCSV: java.util.List properties> = v;
v = new java.util.HashSet;
specialinvoke v.<java.util.HashSet: void <init>()>();
v = <org.apache.nifi.processors.standard.AttributesToCSV: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.AttributesToCSV: 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.AttributesToCSV: java.util.Set relationships> = v;
return;
}
protected java.util.List getSupportedPropertyDescriptors()
{
java.util.List v;
org.apache.nifi.processors.standard.AttributesToCSV v;
v := @this: org.apache.nifi.processors.standard.AttributesToCSV;
v = v.<org.apache.nifi.processors.standard.AttributesToCSV: java.util.List properties>;
return v;
}
public java.util.Set getRelationships()
{
java.util.Set v;
org.apache.nifi.processors.standard.AttributesToCSV v;
v := @this: org.apache.nifi.processors.standard.AttributesToCSV;
v = v.<org.apache.nifi.processors.standard.AttributesToCSV: java.util.Set relationships>;
return v;
}
private java.util.Map buildAttributesMapForFlowFile(org.apache.nifi.flowfile.FlowFile, java.util.Set, java.util.regex.Pattern)
{
java.util.regex.Matcher v;
java.util.Map v, v;
boolean v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.nifi.flowfile.FlowFile v;
java.util.Set v, v, v, v;
java.util.regex.Pattern v;
java.util.LinkedHashMap v;
int v;
java.lang.Boolean v;
org.apache.nifi.processors.standard.AttributesToCSV v;
java.lang.String v, v;
java.util.Iterator v, v, v, v;
java.lang.Object v, v, v, v, v, v, v;
v := @this: org.apache.nifi.processors.standard.AttributesToCSV;
v := @parameter: org.apache.nifi.flowfile.FlowFile;
v := @parameter: java.util.Set;
v := @parameter: java.util.regex.Pattern;
v = interfaceinvoke v.<org.apache.nifi.flowfile.FlowFile: java.util.Map getAttributes()>();
v = new java.util.LinkedHashMap;
v = interfaceinvoke v.<java.util.Map: int size()>();
specialinvoke v.<java.util.LinkedHashMap: void <init>(int)>(v);
v = interfaceinvoke v.<java.util.Set: boolean isEmpty()>();
if v == 0 goto label;
if v == null goto label;
label:
v = interfaceinvoke v.<java.util.Set: boolean isEmpty()>();
if v != 0 goto label;
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);
if v == null goto label;
v = virtualinvoke v.<java.lang.String: boolean isEmpty()>();
if v != 0 goto label;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
goto label;
label:
v = v.<org.apache.nifi.processors.standard.AttributesToCSV: boolean nullValForEmptyString>;
if v == 0 goto label;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, "null");
goto label;
label:
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, "");
goto label;
label:
if v == null goto label;
v = interfaceinvoke v.<org.apache.nifi.flowfile.FlowFile: java.util.Map getAttributes()>();
v = interfaceinvoke v.<java.util.Map: java.util.Set entrySet()>();
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getKey()>();
v = virtualinvoke v.<java.util.regex.Pattern: java.util.regex.Matcher matcher(java.lang.CharSequence)>(v);
v = virtualinvoke v.<java.util.regex.Matcher: boolean matches()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getKey()>();
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
goto label;
label:
interfaceinvoke v.<java.util.Map: void putAll(java.util.Map)>(v);
label:
v = v.<org.apache.nifi.processors.standard.AttributesToCSV: java.lang.Boolean includeCoreAttributes>;
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
if v == 0 goto label;
v = v.<org.apache.nifi.processors.standard.AttributesToCSV: java.util.Set coreAttributes>;
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);
v = interfaceinvoke v.<java.util.Map: boolean containsKey(java.lang.Object)>(v);
if v == 0 goto label;
v = staticinvoke <org.apache.commons.lang.StringUtils: boolean isEmpty(java.lang.CharSequence)>(v);
if v != 0 goto label;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
goto label;
label:
v = v.<org.apache.nifi.processors.standard.AttributesToCSV: boolean nullValForEmptyString>;
if v == 0 goto label;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, "null");
goto label;
label:
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, "");
goto label;
label:
v = v.<org.apache.nifi.processors.standard.AttributesToCSV: java.util.Set coreAttributes>;
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = interfaceinvoke v.<java.util.Set: boolean contains(java.lang.Object)>(v);
if v != 0 goto label;
interfaceinvoke v.<java.util.Map: java.lang.Object remove(java.lang.Object)>(v);
goto label;
label:
return v;
}
private java.util.LinkedHashSet attributeListStringToSet(java.lang.String)
{
java.lang.String[] v;
int v, v;
org.apache.nifi.processors.standard.AttributesToCSV v;
java.lang.String v, v, v, v;
java.util.LinkedHashSet v;
boolean v;
v := @this: org.apache.nifi.processors.standard.AttributesToCSV;
v := @parameter: java.lang.String;
v = new java.util.LinkedHashSet;
specialinvoke v.<java.util.LinkedHashSet: void <init>()>();
v = staticinvoke <org.apache.commons.lang.StringUtils: boolean isNotBlank(java.lang.CharSequence)>(v);
if v == 0 goto label;
v = virtualinvoke v.<java.lang.String: java.lang.String[] split(java.lang.String)>(",(?=(?:[^\"]*\"[^\"]*\")*[^\"]*$)");
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = virtualinvoke v.<java.lang.String: java.lang.String trim()>();
v = staticinvoke <org.apache.commons.text.StringEscapeUtils: java.lang.String unescapeCsv(java.lang.String)>(v);
virtualinvoke v.<java.util.LinkedHashSet: boolean add(java.lang.Object)>(v);
v = v + 1;
goto label;
label:
return v;
}
public void onScheduled(org.apache.nifi.processor.ProcessContext)
{
java.util.function.Function v;
java.util.function.Supplier v;
org.apache.nifi.components.PropertyDescriptor v, v, v, v;
org.apache.nifi.components.PropertyValue v, v, v, v;
java.lang.Boolean v, v, v;
org.apache.nifi.processors.standard.AttributesToCSV v;
java.lang.String v, v;
java.util.stream.Collector v;
boolean v, v;
org.apache.nifi.processor.ProcessContext v;
org.apache.nifi.flowfile.attributes.CoreAttributes[] v;
org.apache.nifi.components.AllowableValue v;
java.util.stream.Stream v, v;
java.lang.Object v;
v := @this: org.apache.nifi.processors.standard.AttributesToCSV;
v := @parameter: org.apache.nifi.processor.ProcessContext;
v = <org.apache.nifi.processors.standard.AttributesToCSV: org.apache.nifi.components.PropertyDescriptor INCLUDE_CORE_ATTRIBUTES>;
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.<org.apache.nifi.processors.standard.AttributesToCSV: java.lang.Boolean includeCoreAttributes> = v;
v = staticinvoke <org.apache.nifi.flowfile.attributes.CoreAttributes: org.apache.nifi.flowfile.attributes.CoreAttributes[] values()>();
v = staticinvoke <java.util.Arrays: java.util.stream.Stream stream(java.lang.Object[])>(v);
v = staticinvoke <org.apache.nifi.processors.standard.AttributesToCSV$key__13: java.util.function.Function bootstrap$()>();
v = interfaceinvoke v.<java.util.stream.Stream: java.util.stream.Stream map(java.util.function.Function)>(v);
v = staticinvoke <org.apache.nifi.processors.standard.AttributesToCSV$init__14: 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);
v.<org.apache.nifi.processors.standard.AttributesToCSV: java.util.Set coreAttributes> = v;
v = <org.apache.nifi.processors.standard.AttributesToCSV: org.apache.nifi.components.AllowableValue OUTPUT_OVERWRITE_CONTENT>;
v = virtualinvoke v.<org.apache.nifi.components.AllowableValue: java.lang.String getValue()>();
v = <org.apache.nifi.processors.standard.AttributesToCSV: org.apache.nifi.components.PropertyDescriptor DESTINATION>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.String getValue()>();
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
v.<org.apache.nifi.processors.standard.AttributesToCSV: boolean destinationContent> = v;
v = <org.apache.nifi.processors.standard.AttributesToCSV: org.apache.nifi.components.PropertyDescriptor NULL_VALUE_FOR_EMPTY_STRING>;
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.<org.apache.nifi.processors.standard.AttributesToCSV: boolean nullValForEmptyString> = v;
v = <org.apache.nifi.processors.standard.AttributesToCSV: org.apache.nifi.components.PropertyDescriptor INCLUDE_SCHEMA>;
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.<org.apache.nifi.processors.standard.AttributesToCSV: java.lang.Boolean includeSchema> = v;
return;
}
public void onTrigger(org.apache.nifi.processor.ProcessContext, org.apache.nifi.processor.ProcessSession) throws org.apache.nifi.processor.exception.ProcessException
{
org.apache.nifi.components.PropertyDescriptor v, v, v;
org.apache.nifi.components.PropertyValue v, v, v, v, v;
java.util.Map v;
boolean v, v, v, v, v, v;
org.apache.nifi.flowfile.FlowFile v, v, v, v;
java.util.Collection v;
java.util.Set v, v;
java.lang.Exception v;
java.lang.StringBuilder v, v;
java.util.regex.Pattern v, v;
org.apache.nifi.processor.io.StreamCallback v;
org.apache.nifi.logging.ComponentLog v;
org.apache.nifi.processor.Relationship v, v, v;
int v, v, v, v, v, v;
java.lang.Boolean v, v;
org.apache.nifi.processors.standard.AttributesToCSV v;
java.lang.String v, v, v, v, v, v, v, v, v, v;
java.util.LinkedHashSet v;
java.util.Iterator v, v;
org.apache.nifi.processor.ProcessContext v;
org.apache.nifi.processor.ProcessSession v;
java.lang.Object v, v, v, v;
org.apache.nifi.flowfile.attributes.CoreAttributes v;
v := @this: org.apache.nifi.processors.standard.AttributesToCSV;
v := @parameter: org.apache.nifi.processor.ProcessContext;
v := @parameter: org.apache.nifi.processor.ProcessSession;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile get()>();
if v != null goto label;
return;
label:
v = <org.apache.nifi.processors.standard.AttributesToCSV: org.apache.nifi.components.PropertyDescriptor ATTRIBUTES_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: boolean isSet()>();
if v == 0 goto label;
v = <org.apache.nifi.processors.standard.AttributesToCSV: org.apache.nifi.components.PropertyDescriptor ATTRIBUTES_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(org.apache.nifi.flowfile.FlowFile)>(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.AttributesToCSV: java.util.regex.Pattern pattern> = v;
label:
v = <org.apache.nifi.processors.standard.AttributesToCSV: org.apache.nifi.components.PropertyDescriptor ATTRIBUTES_LIST>;
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 = specialinvoke v.<org.apache.nifi.processors.standard.AttributesToCSV: java.util.LinkedHashSet attributeListStringToSet(java.lang.String)>(v);
v = v.<org.apache.nifi.processors.standard.AttributesToCSV: java.util.regex.Pattern pattern>;
v = specialinvoke v.<org.apache.nifi.processors.standard.AttributesToCSV: java.util.Map buildAttributesMapForFlowFile(org.apache.nifi.flowfile.FlowFile,java.util.Set,java.util.regex.Pattern)>(v, v, v);
v = 0;
v = interfaceinvoke v.<java.util.Map: java.util.Collection values()>();
v = interfaceinvoke v.<java.util.Collection: int size()>();
v = v - 1;
v = new java.lang.StringBuilder;
specialinvoke v.<java.lang.StringBuilder: void <init>()>();
v = interfaceinvoke v.<java.util.Map: java.util.Set entrySet()>();
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
v = staticinvoke <org.apache.commons.text.StringEscapeUtils: java.lang.String escapeCsv(java.lang.String)>(v);
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
v = v;
v = v + 1;
if v >= v goto label;
v = ",";
goto label;
label:
v = "";
label:
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
goto label;
label:
v = new java.lang.StringBuilder;
specialinvoke v.<java.lang.StringBuilder: void <init>()>();
v = v.<org.apache.nifi.processors.standard.AttributesToCSV: java.lang.Boolean includeSchema>;
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
if v == 0 goto label;
v = 0;
v = interfaceinvoke v.<java.util.Map: java.util.Set entrySet()>();
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getKey()>();
v = staticinvoke <org.apache.commons.text.StringEscapeUtils: java.lang.String escapeCsv(java.lang.String)>(v);
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
v = v;
v = v + 1;
if v >= v goto label;
v = ",";
goto label;
label:
v = "";
label:
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
goto label;
label:
v = v.<org.apache.nifi.processors.standard.AttributesToCSV: boolean destinationContent>;
if v == 0 goto label;
v = staticinvoke <org.apache.nifi.processors.standard.AttributesToCSV$lambda_onTrigger_0__15: org.apache.nifi.processor.io.StreamCallback bootstrap$(org.apache.nifi.processors.standard.AttributesToCSV,java.lang.StringBuilder,java.lang.StringBuilder)>(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 = <org.apache.nifi.flowfile.attributes.CoreAttributes: org.apache.nifi.flowfile.attributes.CoreAttributes MIME_TYPE>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.CoreAttributes: java.lang.String key()>();
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile putAttribute(org.apache.nifi.flowfile.FlowFile,java.lang.String,java.lang.String)>(v, v, "text/csv");
v = <org.apache.nifi.processors.standard.AttributesToCSV: 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:
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.String toString()>();
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile putAttribute(org.apache.nifi.flowfile.FlowFile,java.lang.String,java.lang.String)>(v, "CSVData", v);
v = v.<org.apache.nifi.processors.standard.AttributesToCSV: java.lang.Boolean includeSchema>;
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
if v == 0 goto label;
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.String toString()>();
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile putAttribute(org.apache.nifi.flowfile.FlowFile,java.lang.String,java.lang.String)>(v, "CSVSchema", v);
label:
v = <org.apache.nifi.processors.standard.AttributesToCSV: 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);
label:
goto label;
label:
v := @caughtexception;
v = virtualinvoke v.<org.apache.nifi.processors.standard.AttributesToCSV: org.apache.nifi.logging.ComponentLog getLogger()>();
v = virtualinvoke v.<java.lang.Exception: java.lang.String getMessage()>();
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void error(java.lang.String)>(v);
v = <org.apache.nifi.processors.standard.AttributesToCSV: 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);
label:
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;
org.apache.nifi.components.AllowableValue v, v, v, v, v;
org.apache.nifi.processor.Relationship v, v;
java.lang.String 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;
org.apache.nifi.expression.ExpressionLanguageScope v, v;
org.apache.nifi.components.AllowableValue[] v;
java.lang.String[] v, v, v;
org.apache.nifi.components.Validator v, v, v, v, v, v;
org.apache.nifi.processor.Relationship$Builder v, v, v, v, v, v;
v = new org.apache.nifi.components.AllowableValue;
specialinvoke v.<org.apache.nifi.components.AllowableValue: void <init>(java.lang.String,java.lang.String,java.lang.String)>("flowfile-content", "flowfile-content", "The resulting CSV string will be placed into the content of the flowfile.Existing flowfile context will be overwritten. \'CSVData\' will not be written to at all (neither null nor empty string).");
<org.apache.nifi.processors.standard.AttributesToCSV: org.apache.nifi.components.AllowableValue OUTPUT_OVERWRITE_CONTENT> = 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)>("flowfile-attribute", "flowfile-attribute", "The resulting CSV string will be placed into a new flowfile attribute named \'CSVData\'.  The content of the flowfile will not be changed.");
<org.apache.nifi.processors.standard.AttributesToCSV: org.apache.nifi.components.AllowableValue OUTPUT_NEW_ATTRIBUTE> = 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)>("attribute-list");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder displayName(java.lang.String)>("Attribute List");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("Comma separated list of attributes to be included in the resulting CSV. If this value is left empty then all existing Attributes will be included. This list of attributes is case sensitive and supports attribute names that contain commas. If an attribute specified in the list is not found it will be emitted to the resulting CSV with an empty string or null depending on the \'Null Value\' property. If a core attribute is specified in this list and the \'Include Core Attributes\' property is false, the core attribute will be included. The attribute list ALWAYS wins.");
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_EL_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.AttributesToCSV: org.apache.nifi.components.PropertyDescriptor ATTRIBUTES_LIST> = 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-regex");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder displayName(java.lang.String)>("Attributes Regular Expression");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("Regular expression that will be evaluated against the flow file attributes to select the matching attributes. This property can be used in combination with the attributes list property.  The final output will contain a combination of matches found in the ATTRIBUTE_LIST and ATTRIBUTE_REGEX.");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder required(boolean)>(0);
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 = 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.processor.util.StandardValidators: org.apache.nifi.components.Validator NON_EMPTY_EL_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.AttributesToCSV: org.apache.nifi.components.PropertyDescriptor ATTRIBUTES_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)>("destination");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder displayName(java.lang.String)>("Destination");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("Control if CSV value is written as a new flowfile attribute \'CSVData\' or written in the flowfile content.");
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.AttributesToCSV: org.apache.nifi.components.AllowableValue OUTPUT_NEW_ATTRIBUTE>;
v[0] = v;
v = <org.apache.nifi.processors.standard.AttributesToCSV: org.apache.nifi.components.AllowableValue OUTPUT_OVERWRITE_CONTENT>;
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.AttributesToCSV: org.apache.nifi.components.AllowableValue OUTPUT_NEW_ATTRIBUTE>;
v = virtualinvoke v.<org.apache.nifi.components.AllowableValue: java.lang.String getDisplayName()>();
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.AttributesToCSV: org.apache.nifi.components.PropertyDescriptor DESTINATION> = v;
v = new org.apache.nifi.components.PropertyDescriptor$Builder;
specialinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder name(java.lang.String)>("include-core-attributes");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder displayName(java.lang.String)>("Include Core Attributes");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("Determines if the FlowFile org.apache.nifi.flowfile.attributes.CoreAttributes, which are contained in every FlowFile, should be included in the final CSV value generated.  Core attributes will be added to the end of the CSVData and CSVSchema strings.  The Attribute List property overrides this setting.");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder required(boolean)>(1);
v = newarray (java.lang.String)[2];
v[0] = "true";
v[1] = "false";
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder allowableValues(java.lang.String[])>(v);
v = <org.apache.nifi.processor.util.StandardValidators: org.apache.nifi.components.Validator BOOLEAN_VALIDATOR>;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder addValidator(org.apache.nifi.components.Validator)>(v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder defaultValue(java.lang.String)>("true");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.AttributesToCSV: org.apache.nifi.components.PropertyDescriptor INCLUDE_CORE_ATTRIBUTES> = 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)>("null-value");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder displayName(java.lang.String)>("Null Value");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("If true a non existing or empty attribute will be \'null\' in the resulting CSV. If false an empty string will be placed in the CSV");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder required(boolean)>(1);
v = newarray (java.lang.String)[2];
v[0] = "true";
v[1] = "false";
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder allowableValues(java.lang.String[])>(v);
v = <org.apache.nifi.processor.util.StandardValidators: org.apache.nifi.components.Validator BOOLEAN_VALIDATOR>;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder addValidator(org.apache.nifi.components.Validator)>(v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder defaultValue(java.lang.String)>("false");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.AttributesToCSV: org.apache.nifi.components.PropertyDescriptor NULL_VALUE_FOR_EMPTY_STRING> = 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)>("include-schema");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder displayName(java.lang.String)>("Include Schema");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("If true the schema (attribute names) will also be converted to a CSV string which will either be applied to a new attribute named \'CSVSchema\' or applied at the first row in the content depending on the DESTINATION property setting.");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder required(boolean)>(1);
v = newarray (java.lang.String)[2];
v[0] = "true";
v[1] = "false";
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder allowableValues(java.lang.String[])>(v);
v = <org.apache.nifi.processor.util.StandardValidators: org.apache.nifi.components.Validator BOOLEAN_VALIDATOR>;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder addValidator(org.apache.nifi.components.Validator)>(v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder defaultValue(java.lang.String)>("false");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.AttributesToCSV: org.apache.nifi.components.PropertyDescriptor INCLUDE_SCHEMA> = 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)>("Successfully converted attributes to CSV");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship build()>();
<org.apache.nifi.processors.standard.AttributesToCSV: 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)>("Failed to convert attributes to CSV");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship build()>();
<org.apache.nifi.processors.standard.AttributesToCSV: org.apache.nifi.processor.Relationship REL_FAILURE> = v;
return;
}
}