public class org.apache.nifi.processors.standard.EvaluateXQuery extends org.apache.nifi.processor.AbstractProcessor
{
public static final java.lang.String DESTINATION_ATTRIBUTE;
public static final java.lang.String DESTINATION_CONTENT;
public static final java.lang.String OUTPUT_METHOD_XML;
public static final java.lang.String OUTPUT_METHOD_HTML;
public static final java.lang.String OUTPUT_METHOD_TEXT;
public static final org.apache.nifi.components.PropertyDescriptor DESTINATION;
public static final org.apache.nifi.components.PropertyDescriptor XML_OUTPUT_METHOD;
public static final org.apache.nifi.components.PropertyDescriptor XML_OUTPUT_OMIT_XML_DECLARATION;
public static final org.apache.nifi.components.PropertyDescriptor XML_OUTPUT_INDENT;
public static final org.apache.nifi.components.PropertyDescriptor VALIDATE_DTD;
public static final org.apache.nifi.processor.Relationship REL_MATCH;
public static final org.apache.nifi.processor.Relationship REL_NO_MATCH;
public static final org.apache.nifi.processor.Relationship REL_FAILURE;
private java.util.Set relationships;
private java.util.List properties;
public void <init>()
{
org.apache.nifi.processors.standard.EvaluateXQuery v;
v := @this: org.apache.nifi.processors.standard.EvaluateXQuery;
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;
java.util.ArrayList v;
java.util.HashSet v;
java.util.List v;
org.apache.nifi.processors.standard.EvaluateXQuery v;
org.apache.nifi.processor.Relationship v, v, v;
org.apache.nifi.processor.ProcessorInitializationContext v;
v := @this: org.apache.nifi.processors.standard.EvaluateXQuery;
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.EvaluateXQuery: org.apache.nifi.processor.Relationship REL_MATCH>;
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.EvaluateXQuery: org.apache.nifi.processor.Relationship REL_NO_MATCH>;
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.EvaluateXQuery: 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.EvaluateXQuery: java.util.Set relationships> = v;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = <org.apache.nifi.processors.standard.EvaluateXQuery: org.apache.nifi.components.PropertyDescriptor DESTINATION>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.EvaluateXQuery: org.apache.nifi.components.PropertyDescriptor XML_OUTPUT_METHOD>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.EvaluateXQuery: org.apache.nifi.components.PropertyDescriptor XML_OUTPUT_OMIT_XML_DECLARATION>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.EvaluateXQuery: org.apache.nifi.components.PropertyDescriptor XML_OUTPUT_INDENT>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.EvaluateXQuery: org.apache.nifi.components.PropertyDescriptor VALIDATE_DTD>;
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.EvaluateXQuery: java.util.List properties> = v;
return;
}
protected java.util.Collection customValidate(org.apache.nifi.components.ValidationContext)
{
org.apache.nifi.components.ValidationContext v;
org.apache.nifi.components.PropertyDescriptor v;
java.util.ArrayList v;
org.apache.nifi.components.PropertyValue v;
org.apache.nifi.processors.standard.EvaluateXQuery v;
java.util.Map v;
int v;
java.lang.String v, v;
org.apache.nifi.components.ValidationResult v;
boolean v, v, v;
org.apache.nifi.components.ValidationResult$Builder v, v, v, v;
java.util.Iterator v;
java.util.Collection v;
java.util.Set v;
java.lang.Object v;
v := @this: org.apache.nifi.processors.standard.EvaluateXQuery;
v := @parameter: org.apache.nifi.components.ValidationContext;
v = new java.util.ArrayList;
v = specialinvoke v.<org.apache.nifi.processor.AbstractProcessor: java.util.Collection customValidate(org.apache.nifi.components.ValidationContext)>(v);
specialinvoke v.<java.util.ArrayList: void <init>(java.util.Collection)>(v);
v = <org.apache.nifi.processors.standard.EvaluateXQuery: org.apache.nifi.components.PropertyDescriptor DESTINATION>;
v = interfaceinvoke v.<org.apache.nifi.components.ValidationContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.String getValue()>();
v = "flowfile-content";
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = 0;
v = interfaceinvoke v.<org.apache.nifi.components.ValidationContext: java.util.Map getProperties()>();
v = interfaceinvoke v.<java.util.Map: java.util.Set keySet()>();
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 = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor: boolean isDynamic()>();
if v == 0 goto label;
v = v + 1;
goto label;
label:
if v == 1 goto label;
v = new org.apache.nifi.components.ValidationResult$Builder;
specialinvoke v.<org.apache.nifi.components.ValidationResult$Builder: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.components.ValidationResult$Builder: org.apache.nifi.components.ValidationResult$Builder subject(java.lang.String)>("XQueries");
v = virtualinvoke v.<org.apache.nifi.components.ValidationResult$Builder: org.apache.nifi.components.ValidationResult$Builder valid(boolean)>(0);
v = virtualinvoke v.<org.apache.nifi.components.ValidationResult$Builder: org.apache.nifi.components.ValidationResult$Builder explanation(java.lang.String)>("Exactly one XQuery must be set if using destination of flowfile-content");
v = virtualinvoke v.<org.apache.nifi.components.ValidationResult$Builder: org.apache.nifi.components.ValidationResult build()>();
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
label:
return v;
}
public java.util.Set getRelationships()
{
java.util.Set v;
org.apache.nifi.processors.standard.EvaluateXQuery v;
v := @this: org.apache.nifi.processors.standard.EvaluateXQuery;
v = v.<org.apache.nifi.processors.standard.EvaluateXQuery: java.util.Set relationships>;
return v;
}
protected java.util.List getSupportedPropertyDescriptors()
{
java.util.List v;
org.apache.nifi.processors.standard.EvaluateXQuery v;
v := @this: org.apache.nifi.processors.standard.EvaluateXQuery;
v = v.<org.apache.nifi.processors.standard.EvaluateXQuery: java.util.List properties>;
return v;
}
protected org.apache.nifi.components.PropertyDescriptor getSupportedDynamicPropertyDescriptor(java.lang.String)
{
org.apache.nifi.expression.ExpressionLanguageScope v;
org.apache.nifi.components.PropertyDescriptor v;
org.apache.nifi.components.PropertyDescriptor$Builder v, v, v, v, v, v;
org.apache.nifi.processors.standard.EvaluateXQuery$XQueryValidator v;
org.apache.nifi.processors.standard.EvaluateXQuery v;
java.lang.String v;
v := @this: org.apache.nifi.processors.standard.EvaluateXQuery;
v := @parameter: java.lang.String;
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)>(v);
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 = new org.apache.nifi.processors.standard.EvaluateXQuery$XQueryValidator;
specialinvoke v.<org.apache.nifi.processors.standard.EvaluateXQuery$XQueryValidator: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder addValidator(org.apache.nifi.components.Validator)>(v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder required(boolean)>(0);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder dynamic(boolean)>(1);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
return v;
}
public void onTrigger(org.apache.nifi.processor.ProcessContext, org.apache.nifi.processor.ProcessSession)
{
org.apache.nifi.processor.io.OutputStreamCallback v, v;
java.lang.Integer v, v, v;
org.apache.nifi.components.PropertyDescriptor v, v;
org.apache.nifi.processors.standard.EvaluateXQuery v;
java.util.Map v;
net.sf.saxon.s9api.XQueryExecutable v;
net.sf.saxon.s9api.Processor v;
java.util.Set v, v;
net.sf.saxon.s9api.XQueryEvaluator v;
java.lang.Exception v;
net.sf.saxon.s9api.XdmValue v;
java.lang.Throwable v, v;
java.lang.Object[] v, v, v, v, v, v, v;
java.util.ArrayList v;
org.apache.nifi.provenance.ProvenanceReporter v, v;
org.apache.nifi.processor.Relationship v, v, v, v, v, v, v;
java.lang.String v, v, v, v, v;
java.io.IOException v;
org.apache.nifi.processor.ProcessSession v;
net.sf.saxon.s9api.XdmSequenceIterator v, v;
org.apache.nifi.components.PropertyValue v, v;
org.apache.nifi.processor.io.InputStreamCallback v;
boolean v, v, v, v, v, v, v, v, v, v, v, v, v;
net.sf.saxon.s9api.XQueryCompiler v;
org.apache.nifi.flowfile.FlowFile v, v, v;
java.util.List v;
java.util.HashMap v, v;
org.apache.nifi.logging.ComponentLog v;
java.util.concurrent.atomic.AtomicReference v;
org.apache.nifi.processor.exception.ProcessException v;
net.sf.saxon.s9api.XdmItem v;
int v, v, v, v, v, v, v, v;
java.lang.Boolean v;
java.util.Iterator v, v, v;
org.apache.nifi.processor.ProcessContext v;
java.lang.Object v, v, v, v, v, v, v, v, v, v, v, v, v;
v := @this: org.apache.nifi.processors.standard.EvaluateXQuery;
v := @parameter: org.apache.nifi.processor.ProcessContext;
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;
return;
label:
v = virtualinvoke v.<org.apache.nifi.processors.standard.EvaluateXQuery: org.apache.nifi.logging.ComponentLog getLogger()>();
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v = new net.sf.saxon.s9api.Processor;
specialinvoke v.<net.sf.saxon.s9api.Processor: void <init>(boolean)>(0);
v = virtualinvoke v.<net.sf.saxon.s9api.Processor: net.sf.saxon.s9api.XQueryCompiler newXQueryCompiler()>();
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: java.util.Map getProperties()>();
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.<org.apache.nifi.components.PropertyDescriptor: boolean isDynamic()>();
if v == 0 goto label;
label:
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
v = virtualinvoke v.<net.sf.saxon.s9api.XQueryCompiler: net.sf.saxon.s9api.XQueryExecutable compile(java.lang.String)>(v);
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getKey()>();
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor: java.lang.String getName()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, 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 = <org.apache.nifi.processors.standard.EvaluateXQuery: 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 = <org.apache.nifi.processors.standard.EvaluateXQuery: org.apache.nifi.components.PropertyDescriptor VALIDATE_DTD>;
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 = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = virtualinvoke v.<org.apache.nifi.processors.standard.EvaluateXQuery: boolean isScheduled()>();
if v != 0 goto label;
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void rollback()>();
return;
label:
v = new java.util.concurrent.atomic.AtomicReference;
specialinvoke v.<java.util.concurrent.atomic.AtomicReference: void <init>(java.lang.Object)>(null);
label:
v = staticinvoke <org.apache.nifi.processors.standard.EvaluateXQuery$lambda_onTrigger_0__69: org.apache.nifi.processor.io.InputStreamCallback bootstrap$(boolean,java.util.concurrent.atomic.AtomicReference)>(v, v);
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void read(org.apache.nifi.flowfile.FlowFile,org.apache.nifi.processor.io.InputStreamCallback)>(v, v);
label:
goto label;
label:
v := @caughtexception;
v = newarray (java.lang.Object)[2];
v[0] = v;
v[1] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void error(java.lang.String,java.lang.Object[])>("Input parsing failed {}", v);
v = <org.apache.nifi.processors.standard.EvaluateXQuery: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void transfer(org.apache.nifi.flowfile.FlowFile,org.apache.nifi.processor.Relationship)>(v, v);
goto label;
label:
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: 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()>();
label:
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
v = virtualinvoke v.<net.sf.saxon.s9api.XQueryExecutable: net.sf.saxon.s9api.XQueryEvaluator load()>();
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: java.lang.Object get()>();
virtualinvoke v.<net.sf.saxon.s9api.XQueryEvaluator: void setSource(javax.xml.transform.Source)>(v);
v = virtualinvoke v.<net.sf.saxon.s9api.XQueryEvaluator: net.sf.saxon.s9api.XdmValue evaluate()>();
v = "flowfile-attribute";
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = 1;
v = virtualinvoke v.<net.sf.saxon.s9api.XdmValue: net.sf.saxon.s9api.XdmSequenceIterator 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 = specialinvoke v.<org.apache.nifi.processors.standard.EvaluateXQuery: java.lang.String formatItem(net.sf.saxon.s9api.XdmItem,org.apache.nifi.processor.ProcessContext)>(v, v);
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getKey()>();
v = virtualinvoke v.<net.sf.saxon.s9api.XdmValue: int size()>();
if v <= 1 goto label;
v = v;
v = v + 1;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,int)>(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[])>("\u.\u0001");
label:
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
goto label;
label:
v = virtualinvoke v.<net.sf.saxon.s9api.XdmValue: int size()>();
if v != 0 goto label;
v = newarray (java.lang.Object)[1];
v[0] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void info(java.lang.String,java.lang.Object[])>("No XQuery results found {}", v);
v = <org.apache.nifi.processors.standard.EvaluateXQuery: org.apache.nifi.processor.Relationship REL_NO_MATCH>;
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 = virtualinvoke v.<net.sf.saxon.s9api.XdmValue: int size()>();
if v != 1 goto label;
v = virtualinvoke v.<net.sf.saxon.s9api.XdmValue: net.sf.saxon.s9api.XdmItem itemAt(int)>(0);
v = staticinvoke <org.apache.nifi.processors.standard.EvaluateXQuery$lambda_onTrigger_1__71: org.apache.nifi.processor.io.OutputStreamCallback bootstrap$(org.apache.nifi.processors.standard.EvaluateXQuery,net.sf.saxon.s9api.XdmItem,org.apache.nifi.processor.ProcessContext)>(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.OutputStreamCallback)>(v, v);
goto label;
label:
v = virtualinvoke v.<net.sf.saxon.s9api.XdmValue: net.sf.saxon.s9api.XdmSequenceIterator 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.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile clone(org.apache.nifi.flowfile.FlowFile)>(v);
v = staticinvoke <org.apache.nifi.processors.standard.EvaluateXQuery$lambda_onTrigger_2__70: org.apache.nifi.processor.io.OutputStreamCallback bootstrap$(org.apache.nifi.processors.standard.EvaluateXQuery,net.sf.saxon.s9api.XdmItem,org.apache.nifi.processor.ProcessContext)>(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.OutputStreamCallback)>(v, v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
v := @caughtexception;
v = newarray (java.lang.Object)[2];
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getKey()>();
v[0] = v;
v[1] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void error(java.lang.String,java.lang.Object[])>("XQuery Property [{}] processing failed", v);
v = <org.apache.nifi.processors.standard.EvaluateXQuery: 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);
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void remove(java.util.Collection)>(v);
goto label;
label:
v := @caughtexception;
v = newarray (java.lang.Object)[2];
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getKey()>();
v[0] = v;
v[1] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void error(java.lang.String,java.lang.Object[])>("XQuery Property [{}] configuration failed", v);
v = <org.apache.nifi.processors.standard.EvaluateXQuery: 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);
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void remove(java.util.Collection)>(v);
goto label;
label:
v = "flowfile-attribute";
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile putAllAttributes(org.apache.nifi.flowfile.FlowFile,java.util.Map)>(v, v);
v = interfaceinvoke v.<java.util.Map: boolean isEmpty()>();
if v == 0 goto label;
v = <org.apache.nifi.processors.standard.EvaluateXQuery: org.apache.nifi.processor.Relationship REL_NO_MATCH>;
goto label;
label:
v = <org.apache.nifi.processors.standard.EvaluateXQuery: org.apache.nifi.processor.Relationship REL_MATCH>;
label:
v = newarray (java.lang.Object)[2];
v = interfaceinvoke v.<java.util.Map: int size()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[0] = v;
v[1] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void info(java.lang.String,java.lang.Object[])>("XQuery results found [{}] for {}", v);
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void transfer(org.apache.nifi.flowfile.FlowFile,org.apache.nifi.processor.Relationship)>(v, v);
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.provenance.ProvenanceReporter getProvenanceReporter()>();
interfaceinvoke v.<org.apache.nifi.provenance.ProvenanceReporter: void modifyAttributes(org.apache.nifi.flowfile.FlowFile)>(v);
goto label;
label:
v = interfaceinvoke v.<java.util.List: boolean isEmpty()>();
if v != 0 goto label;
v = newarray (java.lang.Object)[3];
v = interfaceinvoke v.<java.util.Map: int size()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[0] = v;
v[1] = v;
v = interfaceinvoke v.<java.util.List: int size()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[2] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void info(java.lang.String,java.lang.Object[])>("XQuery results found [{}] for {} FlowFiles created [{}]", v);
v = <org.apache.nifi.processors.standard.EvaluateXQuery: org.apache.nifi.processor.Relationship REL_MATCH>;
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void transfer(java.util.Collection,org.apache.nifi.processor.Relationship)>(v, v);
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void remove(org.apache.nifi.flowfile.FlowFile)>(v);
goto label;
label:
v = newarray (java.lang.Object)[1];
v[0] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void info(java.lang.String,java.lang.Object[])>("XQuery results found for {} content updated", v);
v = <org.apache.nifi.processors.standard.EvaluateXQuery: org.apache.nifi.processor.Relationship REL_MATCH>;
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void transfer(org.apache.nifi.flowfile.FlowFile,org.apache.nifi.processor.Relationship)>(v, v);
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.provenance.ProvenanceReporter getProvenanceReporter()>();
interfaceinvoke v.<org.apache.nifi.provenance.ProvenanceReporter: void modifyContent(org.apache.nifi.flowfile.FlowFile)>(v);
goto label;
label:
return;
catch net.sf.saxon.s9api.SaxonApiException from label to label with label;
catch java.lang.Exception from label to label with label;
catch net.sf.saxon.s9api.SaxonApiException from label to label with label;
catch net.sf.saxon.s9api.SaxonApiException from label to label with label;
catch java.io.IOException from label to label with label;
catch java.io.IOException from label to label with label;
}
private java.lang.String formatItem(net.sf.saxon.s9api.XdmItem, org.apache.nifi.processor.ProcessContext) throws java.io.IOException
{
java.io.ByteArrayOutputStream v;
net.sf.saxon.s9api.XdmItem v;
org.apache.nifi.processors.standard.EvaluateXQuery v;
org.apache.nifi.processor.ProcessContext v;
java.lang.String v;
v := @this: org.apache.nifi.processors.standard.EvaluateXQuery;
v := @parameter: net.sf.saxon.s9api.XdmItem;
v := @parameter: org.apache.nifi.processor.ProcessContext;
v = new java.io.ByteArrayOutputStream;
specialinvoke v.<java.io.ByteArrayOutputStream: void <init>()>();
virtualinvoke v.<org.apache.nifi.processors.standard.EvaluateXQuery: void writeFormattedItem(net.sf.saxon.s9api.XdmItem,org.apache.nifi.processor.ProcessContext,java.io.OutputStream)>(v, v, v);
v = virtualinvoke v.<java.io.ByteArrayOutputStream: java.lang.String toString()>();
return v;
}
void writeFormattedItem(net.sf.saxon.s9api.XdmItem, org.apache.nifi.processor.ProcessContext, java.io.OutputStream) throws java.io.IOException
{
byte[] v, v;
javax.xml.transform.stream.StreamResult v;
javax.xml.transform.Source v;
org.apache.nifi.components.PropertyDescriptor v, v, v;
org.apache.nifi.components.PropertyValue v, v, v;
java.nio.charset.Charset v, v;
net.sf.saxon.s9api.XdmItem v;
net.sf.saxon.s9api.XdmNodeKind v;
org.apache.nifi.processors.standard.EvaluateXQuery v;
int[] v;
int v, v;
java.lang.Boolean v, v;
java.lang.String v, v, v;
boolean v, v, v;
java.io.OutputStream v;
org.apache.nifi.xml.processing.transform.StandardTransformProvider v;
org.apache.nifi.processor.ProcessContext v;
v := @this: org.apache.nifi.processors.standard.EvaluateXQuery;
v := @parameter: net.sf.saxon.s9api.XdmItem;
v := @parameter: org.apache.nifi.processor.ProcessContext;
v := @parameter: java.io.OutputStream;
v = virtualinvoke v.<net.sf.saxon.s9api.XdmItem: boolean isAtomicValue()>();
if v == 0 goto label;
v = virtualinvoke v.<net.sf.saxon.s9api.XdmItem: java.lang.String getStringValue()>();
v = <java.nio.charset.StandardCharsets: java.nio.charset.Charset UTF_8>;
v = virtualinvoke v.<java.lang.String: byte[] getBytes(java.nio.charset.Charset)>(v);
virtualinvoke v.<java.io.OutputStream: void write(byte[])>(v);
goto label;
label:
v = <org.apache.nifi.processors.standard.EvaluateXQuery$1: int[] $SwitchMap$net$sf$saxon$sapi$XdmNodeKind>;
v = virtualinvoke v.<net.sf.saxon.s9api.XdmNode: net.sf.saxon.s9api.XdmNodeKind getNodeKind()>();
v = virtualinvoke v.<net.sf.saxon.s9api.XdmNodeKind: int ordinal()>();
v = v[v];
lookupswitch(v)
{
case 1: goto label;
case 2: goto label;
default: goto label;
};
label:
v = new org.apache.nifi.xml.processing.transform.StandardTransformProvider;
specialinvoke v.<org.apache.nifi.xml.processing.transform.StandardTransformProvider: void <init>()>();
v = <org.apache.nifi.processors.standard.EvaluateXQuery: org.apache.nifi.components.PropertyDescriptor XML_OUTPUT_METHOD>;
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()>();
virtualinvoke v.<org.apache.nifi.xml.processing.transform.StandardTransformProvider: void setMethod(java.lang.String)>(v);
v = <org.apache.nifi.processors.standard.EvaluateXQuery: org.apache.nifi.components.PropertyDescriptor XML_OUTPUT_INDENT>;
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()>();
virtualinvoke v.<org.apache.nifi.xml.processing.transform.StandardTransformProvider: void setIndent(boolean)>(v);
v = <org.apache.nifi.processors.standard.EvaluateXQuery: org.apache.nifi.components.PropertyDescriptor XML_OUTPUT_OMIT_XML_DECLARATION>;
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()>();
virtualinvoke v.<org.apache.nifi.xml.processing.transform.StandardTransformProvider: void setOmitXmlDeclaration(boolean)>(v);
v = new javax.xml.transform.stream.StreamResult;
specialinvoke v.<javax.xml.transform.stream.StreamResult: void <init>(java.io.OutputStream)>(v);
v = virtualinvoke v.<net.sf.saxon.s9api.XdmNode: javax.xml.transform.Source asSource()>();
virtualinvoke v.<org.apache.nifi.xml.processing.transform.StandardTransformProvider: void transform(javax.xml.transform.Source,javax.xml.transform.Result)>(v, v);
goto label;
label:
v = virtualinvoke v.<net.sf.saxon.s9api.XdmNode: java.lang.String getStringValue()>();
v = <java.nio.charset.StandardCharsets: java.nio.charset.Charset UTF_8>;
v = virtualinvoke v.<java.lang.String: byte[] getBytes(java.nio.charset.Charset)>(v);
virtualinvoke v.<java.io.OutputStream: void write(byte[])>(v);
label:
return;
}
static void <clinit>()
{
org.apache.nifi.components.PropertyDescriptor v, v, v, v, v;
org.apache.nifi.components.PropertyDescriptor$Builder v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.lang.String[] v, v, v;
org.apache.nifi.processor.Relationship v, v, v;
org.apache.nifi.components.Validator v, v;
org.apache.nifi.processor.Relationship$Builder v, v, v, 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)>("Destination");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("Indicates whether the results of the XQuery evaluation are written to the FlowFile content or a FlowFile attribute. If set to <flowfile-content>, only one XQuery may be specified and the property name is ignored.  If set to <flowfile-attribute> and the XQuery returns more than one result, multiple attributes will be added to theFlowFile, each named with a \'.n\' one-up number appended to the specified attribute name");
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-content";
v[1] = "flowfile-attribute";
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-content");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.EvaluateXQuery: 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)>("Output: Method");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("Identifies the overall method that should be used for outputting a result tree.");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder required(boolean)>(1);
v = newarray (java.lang.String)[3];
v[0] = "xml";
v[1] = "html";
v[2] = "text";
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)>("xml");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.EvaluateXQuery: org.apache.nifi.components.PropertyDescriptor XML_OUTPUT_METHOD> = 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: Omit XML Declaration");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("Specifies whether the processor should output an XML declaration when transforming a result tree.");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder required(boolean)>(1);
v = <org.apache.nifi.processor.util.StandardValidators: org.apache.nifi.components.Validator 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.EvaluateXQuery: org.apache.nifi.components.PropertyDescriptor XML_OUTPUT_OMIT_XML_DECLARATION> = 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: Indent");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("Specifies whether the processor may add additional whitespace when outputting a result tree.");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder required(boolean)>(1);
v = <org.apache.nifi.processor.util.StandardValidators: org.apache.nifi.components.Validator 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.EvaluateXQuery: org.apache.nifi.components.PropertyDescriptor XML_OUTPUT_INDENT> = 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 displayName(java.lang.String)>("Allow DTD");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder name(java.lang.String)>("Validate DTD");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("Allow embedded Document Type Declaration in XML. This feature should be disabled to avoid XML entity expansion vulnerabilities.");
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.EvaluateXQuery: org.apache.nifi.components.PropertyDescriptor VALIDATE_DTD> = 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)>("matched");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship$Builder description(java.lang.String)>("FlowFiles are routed to this relationship when the XQuery is successfully evaluated and the FlowFile is modified as a result");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship build()>();
<org.apache.nifi.processors.standard.EvaluateXQuery: org.apache.nifi.processor.Relationship REL_MATCH> = 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)>("unmatched");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship$Builder description(java.lang.String)>("FlowFiles are routed to this relationship when the XQuery does not match the content of the FlowFile and the Destination is set to flowfile-content");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship build()>();
<org.apache.nifi.processors.standard.EvaluateXQuery: org.apache.nifi.processor.Relationship REL_NO_MATCH> = v;
v = new org.apache.nifi.processor.Relationship$Builder;
specialinvoke v.<org.apache.nifi.processor.Relationship$Builder: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship$Builder name(java.lang.String)>("failure");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship$Builder description(java.lang.String)>("FlowFiles are routed to this relationship when the XQuery cannot be evaluated against the content of the FlowFile.");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship build()>();
<org.apache.nifi.processors.standard.EvaluateXQuery: org.apache.nifi.processor.Relationship REL_FAILURE> = v;
return;
}
}