public class org.apache.nifi.processors.standard.ExecuteStreamCommand extends org.apache.nifi.processor.AbstractProcessor
{
public static final org.apache.nifi.processor.Relationship ORIGINAL_RELATIONSHIP;
public static final org.apache.nifi.processor.Relationship OUTPUT_STREAM_RELATIONSHIP;
public static final org.apache.nifi.processor.Relationship NONZERO_STATUS_RELATIONSHIP;
private final java.util.concurrent.atomic.AtomicReference relationships;
private static final java.util.Set OUTPUT_STREAM_RELATIONSHIP_SET;
private static final java.util.Set ATTRIBUTE_RELATIONSHIP_SET;
private static final java.util.regex.Pattern COMMAND_ARGUMENT_PATTERN;
public static final java.lang.String executionArguments;
public static final java.lang.String dynamicArguements;
static final org.apache.nifi.components.AllowableValue EXECUTION_ARGUMENTS_PROPERTY_STRATEGY;
static final org.apache.nifi.components.AllowableValue DYNAMIC_PROPERTY_ARGUMENTS_STRATEGY;
static final org.apache.nifi.components.PropertyDescriptor WORKING_DIR;
private static final org.apache.nifi.components.Validator ATTRIBUTE_EXPRESSION_LANGUAGE_VALIDATOR;
static final org.apache.nifi.components.PropertyDescriptor EXECUTION_COMMAND;
static final org.apache.nifi.components.PropertyDescriptor ARGUMENTS_STRATEGY;
static final org.apache.nifi.components.PropertyDescriptor EXECUTION_ARGUMENTS;
static final org.apache.nifi.components.PropertyDescriptor ARG_DELIMITER;
static final org.apache.nifi.components.PropertyDescriptor IGNORE_STDIN;
static final org.apache.nifi.components.PropertyDescriptor PUT_OUTPUT_IN_ATTRIBUTE;
static final org.apache.nifi.components.PropertyDescriptor PUT_ATTRIBUTE_MAX_LENGTH;
private static final java.util.List PROPERTIES;
private static final java.lang.String MASKED_ARGUMENT;
private org.apache.nifi.logging.ComponentLog logger;
public void <init>()
{
java.util.concurrent.atomic.AtomicReference v;
org.apache.nifi.processors.standard.ExecuteStreamCommand v;
v := @this: org.apache.nifi.processors.standard.ExecuteStreamCommand;
specialinvoke v.<org.apache.nifi.processor.AbstractProcessor: void <init>()>();
v = new java.util.concurrent.atomic.AtomicReference;
specialinvoke v.<java.util.concurrent.atomic.AtomicReference: void <init>()>();
v.<org.apache.nifi.processors.standard.ExecuteStreamCommand: java.util.concurrent.atomic.AtomicReference relationships> = v;
return;
}
public java.util.Set getRelationships()
{
java.lang.Object v;
java.util.concurrent.atomic.AtomicReference v;
org.apache.nifi.processors.standard.ExecuteStreamCommand v;
v := @this: org.apache.nifi.processors.standard.ExecuteStreamCommand;
v = v.<org.apache.nifi.processors.standard.ExecuteStreamCommand: java.util.concurrent.atomic.AtomicReference relationships>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: java.lang.Object get()>();
return v;
}
protected void init(org.apache.nifi.processor.ProcessorInitializationContext)
{
org.apache.nifi.processors.standard.ExecuteStreamCommand v;
java.util.Set v;
org.apache.nifi.logging.ComponentLog v;
java.util.concurrent.atomic.AtomicReference v;
org.apache.nifi.processor.ProcessorInitializationContext v;
v := @this: org.apache.nifi.processors.standard.ExecuteStreamCommand;
v := @parameter: org.apache.nifi.processor.ProcessorInitializationContext;
v = virtualinvoke v.<org.apache.nifi.processors.standard.ExecuteStreamCommand: org.apache.nifi.logging.ComponentLog getLogger()>();
v.<org.apache.nifi.processors.standard.ExecuteStreamCommand: org.apache.nifi.logging.ComponentLog logger> = v;
v = v.<org.apache.nifi.processors.standard.ExecuteStreamCommand: java.util.concurrent.atomic.AtomicReference relationships>;
v = <org.apache.nifi.processors.standard.ExecuteStreamCommand: java.util.Set OUTPUT_STREAM_RELATIONSHIP_SET>;
virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: void set(java.lang.Object)>(v);
return;
}
public void onPropertyModified(org.apache.nifi.components.PropertyDescriptor, java.lang.String, java.lang.String)
{
java.util.Set v, v;
java.util.concurrent.atomic.AtomicReference v, v;
org.apache.nifi.components.PropertyDescriptor v, v;
org.apache.nifi.processors.standard.ExecuteStreamCommand v;
java.lang.String v, v;
boolean v;
v := @this: org.apache.nifi.processors.standard.ExecuteStreamCommand;
v := @parameter: org.apache.nifi.components.PropertyDescriptor;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = <org.apache.nifi.processors.standard.ExecuteStreamCommand: org.apache.nifi.components.PropertyDescriptor PUT_OUTPUT_IN_ATTRIBUTE>;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
if v == null goto label;
v = v.<org.apache.nifi.processors.standard.ExecuteStreamCommand: java.util.concurrent.atomic.AtomicReference relationships>;
v = <org.apache.nifi.processors.standard.ExecuteStreamCommand: java.util.Set ATTRIBUTE_RELATIONSHIP_SET>;
virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: void set(java.lang.Object)>(v);
goto label;
label:
v = v.<org.apache.nifi.processors.standard.ExecuteStreamCommand: java.util.concurrent.atomic.AtomicReference relationships>;
v = <org.apache.nifi.processors.standard.ExecuteStreamCommand: java.util.Set OUTPUT_STREAM_RELATIONSHIP_SET>;
virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: void set(java.lang.Object)>(v);
label:
return;
}
public java.util.List getSupportedPropertyDescriptors()
{
java.util.List v;
org.apache.nifi.processors.standard.ExecuteStreamCommand v;
v := @this: org.apache.nifi.processors.standard.ExecuteStreamCommand;
v = <org.apache.nifi.processors.standard.ExecuteStreamCommand: java.util.List PROPERTIES>;
return v;
}
protected org.apache.nifi.components.PropertyDescriptor getSupportedDynamicPropertyDescriptor(java.lang.String)
{
org.apache.nifi.components.PropertyDescriptor v, v;
org.apache.nifi.components.PropertyDescriptor$Builder v, v, v, v, v, v, v, v, v, v, v, v;
java.util.regex.Matcher v;
java.lang.String v, v;
boolean v;
org.apache.nifi.components.Validator v, v;
org.apache.nifi.expression.ExpressionLanguageScope v;
org.apache.nifi.processors.standard.ExecuteStreamCommand v;
java.util.regex.Pattern v;
v := @this: org.apache.nifi.processors.standard.ExecuteStreamCommand;
v := @parameter: java.lang.String;
v = <org.apache.nifi.processors.standard.ExecuteStreamCommand: java.util.regex.Pattern COMMAND_ARGUMENT_PATTERN>;
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 = 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 = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder displayName(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("Argument passed to command");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder dynamic(boolean)>(1);
v = <org.apache.nifi.expression.ExpressionLanguageScope: org.apache.nifi.expression.ExpressionLanguageScope FLOWFILE_ATTRIBUTES>;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder expressionLanguageSupported(org.apache.nifi.expression.ExpressionLanguageScope)>(v);
v = <org.apache.nifi.processors.standard.ExecuteStreamCommand: org.apache.nifi.components.Validator ATTRIBUTE_EXPRESSION_LANGUAGE_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()>();
return v;
label:
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 = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(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[])>("Sets the environment variable \'\u0001\' for the process\' environment");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder dynamic(boolean)>(1);
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()>();
return v;
}
protected java.util.Collection customValidate(org.apache.nifi.components.ValidationContext)
{
java.lang.Object[] v;
org.apache.nifi.components.ValidationContext v;
org.apache.nifi.logging.ComponentLog v;
org.apache.nifi.components.PropertyDescriptor v, v;
java.util.ArrayList v;
org.apache.nifi.components.PropertyValue v;
java.util.regex.Matcher v;
java.util.Map v;
java.lang.String v, v, v, v, v;
boolean v, v, v;
java.util.Iterator v;
java.util.Collection v;
java.util.Set v;
org.apache.nifi.components.AllowableValue v, v;
org.apache.nifi.processors.standard.ExecuteStreamCommand v;
java.lang.Object v;
java.util.regex.Pattern v;
v := @this: org.apache.nifi.processors.standard.ExecuteStreamCommand;
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.ExecuteStreamCommand: org.apache.nifi.components.PropertyDescriptor ARGUMENTS_STRATEGY>;
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 = <org.apache.nifi.processors.standard.ExecuteStreamCommand: org.apache.nifi.components.AllowableValue DYNAMIC_PROPERTY_ARGUMENTS_STRATEGY>;
v = virtualinvoke v.<org.apache.nifi.components.AllowableValue: java.lang.String getValue()>();
if v == v goto label;
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 = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor: java.lang.String getName()>();
v = <org.apache.nifi.processors.standard.ExecuteStreamCommand: java.util.regex.Pattern COMMAND_ARGUMENT_PATTERN>;
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 = v.<org.apache.nifi.processors.standard.ExecuteStreamCommand: org.apache.nifi.logging.ComponentLog logger>;
v = newarray (java.lang.Object)[3];
v = <org.apache.nifi.processors.standard.ExecuteStreamCommand: org.apache.nifi.components.PropertyDescriptor ARGUMENTS_STRATEGY>;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor: java.lang.String getDisplayName()>();
v[0] = v;
v = <org.apache.nifi.processors.standard.ExecuteStreamCommand: org.apache.nifi.components.AllowableValue DYNAMIC_PROPERTY_ARGUMENTS_STRATEGY>;
v = virtualinvoke v.<org.apache.nifi.components.AllowableValue: java.lang.String getDisplayName()>();
v[1] = v;
v[2] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void warn(java.lang.String,java.lang.Object[])>("[{}] should be set to [{}] when command arguments are supplied as Dynamic Properties. The property [{}] will be ignored.", v);
goto label;
label:
return v;
}
public void onTrigger(org.apache.nifi.processor.ProcessContext, org.apache.nifi.processor.ProcessSession) throws org.apache.nifi.processor.exception.ProcessException
{
byte[] v;
java.io.BufferedInputStream v;
java.lang.Integer v, v;
java.util.Map v, v, v;
org.apache.nifi.components.AllowableValue v;
java.lang.StringBuilder v, v, v;
java.lang.Object[] v, v, v, v, v, v, v;
org.apache.nifi.processors.standard.ExecuteStreamCommand$ProcessStreamWriterCallback v;
org.apache.nifi.processor.Relationship v, v, v, v;
java.io.IOException v, v, v, v;
org.apache.nifi.processor.ProcessSession v;
org.apache.nifi.components.PropertyValue v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.lang.SecurityException v;
java.lang.Process v;
int v, v, v, v, v, v, v, v;
java.lang.ProcessBuilder v;
java.io.FileInputStream v;
org.apache.nifi.processors.standard.ExecuteStreamCommand v;
java.lang.Object v, v, v, v, v, v, v, v, v;
java.util.Comparator v;
org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v, v, v, v;
java.util.regex.Matcher v;
java.util.Set v, v;
java.lang.Throwable v, v, v, v, v;
java.io.BufferedOutputStream v;
java.util.ArrayList v, v, v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.io.File v, v, v;
boolean v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.nifi.flowfile.FlowFile v, v, v, v, v;
java.util.List v;
java.util.regex.Pattern v;
java.lang.ProcessBuilder$Redirect v, v;
java.lang.String[] v;
java.util.HashMap v, v;
org.apache.nifi.logging.ComponentLog v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.nifi.processor.exception.ProcessException v, v;
java.io.OutputStream v;
java.util.Iterator v, v, v, v;
org.apache.nifi.processor.ProcessContext v;
char v;
java.io.InputStream v;
v := @this: org.apache.nifi.processors.standard.ExecuteStreamCommand;
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 null != v goto label;
return;
label:
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = <org.apache.nifi.processors.standard.ExecuteStreamCommand: org.apache.nifi.components.PropertyDescriptor PUT_OUTPUT_IN_ATTRIBUTE>;
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()>();
v = <org.apache.nifi.processors.standard.ExecuteStreamCommand: org.apache.nifi.components.PropertyDescriptor ARGUMENTS_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: boolean isSet()>();
if v == 0 goto label;
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.String getValue()>();
v = <org.apache.nifi.processors.standard.ExecuteStreamCommand: org.apache.nifi.components.AllowableValue DYNAMIC_PROPERTY_ARGUMENTS_STRATEGY>;
v = virtualinvoke v.<org.apache.nifi.components.AllowableValue: java.lang.String getValue()>();
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
v = <org.apache.nifi.processors.standard.ExecuteStreamCommand: org.apache.nifi.components.PropertyDescriptor PUT_ATTRIBUTE_MAX_LENGTH>;
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.Integer asInteger()>();
v = <org.apache.nifi.processors.standard.ExecuteStreamCommand: org.apache.nifi.components.PropertyDescriptor PUT_OUTPUT_IN_ATTRIBUTE>;
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.ExecuteStreamCommand: org.apache.nifi.components.PropertyDescriptor EXECUTION_COMMAND>;
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()>();
virtualinvoke v.<java.util.ArrayList: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.ExecuteStreamCommand: org.apache.nifi.components.PropertyDescriptor IGNORE_STDIN>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.String getValue()>();
v = staticinvoke <java.lang.Boolean: boolean parseBoolean(java.lang.String)>(v);
if v != 0 goto label;
v = <org.apache.nifi.processors.standard.ExecuteStreamCommand: org.apache.nifi.components.PropertyDescriptor EXECUTION_ARGUMENTS>;
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 <org.apache.commons.lang.StringUtils: boolean isBlank(java.lang.CharSequence)>(v);
if v != 0 goto label;
v = <org.apache.nifi.processors.standard.ExecuteStreamCommand: org.apache.nifi.components.PropertyDescriptor ARG_DELIMITER>;
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: char charAt(int)>(0);
v = staticinvoke <org.apache.nifi.processors.standard.util.ArgumentUtils: java.util.List splitArgs(java.lang.String,char)>(v, v);
virtualinvoke v.<java.util.ArrayList: boolean addAll(java.util.Collection)>(v);
goto label;
label:
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
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 = <org.apache.nifi.processors.standard.ExecuteStreamCommand: java.util.regex.Pattern COMMAND_ARGUMENT_PATTERN>;
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getKey()>();
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor: java.lang.String getName()>();
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()>();
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
v = staticinvoke <org.apache.nifi.processors.standard.ExecuteStreamCommand$lambda_onTrigger_1__75: java.util.Comparator bootstrap$()>();
interfaceinvoke v.<java.util.List: void sort(java.util.Comparator)>(v);
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.components.PropertyDescriptor: java.lang.String getName()>();
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(java.lang.String)>(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 = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor: boolean isSensitive()>();
if v == 0 goto label;
virtualinvoke v.<java.util.ArrayList: boolean add(java.lang.Object)>("********");
goto label;
label:
virtualinvoke v.<java.util.ArrayList: boolean add(java.lang.Object)>(v);
label:
virtualinvoke v.<java.util.ArrayList: boolean add(java.lang.Object)>(v);
goto label;
label:
v = virtualinvoke v.<java.util.ArrayList: int size()>();
if v <= 0 goto label;
v = new java.lang.StringBuilder;
specialinvoke v.<java.lang.StringBuilder: void <init>()>();
v = virtualinvoke v.<java.util.ArrayList: 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.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>("\t");
goto label;
label:
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.String toString()>();
v = virtualinvoke v.<java.lang.String: java.lang.String trim()>();
goto label;
label:
v = "";
label:
v = <org.apache.nifi.processors.standard.ExecuteStreamCommand: org.apache.nifi.components.PropertyDescriptor WORKING_DIR>;
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 = new java.lang.ProcessBuilder;
v = newarray (java.lang.String)[0];
specialinvoke v.<java.lang.ProcessBuilder: void <init>(java.lang.String[])>(v);
v = v.<org.apache.nifi.processors.standard.ExecuteStreamCommand: org.apache.nifi.logging.ComponentLog logger>;
v = newarray (java.lang.Object)[1];
v[0] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void debug(java.lang.String,java.lang.Object[])>("Executing and waiting for command: {}", v);
v = null;
v = staticinvoke <org.apache.commons.lang.StringUtils: boolean isBlank(java.lang.CharSequence)>(v);
if v != 0 goto label;
v = new java.io.File;
specialinvoke v.<java.io.File: void <init>(java.lang.String)>(v);
v = v;
v = virtualinvoke v.<java.io.File: boolean exists()>();
if v != 0 goto label;
v = virtualinvoke v.<java.io.File: boolean mkdirs()>();
if v != 0 goto label;
v = v.<org.apache.nifi.processors.standard.ExecuteStreamCommand: org.apache.nifi.logging.ComponentLog logger>;
v = newarray (java.lang.Object)[2];
v[0] = v;
v = staticinvoke <java.lang.System: java.lang.String getProperty(java.lang.String)>("user.dir");
v[1] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void warn(java.lang.String,java.lang.Object[])>("Failed to create working directory {}, using current working directory {}", v);
label:
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
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;
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getKey()>();
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor: java.lang.String getName()>();
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 = virtualinvoke v.<java.lang.ProcessBuilder: java.util.Map environment()>();
interfaceinvoke v.<java.util.Map: void putAll(java.util.Map)>(v);
virtualinvoke v.<java.lang.ProcessBuilder: java.lang.ProcessBuilder command(java.util.List)>(v);
virtualinvoke v.<java.lang.ProcessBuilder: java.lang.ProcessBuilder directory(java.io.File)>(v);
v = <java.lang.ProcessBuilder$Redirect: java.lang.ProcessBuilder$Redirect PIPE>;
virtualinvoke v.<java.lang.ProcessBuilder: java.lang.ProcessBuilder redirectInput(java.lang.ProcessBuilder$Redirect)>(v);
v = <java.lang.ProcessBuilder$Redirect: java.lang.ProcessBuilder$Redirect PIPE>;
virtualinvoke v.<java.lang.ProcessBuilder: java.lang.ProcessBuilder redirectOutput(java.lang.ProcessBuilder$Redirect)>(v);
label:
v = staticinvoke <java.io.File: java.io.File createTempFile(java.lang.String,java.lang.String)>("out", null);
virtualinvoke v.<java.lang.ProcessBuilder: java.lang.ProcessBuilder redirectError(java.io.File)>(v);
label:
goto label;
label:
v := @caughtexception;
v = v.<org.apache.nifi.processors.standard.ExecuteStreamCommand: org.apache.nifi.logging.ComponentLog logger>;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void error(java.lang.String,java.lang.Throwable)>("Could not create temporary file for error logging", v);
v = new org.apache.nifi.processor.exception.ProcessException;
specialinvoke v.<org.apache.nifi.processor.exception.ProcessException: void <init>(java.lang.Throwable)>(v);
throw v;
label:
v = virtualinvoke v.<java.lang.ProcessBuilder: java.lang.Process start()>();
label:
goto label;
label:
v := @caughtexception;
label:
v = virtualinvoke v.<java.io.File: boolean delete()>();
if v != 0 goto label;
v = v.<org.apache.nifi.processors.standard.ExecuteStreamCommand: org.apache.nifi.logging.ComponentLog logger>;
v = virtualinvoke v.<java.io.File: java.lang.String getAbsolutePath()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(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[])>("Unable to delete file: \u0001");
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void warn(java.lang.String)>(v);
label:
goto label;
label:
v := @caughtexception;
v = v.<org.apache.nifi.processors.standard.ExecuteStreamCommand: org.apache.nifi.logging.ComponentLog logger>;
v = virtualinvoke v.<java.io.File: java.lang.String getAbsolutePath()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.SecurityException)>(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[])>("Unable to delete file: \'\u0001\' due to \u0001");
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void warn(java.lang.String)>(v);
label:
v = v.<org.apache.nifi.processors.standard.ExecuteStreamCommand: org.apache.nifi.logging.ComponentLog logger>;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void error(java.lang.String,java.lang.Throwable)>("Could not create external process to run command", v);
v = new org.apache.nifi.processor.exception.ProcessException;
specialinvoke v.<org.apache.nifi.processor.exception.ProcessException: void <init>(java.lang.Throwable)>(v);
throw v;
label:
v = virtualinvoke v.<java.lang.Process: java.io.OutputStream getOutputStream()>();
label:
v = virtualinvoke v.<java.lang.Process: java.io.InputStream getInputStream()>();
label:
v = new java.io.BufferedInputStream;
specialinvoke v.<java.io.BufferedInputStream: void <init>(java.io.InputStream)>(v);
label:
v = new java.io.BufferedOutputStream;
specialinvoke v.<java.io.BufferedOutputStream: void <init>(java.io.OutputStream)>(v);
if v == 0 goto label;
v = v;
goto label;
label:
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile create(org.apache.nifi.flowfile.FlowFile)>(v);
label:
v = new org.apache.nifi.processors.standard.ExecuteStreamCommand$ProcessStreamWriterCallback;
v = v.<org.apache.nifi.processors.standard.ExecuteStreamCommand: org.apache.nifi.logging.ComponentLog logger>;
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
specialinvoke v.<org.apache.nifi.processors.standard.ExecuteStreamCommand$ProcessStreamWriterCallback: void <init>(boolean,java.io.OutputStream,java.io.InputStream,org.apache.nifi.logging.ComponentLog,java.lang.String,org.apache.nifi.processor.ProcessSession,org.apache.nifi.flowfile.FlowFile,java.lang.Process,boolean,int)>(v, v, v, v, v, v, v, v, v, v);
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void read(org.apache.nifi.flowfile.FlowFile,org.apache.nifi.processor.io.InputStreamCallback)>(v, v);
v = v.<org.apache.nifi.processors.standard.ExecuteStreamCommand$ProcessStreamWriterCallback: org.apache.nifi.flowfile.FlowFile outputFlowFile>;
if v == 0 goto label;
v = new java.lang.String;
v = v.<org.apache.nifi.processors.standard.ExecuteStreamCommand$ProcessStreamWriterCallback: byte[] outputBuffer>;
v = v.<org.apache.nifi.processors.standard.ExecuteStreamCommand$ProcessStreamWriterCallback: int size>;
specialinvoke v.<java.lang.String: void <init>(byte[],int,int)>(v, 0, 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, v, v);
label:
v = v.<org.apache.nifi.processors.standard.ExecuteStreamCommand$ProcessStreamWriterCallback: int exitCode>;
v = v.<org.apache.nifi.processors.standard.ExecuteStreamCommand: org.apache.nifi.logging.ComponentLog logger>;
v = newarray (java.lang.Object)[2];
v[0] = v;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[1] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void debug(java.lang.String,java.lang.Object[])>("Execution complete for command: {}.  Exited with code: {}", v);
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v = new java.lang.StringBuilder;
specialinvoke v.<java.lang.StringBuilder: void <init>()>();
label:
v = new java.io.FileInputStream;
specialinvoke v.<java.io.FileInputStream: void <init>(java.io.File)>(v);
label:
v = virtualinvoke v.<java.io.InputStream: int read()>();
v = (int) -1;
if v == v goto label;
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(char)>(v);
goto label;
label:
virtualinvoke v.<java.io.InputStream: void close()>();
goto label;
label:
v := @caughtexception;
throw v;
label:
v := @caughtexception;
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>("Unknown...could not read Process\'s Std Error");
label:
v = virtualinvoke v.<java.lang.StringBuilder: int length()>();
v = staticinvoke <java.lang.Math: int min(int,int)>(v, 4000);
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.String substring(int,int)>(0, v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("execution.error", v);
if v == 0 goto label;
v = <org.apache.nifi.processors.standard.ExecuteStreamCommand: org.apache.nifi.processor.Relationship ORIGINAL_RELATIONSHIP>;
goto label;
label:
if v == 0 goto label;
v = <org.apache.nifi.processors.standard.ExecuteStreamCommand: org.apache.nifi.processor.Relationship NONZERO_STATUS_RELATIONSHIP>;
goto label;
label:
v = <org.apache.nifi.processors.standard.ExecuteStreamCommand: org.apache.nifi.processor.Relationship OUTPUT_STREAM_RELATIONSHIP>;
label:
v = v;
if v != 0 goto label;
v = v.<org.apache.nifi.processors.standard.ExecuteStreamCommand: org.apache.nifi.logging.ComponentLog logger>;
v = newarray (java.lang.Object)[2];
v[0] = v;
v = virtualinvoke v.<org.apache.nifi.processor.Relationship: java.lang.String getName()>();
v[1] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void info(java.lang.String,java.lang.Object[])>("Transferring {} to {}", v);
goto label;
label:
v = v.<org.apache.nifi.processors.standard.ExecuteStreamCommand: org.apache.nifi.logging.ComponentLog logger>;
v = newarray (java.lang.Object)[4];
v[0] = v;
v = virtualinvoke v.<org.apache.nifi.processor.Relationship: java.lang.String getName()>();
v[1] = v;
v[2] = v;
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.String toString()>();
v[3] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void error(java.lang.String,java.lang.Object[])>("Transferring {} to {}. Executable command {} ended in an error: {}", v);
label:
v = staticinvoke <java.lang.Integer: java.lang.String toString(int)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("execution.status", v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("execution.command", v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("execution.command.args", v);
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 = <org.apache.nifi.processors.standard.ExecuteStreamCommand: org.apache.nifi.processor.Relationship NONZERO_STATUS_RELATIONSHIP>;
v = virtualinvoke v.<org.apache.nifi.processor.Relationship: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile penalize(org.apache.nifi.flowfile.FlowFile)>(v);
label:
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void transfer(org.apache.nifi.flowfile.FlowFile,org.apache.nifi.processor.Relationship)>(v, v);
if v != 0 goto label;
v = v.<org.apache.nifi.processors.standard.ExecuteStreamCommand: org.apache.nifi.logging.ComponentLog logger>;
v = newarray (java.lang.Object)[1];
v[0] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void info(java.lang.String,java.lang.Object[])>("Transferring {} to original", v);
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 = <org.apache.nifi.processors.standard.ExecuteStreamCommand: org.apache.nifi.processor.Relationship ORIGINAL_RELATIONSHIP>;
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void transfer(org.apache.nifi.flowfile.FlowFile,org.apache.nifi.processor.Relationship)>(v, v);
label:
virtualinvoke v.<java.io.BufferedInputStream: void close()>();
goto label;
label:
v := @caughtexception;
throw v;
label:
if v == null goto label;
virtualinvoke v.<java.io.InputStream: void close()>();
goto label;
label:
v := @caughtexception;
throw v;
label:
if v == null goto label;
virtualinvoke v.<java.io.OutputStream: void close()>();
goto label;
label:
v := @caughtexception;
throw v;
label:
staticinvoke <org.apache.commons.io.FileUtils: boolean deleteQuietly(java.io.File)>(v);
virtualinvoke v.<java.lang.Process: void destroy()>();
goto label;
label:
v := @caughtexception;
v = v.<org.apache.nifi.processors.standard.ExecuteStreamCommand: org.apache.nifi.logging.ComponentLog logger>;
v = newarray (java.lang.Object)[2];
v[0] = v;
v[1] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void warn(java.lang.String,java.lang.Object[])>("Problem terminating Process {}", v);
label:
staticinvoke <org.apache.commons.io.FileUtils: boolean deleteQuietly(java.io.File)>(v);
virtualinvoke v.<java.lang.Process: void destroy()>();
goto label;
label:
v := @caughtexception;
staticinvoke <org.apache.commons.io.FileUtils: boolean deleteQuietly(java.io.File)>(v);
virtualinvoke v.<java.lang.Process: void destroy()>();
throw v;
label:
return;
catch java.io.IOException from label to label with label;
catch java.io.IOException from label to label with label;
catch java.lang.SecurityException from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.io.IOException from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.io.IOException from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
}
private static void readStdoutReadable(boolean, java.io.OutputStream, org.apache.nifi.logging.ComponentLog, java.io.InputStream)
{
java.io.OutputStream v;
java.lang.Thread v;
org.apache.nifi.logging.ComponentLog v;
java.lang.Runnable v;
boolean v;
java.io.InputStream v;
v := @parameter: boolean;
v := @parameter: java.io.OutputStream;
v := @parameter: org.apache.nifi.logging.ComponentLog;
v := @parameter: java.io.InputStream;
v = new java.lang.Thread;
v = staticinvoke <org.apache.nifi.processors.standard.ExecuteStreamCommand$lambda_readStdoutReadable_2__76: java.lang.Runnable bootstrap$(boolean,java.io.InputStream,java.io.OutputStream,org.apache.nifi.logging.ComponentLog)>(v, v, v, v);
specialinvoke v.<java.lang.Thread: void <init>(java.lang.Runnable)>(v);
virtualinvoke v.<java.lang.Thread: void setDaemon(boolean)>(1);
virtualinvoke v.<java.lang.Thread: void start()>();
return;
}
static void <clinit>()
{
org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.nifi.expression.AttributeExpression$ResultType v;
java.util.Set v, v;
org.apache.nifi.components.AllowableValue v, v, v, v, v, v, v;
java.util.ArrayList v;
org.apache.nifi.processor.Relationship v, v, v, v, v, 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, v;
org.apache.nifi.expression.ExpressionLanguageScope v, v, v, v;
java.util.List v;
java.util.regex.Pattern v;
org.apache.nifi.components.AllowableValue[] v, v, v;
java.lang.String[] v;
java.util.HashSet v, v;
org.apache.nifi.components.Validator v, v, v, v, v, v, v, v;
org.apache.nifi.processor.Relationship$Builder v, v, v, v, v, v, v, v, 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)>("original");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship$Builder description(java.lang.String)>("The original FlowFile will be routed. It will have new attributes detailing the result of the script execution.");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship build()>();
<org.apache.nifi.processors.standard.ExecuteStreamCommand: org.apache.nifi.processor.Relationship ORIGINAL_RELATIONSHIP> = 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)>("output stream");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship$Builder description(java.lang.String)>("The destination path for the flow file created from the command\'s output, if the returned status code is zero.");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship build()>();
<org.apache.nifi.processors.standard.ExecuteStreamCommand: org.apache.nifi.processor.Relationship OUTPUT_STREAM_RELATIONSHIP> = 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)>("nonzero status");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship$Builder description(java.lang.String)>("The destination path for the flow file created from the command\'s output, if the returned status code is non-zero. All flow files routed to this relationship will be penalized.");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship build()>();
<org.apache.nifi.processors.standard.ExecuteStreamCommand: org.apache.nifi.processor.Relationship NONZERO_STATUS_RELATIONSHIP> = v;
v = staticinvoke <java.util.regex.Pattern: java.util.regex.Pattern compile(java.lang.String)>("command\\.argument\\.(?<commandIndex>[0-9]+)$");
<org.apache.nifi.processors.standard.ExecuteStreamCommand: java.util.regex.Pattern COMMAND_ARGUMENT_PATTERN> = 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)>("Command Arguments Property", "Command Arguments Property", "Arguments to be supplied to the executable are taken from the Command Arguments property");
<org.apache.nifi.processors.standard.ExecuteStreamCommand: org.apache.nifi.components.AllowableValue EXECUTION_ARGUMENTS_PROPERTY_STRATEGY> = 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)>("Dynamic Property Arguments", "Dynamic Property Arguments", "Arguments to be supplied to the executable are taken from dynamic properties with pattern of \'command.argument.<commandIndex>\'");
<org.apache.nifi.processors.standard.ExecuteStreamCommand: org.apache.nifi.components.AllowableValue DYNAMIC_PROPERTY_ARGUMENTS_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)>("Working Directory");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("The directory to use as the current working directory when executing the command");
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 createDirectoryExistsValidator(boolean,boolean)>(1, 1);
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 build()>();
<org.apache.nifi.processors.standard.ExecuteStreamCommand: org.apache.nifi.components.PropertyDescriptor WORKING_DIR> = v;
v = <org.apache.nifi.expression.AttributeExpression$ResultType: org.apache.nifi.expression.AttributeExpression$ResultType STRING>;
v = staticinvoke <org.apache.nifi.processor.util.StandardValidators: org.apache.nifi.components.Validator createAttributeExpressionLanguageValidator(org.apache.nifi.expression.AttributeExpression$ResultType,boolean)>(v, 1);
<org.apache.nifi.processors.standard.ExecuteStreamCommand: org.apache.nifi.components.Validator ATTRIBUTE_EXPRESSION_LANGUAGE_VALIDATOR> = 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)>("Command Path");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("Specifies the command to be executed; if just the name of an executable is provided, it must be in the user\'s environment PATH.");
v = <org.apache.nifi.expression.ExpressionLanguageScope: org.apache.nifi.expression.ExpressionLanguageScope FLOWFILE_ATTRIBUTES>;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder expressionLanguageSupported(org.apache.nifi.expression.ExpressionLanguageScope)>(v);
v = <org.apache.nifi.processors.standard.ExecuteStreamCommand: org.apache.nifi.components.Validator ATTRIBUTE_EXPRESSION_LANGUAGE_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 required(boolean)>(1);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.ExecuteStreamCommand: org.apache.nifi.components.PropertyDescriptor EXECUTION_COMMAND> = 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)>("argumentsStrategy");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder displayName(java.lang.String)>("Command Arguments Strategy");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("Strategy for configuring arguments to be supplied to the command.");
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 required(boolean)>(0);
v = newarray (org.apache.nifi.components.AllowableValue)[2];
v = <org.apache.nifi.processors.standard.ExecuteStreamCommand: org.apache.nifi.components.AllowableValue EXECUTION_ARGUMENTS_PROPERTY_STRATEGY>;
v[0] = v;
v = <org.apache.nifi.processors.standard.ExecuteStreamCommand: org.apache.nifi.components.AllowableValue DYNAMIC_PROPERTY_ARGUMENTS_STRATEGY>;
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.ExecuteStreamCommand: org.apache.nifi.components.AllowableValue EXECUTION_ARGUMENTS_PROPERTY_STRATEGY>;
v = virtualinvoke v.<org.apache.nifi.components.AllowableValue: java.lang.String getValue()>();
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder defaultValue(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.ExecuteStreamCommand: org.apache.nifi.components.PropertyDescriptor ARGUMENTS_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)>("Command Arguments");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("The arguments to supply to the executable delimited by the \';\' character.");
v = <org.apache.nifi.processors.standard.ExecuteStreamCommand: org.apache.nifi.components.PropertyDescriptor ARGUMENTS_STRATEGY>;
v = newarray (org.apache.nifi.components.AllowableValue)[1];
v = <org.apache.nifi.processors.standard.ExecuteStreamCommand: org.apache.nifi.components.AllowableValue EXECUTION_ARGUMENTS_PROPERTY_STRATEGY>;
v[0] = v;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder dependsOn(org.apache.nifi.components.PropertyDescriptor,org.apache.nifi.components.AllowableValue[])>(v, 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 = staticinvoke <org.apache.nifi.processors.standard.ExecuteStreamCommand$lambda_static_0__77: org.apache.nifi.components.Validator bootstrap$()>();
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.ExecuteStreamCommand: org.apache.nifi.components.PropertyDescriptor EXECUTION_ARGUMENTS> = 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)>("Argument Delimiter");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("Delimiter to use to separate arguments for a command [default: ;]. Must be a single character");
v = <org.apache.nifi.processors.standard.ExecuteStreamCommand: org.apache.nifi.components.PropertyDescriptor ARGUMENTS_STRATEGY>;
v = newarray (org.apache.nifi.components.AllowableValue)[1];
v = <org.apache.nifi.processors.standard.ExecuteStreamCommand: org.apache.nifi.components.AllowableValue EXECUTION_ARGUMENTS_PROPERTY_STRATEGY>;
v[0] = v;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder dependsOn(org.apache.nifi.components.PropertyDescriptor,org.apache.nifi.components.AllowableValue[])>(v, v);
v = <org.apache.nifi.processor.util.StandardValidators: org.apache.nifi.components.Validator SINGLE_CHAR_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 required(boolean)>(1);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder defaultValue(java.lang.String)>(";");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.ExecuteStreamCommand: org.apache.nifi.components.PropertyDescriptor ARG_DELIMITER> = 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)>("Ignore STDIN");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("If true, the contents of the incoming flowfile will not be passed to the executing command");
v = <org.apache.nifi.components.Validator: org.apache.nifi.components.Validator VALID>;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder addValidator(org.apache.nifi.components.Validator)>(v);
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.ExecuteStreamCommand: org.apache.nifi.components.PropertyDescriptor IGNORE_STDIN> = 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 Destination Attribute");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("If set, the output of the stream command will be put into an attribute of the original FlowFile instead of a separate FlowFile. There will no longer be a relationship for \'output stream\' or \'nonzero status\'. The value of this property will be the key for the output attribute.");
v = <org.apache.nifi.processor.util.StandardValidators: org.apache.nifi.components.Validator ATTRIBUTE_KEY_PROPERTY_NAME_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.ExecuteStreamCommand: org.apache.nifi.components.PropertyDescriptor PUT_OUTPUT_IN_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)>("Max Attribute Length");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("If routing the output of the stream command to an attribute, the number of characters put to the attribute value will be at most this amount. This is important because attributes are held in memory and large attributes will quickly cause out of memory issues. If the output goes longer than this value, it will truncated to fit. Consider making this smaller if able.");
v = <org.apache.nifi.processor.util.StandardValidators: org.apache.nifi.components.Validator POSITIVE_INTEGER_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)>("256");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.ExecuteStreamCommand: org.apache.nifi.components.PropertyDescriptor PUT_ATTRIBUTE_MAX_LENGTH> = v;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = <org.apache.nifi.processors.standard.ExecuteStreamCommand: org.apache.nifi.components.PropertyDescriptor WORKING_DIR>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.ExecuteStreamCommand: org.apache.nifi.components.PropertyDescriptor EXECUTION_COMMAND>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.ExecuteStreamCommand: org.apache.nifi.components.PropertyDescriptor ARGUMENTS_STRATEGY>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.ExecuteStreamCommand: org.apache.nifi.components.PropertyDescriptor EXECUTION_ARGUMENTS>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.ExecuteStreamCommand: org.apache.nifi.components.PropertyDescriptor ARG_DELIMITER>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.ExecuteStreamCommand: org.apache.nifi.components.PropertyDescriptor IGNORE_STDIN>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.ExecuteStreamCommand: org.apache.nifi.components.PropertyDescriptor PUT_OUTPUT_IN_ATTRIBUTE>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.ExecuteStreamCommand: org.apache.nifi.components.PropertyDescriptor PUT_ATTRIBUTE_MAX_LENGTH>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = staticinvoke <java.util.Collections: java.util.List unmodifiableList(java.util.List)>(v);
<org.apache.nifi.processors.standard.ExecuteStreamCommand: java.util.List PROPERTIES> = v;
v = new java.util.HashSet;
specialinvoke v.<java.util.HashSet: void <init>()>();
v = <org.apache.nifi.processors.standard.ExecuteStreamCommand: org.apache.nifi.processor.Relationship OUTPUT_STREAM_RELATIONSHIP>;
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.ExecuteStreamCommand: org.apache.nifi.processor.Relationship ORIGINAL_RELATIONSHIP>;
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.ExecuteStreamCommand: org.apache.nifi.processor.Relationship NONZERO_STATUS_RELATIONSHIP>;
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
v = staticinvoke <java.util.Collections: java.util.Set unmodifiableSet(java.util.Set)>(v);
<org.apache.nifi.processors.standard.ExecuteStreamCommand: java.util.Set OUTPUT_STREAM_RELATIONSHIP_SET> = v;
v = new java.util.HashSet;
specialinvoke v.<java.util.HashSet: void <init>()>();
v = <org.apache.nifi.processors.standard.ExecuteStreamCommand: org.apache.nifi.processor.Relationship ORIGINAL_RELATIONSHIP>;
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
v = staticinvoke <java.util.Collections: java.util.Set unmodifiableSet(java.util.Set)>(v);
<org.apache.nifi.processors.standard.ExecuteStreamCommand: java.util.Set ATTRIBUTE_RELATIONSHIP_SET> = v;
return;
}
}