public class org.apache.nifi.processors.standard.AttributesToJSON extends org.apache.nifi.processor.AbstractProcessor
{
public static final java.lang.String JSON_ATTRIBUTE_NAME;
private static final java.lang.String AT_LIST_SEPARATOR;
public static final java.lang.String DESTINATION_ATTRIBUTE;
public static final java.lang.String DESTINATION_CONTENT;
public static final java.lang.String APPLICATION_JSON;
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 JSON_HANDLING_STRATEGY;
public static final org.apache.nifi.components.PropertyDescriptor PRETTY_PRINT;
public static final org.apache.nifi.processor.Relationship REL_SUCCESS;
public static final org.apache.nifi.processor.Relationship REL_FAILURE;
private static final com.fasterxml.jackson.databind.ObjectMapper OBJECT_MAPPER;
private java.util.List properties;
private java.util.Set relationships;
private volatile java.util.Set attributesToRemove;
private volatile java.util.Set attributes;
private volatile java.lang.Boolean nullValueForEmptyString;
private volatile boolean destinationContent;
private volatile com.fasterxml.jackson.databind.ObjectWriter objectWriter;
private volatile java.util.regex.Pattern pattern;
private volatile org.apache.nifi.processors.standard.AttributesToJSON$JsonHandlingStrategy jsonHandlingStrategy;
public void <init>()
{
org.apache.nifi.processors.standard.AttributesToJSON v;
v := @this: org.apache.nifi.processors.standard.AttributesToJSON;
specialinvoke v.<org.apache.nifi.processor.AbstractProcessor: void <init>()>();
return;
}
protected void init(org.apache.nifi.processor.ProcessorInitializationContext)
{
org.apache.nifi.processors.standard.AttributesToJSON v;
java.util.Set v;
org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v, v;
java.util.ArrayList v;
java.util.HashSet v;
java.util.List v;
org.apache.nifi.processor.Relationship v, v;
org.apache.nifi.processor.ProcessorInitializationContext v;
v := @this: org.apache.nifi.processors.standard.AttributesToJSON;
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.AttributesToJSON: org.apache.nifi.components.PropertyDescriptor ATTRIBUTES_LIST>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.AttributesToJSON: org.apache.nifi.components.PropertyDescriptor ATTRIBUTES_REGEX>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.AttributesToJSON: org.apache.nifi.components.PropertyDescriptor DESTINATION>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.AttributesToJSON: 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.AttributesToJSON: 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.AttributesToJSON: org.apache.nifi.components.PropertyDescriptor JSON_HANDLING_STRATEGY>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.AttributesToJSON: org.apache.nifi.components.PropertyDescriptor PRETTY_PRINT>;
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.AttributesToJSON: java.util.List properties> = v;
v = new java.util.HashSet;
specialinvoke v.<java.util.HashSet: void <init>()>();
v = <org.apache.nifi.processors.standard.AttributesToJSON: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.AttributesToJSON: 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.AttributesToJSON: java.util.Set relationships> = v;
return;
}
protected java.util.List getSupportedPropertyDescriptors()
{
java.util.List v;
org.apache.nifi.processors.standard.AttributesToJSON v;
v := @this: org.apache.nifi.processors.standard.AttributesToJSON;
v = v.<org.apache.nifi.processors.standard.AttributesToJSON: java.util.List properties>;
return v;
}
public java.util.Set getRelationships()
{
java.util.Set v;
org.apache.nifi.processors.standard.AttributesToJSON v;
v := @this: org.apache.nifi.processors.standard.AttributesToJSON;
v = v.<org.apache.nifi.processors.standard.AttributesToJSON: java.util.Set relationships>;
return v;
}
protected java.util.Map buildAttributesMapForFlowFile(org.apache.nifi.flowfile.FlowFile, java.util.Set, java.util.Set, boolean, java.util.regex.Pattern)
{
org.apache.nifi.processors.standard.AttributesToJSON v;
java.util.regex.Matcher v;
java.util.Map v, v;
boolean 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, v, v;
int v;
java.lang.String v;
java.util.Iterator v, v, v;
java.lang.Object v, v, v, v, v, v, v, v, v;
v := @this: org.apache.nifi.processors.standard.AttributesToJSON;
v := @parameter: org.apache.nifi.flowfile.FlowFile;
v := @parameter: java.util.Set;
v := @parameter: java.util.Set;
v := @parameter: boolean;
v := @parameter: java.util.regex.Pattern;
if v != null goto label;
if v == null goto label;
label:
v = new java.util.LinkedHashMap;
specialinvoke v.<java.util.LinkedHashMap: void <init>()>();
v = v;
if v == null 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;
if v == 0 goto label;
label:
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: 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:
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 = v;
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 = interfaceinvoke v.<java.util.Set: boolean contains(java.lang.Object)>(v);
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:
return v;
}
private java.util.Set buildAtrs(java.lang.String)
{
org.apache.nifi.processors.standard.AttributesToJSON v;
java.lang.String[] v;
java.util.HashSet v;
int v, v, v;
java.lang.String v, v, v;
boolean v;
v := @this: org.apache.nifi.processors.standard.AttributesToJSON;
v := @parameter: java.lang.String;
v = staticinvoke <org.apache.commons.lang.StringUtils: boolean isNotBlank(java.lang.CharSequence)>(v);
if v == 0 goto label;
v = staticinvoke <org.apache.commons.lang.StringUtils: java.lang.String[] split(java.lang.String,java.lang.String)>(v, ",");
if v == null goto label;
v = new java.util.HashSet;
v = lengthof v;
specialinvoke v.<java.util.HashSet: void <init>(int)>(v);
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = virtualinvoke v.<java.lang.String: java.lang.String trim()>();
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
v = v + 1;
goto label;
label:
return v;
label:
return null;
}
public void onScheduled(org.apache.nifi.processor.ProcessContext)
{
org.apache.nifi.processors.standard.AttributesToJSON v;
org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v, v, v;
org.apache.nifi.components.PropertyValue v, v, v, v, v, v, v, v, v;
java.util.stream.Collector v;
boolean v, v, v, v, v;
com.fasterxml.jackson.databind.ObjectWriter v;
java.util.Set v, v;
org.apache.nifi.processors.standard.AttributesToJSON$JsonHandlingStrategy v;
java.util.stream.Stream v, v;
java.util.regex.Pattern v;
java.util.function.Function v;
java.lang.Boolean v, v, v;
java.lang.String v, v, v, v, v;
com.fasterxml.jackson.databind.ObjectMapper v, v;
org.apache.nifi.processor.ProcessContext v;
org.apache.nifi.flowfile.attributes.CoreAttributes[] v;
java.lang.Object v;
v := @this: org.apache.nifi.processors.standard.AttributesToJSON;
v := @parameter: org.apache.nifi.processor.ProcessContext;
v = <org.apache.nifi.processors.standard.AttributesToJSON: 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 = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
if v == 0 goto label;
v = <java.util.Collections: java.util.Set EMPTY_SET>;
goto label;
label:
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.AttributesToJSON$key__16: java.util.function.Function bootstrap$()>();
v = interfaceinvoke v.<java.util.stream.Stream: java.util.stream.Stream map(java.util.function.Function)>(v);
v = staticinvoke <java.util.stream.Collectors: java.util.stream.Collector toSet()>();
v = interfaceinvoke v.<java.util.stream.Stream: java.lang.Object collect(java.util.stream.Collector)>(v);
label:
v.<org.apache.nifi.processors.standard.AttributesToJSON: java.util.Set attributesToRemove> = v;
v = <org.apache.nifi.processors.standard.AttributesToJSON: 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: java.lang.String getValue()>();
v = specialinvoke v.<org.apache.nifi.processors.standard.AttributesToJSON: java.util.Set buildAtrs(java.lang.String)>(v);
v.<org.apache.nifi.processors.standard.AttributesToJSON: java.util.Set attributes> = v;
v = <org.apache.nifi.processors.standard.AttributesToJSON: 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.<org.apache.nifi.processors.standard.AttributesToJSON: java.lang.Boolean nullValueForEmptyString> = v;
v = "flowfile-content";
v = <org.apache.nifi.processors.standard.AttributesToJSON: 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.AttributesToJSON: boolean destinationContent> = v;
v = <org.apache.nifi.processors.standard.AttributesToJSON: org.apache.nifi.components.PropertyDescriptor PRETTY_PRINT>;
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 = v.<org.apache.nifi.processors.standard.AttributesToJSON: boolean destinationContent>;
if v == 0 goto label;
if v == 0 goto label;
v = <org.apache.nifi.processors.standard.AttributesToJSON: com.fasterxml.jackson.databind.ObjectMapper OBJECT_MAPPER>;
v = virtualinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: com.fasterxml.jackson.databind.ObjectWriter writerWithDefaultPrettyPrinter()>();
goto label;
label:
v = <org.apache.nifi.processors.standard.AttributesToJSON: com.fasterxml.jackson.databind.ObjectMapper OBJECT_MAPPER>;
v = virtualinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: com.fasterxml.jackson.databind.ObjectWriter writer()>();
label:
v.<org.apache.nifi.processors.standard.AttributesToJSON: com.fasterxml.jackson.databind.ObjectWriter objectWriter> = v;
v = <org.apache.nifi.processors.standard.AttributesToJSON: org.apache.nifi.components.PropertyDescriptor JSON_HANDLING_STRATEGY>;
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.nifi.processors.standard.AttributesToJSON$JsonHandlingStrategy: org.apache.nifi.processors.standard.AttributesToJSON$JsonHandlingStrategy valueOf(java.lang.String)>(v);
v.<org.apache.nifi.processors.standard.AttributesToJSON: org.apache.nifi.processors.standard.AttributesToJSON$JsonHandlingStrategy jsonHandlingStrategy> = v;
v = <org.apache.nifi.processors.standard.AttributesToJSON: 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.AttributesToJSON: 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()>();
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.AttributesToJSON: java.util.regex.Pattern pattern> = v;
label:
return;
}
public void onTrigger(org.apache.nifi.processor.ProcessContext, org.apache.nifi.processor.ProcessSession) throws org.apache.nifi.processor.exception.ProcessException
{
java.lang.Throwable v;
org.apache.nifi.processors.standard.AttributesToJSON v;
org.apache.nifi.logging.ComponentLog v;
org.apache.nifi.processor.Relationship v, v, v;
java.util.Map v, v;
java.lang.Boolean v;
java.lang.String v, v, v;
boolean v, v;
org.apache.nifi.flowfile.FlowFile v, v, v, v;
com.fasterxml.jackson.databind.ObjectMapper v;
org.apache.nifi.processor.ProcessContext v;
java.util.Set v, v;
org.apache.nifi.processor.ProcessSession v;
java.util.regex.Pattern v;
org.apache.nifi.flowfile.attributes.CoreAttributes v;
org.apache.nifi.processor.io.StreamCallback v;
v := @this: org.apache.nifi.processors.standard.AttributesToJSON;
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 = v.<org.apache.nifi.processors.standard.AttributesToJSON: java.util.Set attributes>;
v = v.<org.apache.nifi.processors.standard.AttributesToJSON: java.util.Set attributesToRemove>;
v = v.<org.apache.nifi.processors.standard.AttributesToJSON: java.lang.Boolean nullValueForEmptyString>;
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
v = v.<org.apache.nifi.processors.standard.AttributesToJSON: java.util.regex.Pattern pattern>;
v = virtualinvoke v.<org.apache.nifi.processors.standard.AttributesToJSON: java.util.Map buildAttributesMapForFlowFile(org.apache.nifi.flowfile.FlowFile,java.util.Set,java.util.Set,boolean,java.util.regex.Pattern)>(v, v, v, v, v);
label:
v = specialinvoke v.<org.apache.nifi.processors.standard.AttributesToJSON: java.util.Map getFormattedAttributes(java.util.Map)>(v);
v = v.<org.apache.nifi.processors.standard.AttributesToJSON: boolean destinationContent>;
if v == 0 goto label;
v = staticinvoke <org.apache.nifi.processors.standard.AttributesToJSON$lambda_onTrigger_0__17: org.apache.nifi.processor.io.StreamCallback bootstrap$(org.apache.nifi.processors.standard.AttributesToJSON,java.util.Map)>(v, v);
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile write(org.apache.nifi.flowfile.FlowFile,org.apache.nifi.processor.io.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, "application/json");
v = <org.apache.nifi.processors.standard.AttributesToJSON: 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 = <org.apache.nifi.processors.standard.AttributesToJSON: com.fasterxml.jackson.databind.ObjectMapper OBJECT_MAPPER>;
v = virtualinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: java.lang.String writeValueAsString(java.lang.Object)>(v);
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, "JSONAttributes", v);
v = <org.apache.nifi.processors.standard.AttributesToJSON: 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.AttributesToJSON: org.apache.nifi.logging.ComponentLog getLogger()>();
v = virtualinvoke v.<com.fasterxml.jackson.core.JsonProcessingException: java.lang.String getMessage()>();
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void error(java.lang.String)>(v);
v = <org.apache.nifi.processors.standard.AttributesToJSON: 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 com.fasterxml.jackson.core.JsonProcessingException from label to label with label;
}
private java.util.Map getFormattedAttributes(java.util.Map) throws com.fasterxml.jackson.core.JsonProcessingException
{
org.apache.nifi.processors.standard.AttributesToJSON v;
java.util.LinkedHashMap v;
java.util.Map v;
com.fasterxml.jackson.databind.JsonNode v;
java.lang.String v;
boolean v, v, v;
java.util.Iterator v;
com.fasterxml.jackson.databind.ObjectMapper v;
java.util.Set v;
org.apache.nifi.processors.standard.AttributesToJSON$JsonHandlingStrategy v, v;
java.lang.Object v, v, v, v;
v := @this: org.apache.nifi.processors.standard.AttributesToJSON;
v := @parameter: java.util.Map;
v = <org.apache.nifi.processors.standard.AttributesToJSON$JsonHandlingStrategy: org.apache.nifi.processors.standard.AttributesToJSON$JsonHandlingStrategy ESCAPED>;
v = v.<org.apache.nifi.processors.standard.AttributesToJSON: org.apache.nifi.processors.standard.AttributesToJSON$JsonHandlingStrategy jsonHandlingStrategy>;
if v != v goto label;
return v;
label:
v = new java.util.LinkedHashMap;
specialinvoke v.<java.util.LinkedHashMap: void <init>()>();
v = interfaceinvoke v.<java.util.Map: java.util.Set entrySet()>();
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
if v == null goto label;
v = virtualinvoke v.<java.lang.String: java.lang.String trim()>();
v = specialinvoke v.<org.apache.nifi.processors.standard.AttributesToJSON: boolean isPossibleJsonArray(java.lang.String)>(v);
if v != 0 goto label;
v = specialinvoke v.<org.apache.nifi.processors.standard.AttributesToJSON: boolean isPossibleJsonObject(java.lang.String)>(v);
if v == 0 goto label;
label:
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getKey()>();
v = <org.apache.nifi.processors.standard.AttributesToJSON: com.fasterxml.jackson.databind.ObjectMapper OBJECT_MAPPER>;
v = virtualinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: com.fasterxml.jackson.databind.JsonNode readTree(java.lang.String)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
goto label;
label:
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getKey()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
goto label;
label:
return v;
}
private boolean isPossibleJsonArray(java.lang.String)
{
org.apache.nifi.processors.standard.AttributesToJSON v;
java.lang.String v;
boolean v, v, v;
v := @this: org.apache.nifi.processors.standard.AttributesToJSON;
v := @parameter: java.lang.String;
v = virtualinvoke v.<java.lang.String: boolean startsWith(java.lang.String)>("[");
if v == 0 goto label;
v = virtualinvoke v.<java.lang.String: boolean endsWith(java.lang.String)>("]");
if v == 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
private boolean isPossibleJsonObject(java.lang.String)
{
org.apache.nifi.processors.standard.AttributesToJSON v;
java.lang.String v;
boolean v, v, v;
v := @this: org.apache.nifi.processors.standard.AttributesToJSON;
v := @parameter: java.lang.String;
v = virtualinvoke v.<java.lang.String: boolean startsWith(java.lang.String)>("{");
if v == 0 goto label;
v = virtualinvoke v.<java.lang.String: boolean endsWith(java.lang.String)>("}");
if v == 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
static void <clinit>()
{
org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v, v, v;
org.apache.nifi.processors.standard.AttributesToJSON$JsonHandlingStrategy 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, v;
org.apache.nifi.expression.ExpressionLanguageScope v, v;
java.lang.String[] v, v, v, v, v;
org.apache.nifi.components.Validator v, v, v;
com.fasterxml.jackson.databind.ObjectMapper v;
org.apache.nifi.processor.Relationship$Builder v, v, v, v, v, v;
v = new org.apache.nifi.components.PropertyDescriptor$Builder;
specialinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder name(java.lang.String)>("Attributes 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 JSON. If this value is left empty then all existing Attributes will be included. This list of attributes is case sensitive. If an attribute specified in the list is not found it will be be emitted to the resulting JSON with an empty string or NULL value.");
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.AttributesToJSON: 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-to-json-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.");
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 VARIABLE_REGISTRY>;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder expressionLanguageSupported(org.apache.nifi.expression.ExpressionLanguageScope)>(v);
v = 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_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.AttributesToJSON: 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 description(java.lang.String)>("Control if JSON value is written as a new flowfile attribute \'JSONAttributes\' or written in the flowfile content. Writing to flowfile content will overwrite any existing flowfile content.");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder required(boolean)>(1);
v = newarray (java.lang.String)[2];
v[0] = "flowfile-attribute";
v[1] = "flowfile-content";
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder allowableValues(java.lang.String[])>(v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder defaultValue(java.lang.String)>("flowfile-attribute");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.AttributesToJSON: 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 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 JSON value generated.");
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.AttributesToJSON: 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 description(java.lang.String)>("If true a non existing selected attribute will be NULL in the resulting JSON. If false an empty string will be placed in the JSON");
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)>("false");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.AttributesToJSON: 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)>("JSON Handling Strategy");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder displayName(java.lang.String)>("JSON Handling Strategy");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("Strategy to use for handling attributes which contain nested JSON.");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder required(boolean)>(1);
v = <org.apache.nifi.expression.ExpressionLanguageScope: org.apache.nifi.expression.ExpressionLanguageScope NONE>;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder expressionLanguageSupported(org.apache.nifi.expression.ExpressionLanguageScope)>(v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder allowableValues(java.lang.Class)>(class "Lorg/apache/nifi/processors/standard/AttributesToJSON$JsonHandlingStrategy;");
v = <org.apache.nifi.processors.standard.AttributesToJSON$JsonHandlingStrategy: org.apache.nifi.processors.standard.AttributesToJSON$JsonHandlingStrategy ESCAPED>;
v = virtualinvoke v.<org.apache.nifi.processors.standard.AttributesToJSON$JsonHandlingStrategy: 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.AttributesToJSON: org.apache.nifi.components.PropertyDescriptor JSON_HANDLING_STRATEGY> = 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)>("Pretty Print");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder displayName(java.lang.String)>("Pretty Print");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("Apply pretty print formatting to the output.");
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)>("false");
v = <org.apache.nifi.processors.standard.AttributesToJSON: org.apache.nifi.components.PropertyDescriptor DESTINATION>;
v = newarray (java.lang.String)[0];
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder dependsOn(org.apache.nifi.components.PropertyDescriptor,java.lang.String,java.lang.String[])>(v, "flowfile-content", v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.AttributesToJSON: org.apache.nifi.components.PropertyDescriptor PRETTY_PRINT> = 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 JSON");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship build()>();
<org.apache.nifi.processors.standard.AttributesToJSON: 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 JSON");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship build()>();
<org.apache.nifi.processors.standard.AttributesToJSON: org.apache.nifi.processor.Relationship REL_FAILURE> = v;
v = new com.fasterxml.jackson.databind.ObjectMapper;
specialinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: void <init>()>();
<org.apache.nifi.processors.standard.AttributesToJSON: com.fasterxml.jackson.databind.ObjectMapper OBJECT_MAPPER> = v;
return;
}
}