public class org.apache.nifi.processors.standard.DebugFlow extends org.apache.nifi.processor.AbstractProcessor
{
private final java.util.concurrent.atomic.AtomicReference relationships;
static final org.apache.nifi.processor.Relationship REL_SUCCESS;
static final org.apache.nifi.processor.Relationship REL_FAILURE;
private final java.util.concurrent.atomic.AtomicReference propertyDescriptors;
static final org.apache.nifi.components.PropertyDescriptor FF_SUCCESS_ITERATIONS;
static final org.apache.nifi.components.PropertyDescriptor FF_FAILURE_ITERATIONS;
static final org.apache.nifi.components.PropertyDescriptor FF_ROLLBACK_ITERATIONS;
static final org.apache.nifi.components.PropertyDescriptor FF_ROLLBACK_YIELD_ITERATIONS;
static final org.apache.nifi.components.PropertyDescriptor FF_ROLLBACK_PENALTY_ITERATIONS;
static final org.apache.nifi.components.PropertyDescriptor FF_EXCEPTION_ITERATIONS;
static final org.apache.nifi.components.PropertyDescriptor FF_EXCEPTION_CLASS;
static final org.apache.nifi.components.PropertyDescriptor NO_FF_SKIP_ITERATIONS;
static final org.apache.nifi.components.PropertyDescriptor NO_FF_EXCEPTION_ITERATIONS;
static final org.apache.nifi.components.PropertyDescriptor NO_FF_YIELD_ITERATIONS;
static final org.apache.nifi.components.PropertyDescriptor NO_FF_EXCEPTION_CLASS;
static final org.apache.nifi.components.PropertyDescriptor WRITE_ITERATIONS;
static final org.apache.nifi.components.PropertyDescriptor CONTENT_SIZE;
static final org.apache.nifi.components.PropertyDescriptor ON_SCHEDULED_SLEEP_TIME;
static final org.apache.nifi.components.PropertyDescriptor ON_SCHEDULED_FAIL;
static final org.apache.nifi.components.PropertyDescriptor ON_UNSCHEDULED_SLEEP_TIME;
static final org.apache.nifi.components.PropertyDescriptor ON_UNSCHEDULED_FAIL;
static final org.apache.nifi.components.PropertyDescriptor ON_STOPPED_SLEEP_TIME;
static final org.apache.nifi.components.PropertyDescriptor ON_STOPPED_FAIL;
static final org.apache.nifi.components.PropertyDescriptor ON_TRIGGER_SLEEP_TIME;
static final org.apache.nifi.components.PropertyDescriptor CUSTOM_VALIDATE_SLEEP_TIME;
static final org.apache.nifi.components.PropertyDescriptor IGNORE_INTERRUPTS;
private volatile java.lang.Integer flowFileMaxSuccess;
private volatile java.lang.Integer flowFileMaxFailure;
private volatile java.lang.Integer flowFileMaxRollback;
private volatile java.lang.Integer flowFileMaxYield;
private volatile java.lang.Integer flowFileMaxPenalty;
private volatile java.lang.Integer flowFileMaxException;
private volatile java.lang.Integer noFlowFileMaxSkip;
private volatile java.lang.Integer noFlowFileMaxException;
private volatile java.lang.Integer noFlowFileMaxYield;
private volatile java.lang.Integer flowFileCurrSuccess;
private volatile java.lang.Integer flowFileCurrFailure;
private volatile java.lang.Integer flowFileCurrRollback;
private volatile java.lang.Integer flowFileCurrYield;
private volatile java.lang.Integer flowFileCurrPenalty;
private volatile java.lang.Integer flowFileCurrException;
private volatile java.lang.Integer noFlowFileCurrSkip;
private volatile java.lang.Integer noFlowFileCurrException;
private volatile java.lang.Integer noFlowFileCurrYield;
private volatile java.lang.Class flowFileExceptionClass;
private volatile java.lang.Class noFlowFileExceptionClass;
private final org.apache.nifi.processors.standard.DebugFlow$FlowFileResponse curr_ff_resp;
private final org.apache.nifi.processors.standard.DebugFlow$NoFlowFileResponse curr_noff_resp;
public void <init>()
{
java.lang.Integer v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.util.concurrent.atomic.AtomicReference v, v;
org.apache.nifi.processors.standard.DebugFlow$FlowFileResponse v;
org.apache.nifi.processors.standard.DebugFlow v;
org.apache.nifi.processors.standard.DebugFlow$NoFlowFileResponse v;
v := @this: org.apache.nifi.processors.standard.DebugFlow;
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.DebugFlow: java.util.concurrent.atomic.AtomicReference relationships> = v;
v = new java.util.concurrent.atomic.AtomicReference;
specialinvoke v.<java.util.concurrent.atomic.AtomicReference: void <init>()>();
v.<org.apache.nifi.processors.standard.DebugFlow: java.util.concurrent.atomic.AtomicReference propertyDescriptors> = v;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(0);
v.<org.apache.nifi.processors.standard.DebugFlow: java.lang.Integer flowFileMaxSuccess> = v;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(0);
v.<org.apache.nifi.processors.standard.DebugFlow: java.lang.Integer flowFileMaxFailure> = v;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(0);
v.<org.apache.nifi.processors.standard.DebugFlow: java.lang.Integer flowFileMaxRollback> = v;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(0);
v.<org.apache.nifi.processors.standard.DebugFlow: java.lang.Integer flowFileMaxYield> = v;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(0);
v.<org.apache.nifi.processors.standard.DebugFlow: java.lang.Integer flowFileMaxPenalty> = v;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(0);
v.<org.apache.nifi.processors.standard.DebugFlow: java.lang.Integer flowFileMaxException> = v;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(0);
v.<org.apache.nifi.processors.standard.DebugFlow: java.lang.Integer noFlowFileMaxSkip> = v;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(0);
v.<org.apache.nifi.processors.standard.DebugFlow: java.lang.Integer noFlowFileMaxException> = v;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(0);
v.<org.apache.nifi.processors.standard.DebugFlow: java.lang.Integer noFlowFileMaxYield> = v;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(0);
v.<org.apache.nifi.processors.standard.DebugFlow: java.lang.Integer flowFileCurrSuccess> = v;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(0);
v.<org.apache.nifi.processors.standard.DebugFlow: java.lang.Integer flowFileCurrFailure> = v;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(0);
v.<org.apache.nifi.processors.standard.DebugFlow: java.lang.Integer flowFileCurrRollback> = v;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(0);
v.<org.apache.nifi.processors.standard.DebugFlow: java.lang.Integer flowFileCurrYield> = v;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(0);
v.<org.apache.nifi.processors.standard.DebugFlow: java.lang.Integer flowFileCurrPenalty> = v;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(0);
v.<org.apache.nifi.processors.standard.DebugFlow: java.lang.Integer flowFileCurrException> = v;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(0);
v.<org.apache.nifi.processors.standard.DebugFlow: java.lang.Integer noFlowFileCurrSkip> = v;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(0);
v.<org.apache.nifi.processors.standard.DebugFlow: java.lang.Integer noFlowFileCurrException> = v;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(0);
v.<org.apache.nifi.processors.standard.DebugFlow: java.lang.Integer noFlowFileCurrYield> = v;
v.<org.apache.nifi.processors.standard.DebugFlow: java.lang.Class flowFileExceptionClass> = null;
v.<org.apache.nifi.processors.standard.DebugFlow: java.lang.Class noFlowFileExceptionClass> = null;
v = new org.apache.nifi.processors.standard.DebugFlow$FlowFileResponse;
specialinvoke v.<org.apache.nifi.processors.standard.DebugFlow$FlowFileResponse: void <init>(org.apache.nifi.processors.standard.DebugFlow)>(v);
v.<org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.processors.standard.DebugFlow$FlowFileResponse curr_ff_resp> = v;
v = new org.apache.nifi.processors.standard.DebugFlow$NoFlowFileResponse;
specialinvoke v.<org.apache.nifi.processors.standard.DebugFlow$NoFlowFileResponse: void <init>(org.apache.nifi.processors.standard.DebugFlow)>(v);
v.<org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.processors.standard.DebugFlow$NoFlowFileResponse curr_noff_resp> = v;
return;
}
public java.util.Set getRelationships()
{
java.lang.Throwable v;
java.util.Set v;
org.apache.nifi.processors.standard.DebugFlow v;
java.util.concurrent.atomic.AtomicReference v, v, v, v;
java.util.HashSet v;
org.apache.nifi.processor.Relationship v, v;
java.lang.Object v, v;
v := @this: org.apache.nifi.processors.standard.DebugFlow;
v = v.<org.apache.nifi.processors.standard.DebugFlow: java.util.concurrent.atomic.AtomicReference relationships>;
entermonitor v;
label:
v = v.<org.apache.nifi.processors.standard.DebugFlow: java.util.concurrent.atomic.AtomicReference relationships>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: java.lang.Object get()>();
if v != null goto label;
v = new java.util.HashSet;
specialinvoke v.<java.util.HashSet: void <init>()>();
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.processor.Relationship REL_SUCCESS>;
virtualinvoke v.<java.util.HashSet: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.processor.Relationship REL_FAILURE>;
virtualinvoke v.<java.util.HashSet: boolean add(java.lang.Object)>(v);
v = v.<org.apache.nifi.processors.standard.DebugFlow: java.util.concurrent.atomic.AtomicReference relationships>;
v = staticinvoke <java.util.Collections: java.util.Set unmodifiableSet(java.util.Set)>(v);
virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: boolean compareAndSet(java.lang.Object,java.lang.Object)>(null, v);
label:
v = v.<org.apache.nifi.processors.standard.DebugFlow: java.util.concurrent.atomic.AtomicReference relationships>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: java.lang.Object get()>();
exitmonitor v;
label:
return v;
label:
v := @caughtexception;
exitmonitor v;
throw v;
catch java.lang.Throwable from label to label with label;
}
protected java.util.List getSupportedPropertyDescriptors()
{
org.apache.nifi.components.PropertyDescriptor 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.processors.standard.DebugFlow v;
java.util.List v;
java.lang.Throwable v;
java.util.concurrent.atomic.AtomicReference v, v, v, v;
java.util.ArrayList v;
java.lang.Object v, v;
v := @this: org.apache.nifi.processors.standard.DebugFlow;
v = v.<org.apache.nifi.processors.standard.DebugFlow: java.util.concurrent.atomic.AtomicReference propertyDescriptors>;
entermonitor v;
label:
v = v.<org.apache.nifi.processors.standard.DebugFlow: java.util.concurrent.atomic.AtomicReference propertyDescriptors>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: java.lang.Object get()>();
if v != null goto label;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor FF_SUCCESS_ITERATIONS>;
virtualinvoke v.<java.util.ArrayList: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor FF_FAILURE_ITERATIONS>;
virtualinvoke v.<java.util.ArrayList: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor FF_ROLLBACK_ITERATIONS>;
virtualinvoke v.<java.util.ArrayList: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor FF_ROLLBACK_YIELD_ITERATIONS>;
virtualinvoke v.<java.util.ArrayList: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor FF_ROLLBACK_PENALTY_ITERATIONS>;
virtualinvoke v.<java.util.ArrayList: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor FF_EXCEPTION_ITERATIONS>;
virtualinvoke v.<java.util.ArrayList: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor FF_EXCEPTION_CLASS>;
virtualinvoke v.<java.util.ArrayList: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor NO_FF_SKIP_ITERATIONS>;
virtualinvoke v.<java.util.ArrayList: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor NO_FF_EXCEPTION_ITERATIONS>;
virtualinvoke v.<java.util.ArrayList: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor NO_FF_YIELD_ITERATIONS>;
virtualinvoke v.<java.util.ArrayList: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor NO_FF_EXCEPTION_CLASS>;
virtualinvoke v.<java.util.ArrayList: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor WRITE_ITERATIONS>;
virtualinvoke v.<java.util.ArrayList: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor CONTENT_SIZE>;
virtualinvoke v.<java.util.ArrayList: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor ON_SCHEDULED_SLEEP_TIME>;
virtualinvoke v.<java.util.ArrayList: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor ON_SCHEDULED_FAIL>;
virtualinvoke v.<java.util.ArrayList: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor ON_UNSCHEDULED_SLEEP_TIME>;
virtualinvoke v.<java.util.ArrayList: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor ON_UNSCHEDULED_FAIL>;
virtualinvoke v.<java.util.ArrayList: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor ON_STOPPED_SLEEP_TIME>;
virtualinvoke v.<java.util.ArrayList: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor ON_STOPPED_FAIL>;
virtualinvoke v.<java.util.ArrayList: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor ON_TRIGGER_SLEEP_TIME>;
virtualinvoke v.<java.util.ArrayList: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor CUSTOM_VALIDATE_SLEEP_TIME>;
virtualinvoke v.<java.util.ArrayList: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor IGNORE_INTERRUPTS>;
virtualinvoke v.<java.util.ArrayList: boolean add(java.lang.Object)>(v);
v = v.<org.apache.nifi.processors.standard.DebugFlow: java.util.concurrent.atomic.AtomicReference propertyDescriptors>;
v = staticinvoke <java.util.Collections: java.util.List unmodifiableList(java.util.List)>(v);
virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: boolean compareAndSet(java.lang.Object,java.lang.Object)>(null, v);
label:
v = v.<org.apache.nifi.processors.standard.DebugFlow: java.util.concurrent.atomic.AtomicReference propertyDescriptors>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: java.lang.Object get()>();
exitmonitor v;
label:
return v;
label:
v := @caughtexception;
exitmonitor v;
throw v;
catch java.lang.Throwable from label to label with label;
}
public void onScheduled(org.apache.nifi.processor.ProcessContext) throws java.lang.ClassNotFoundException, java.lang.InterruptedException
{
java.lang.Integer v, v, v, v, v, v, v, v, v;
org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.nifi.components.PropertyValue v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.lang.Long v;
boolean v, v;
org.apache.nifi.processors.standard.DebugFlow$FlowFileResponse v;
org.apache.nifi.processors.standard.DebugFlow v;
long v;
java.lang.Boolean v, v;
java.lang.String v, v;
org.apache.nifi.processor.ProcessContext v;
org.apache.nifi.processors.standard.DebugFlow$NoFlowFileResponse v;
java.util.concurrent.TimeUnit v;
java.lang.Class v, v;
v := @this: org.apache.nifi.processors.standard.DebugFlow;
v := @parameter: org.apache.nifi.processor.ProcessContext;
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor FF_SUCCESS_ITERATIONS>;
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.DebugFlow: java.lang.Integer flowFileMaxSuccess> = v;
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor FF_FAILURE_ITERATIONS>;
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.DebugFlow: java.lang.Integer flowFileMaxFailure> = v;
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor FF_ROLLBACK_YIELD_ITERATIONS>;
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.DebugFlow: java.lang.Integer flowFileMaxYield> = v;
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor FF_ROLLBACK_ITERATIONS>;
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.DebugFlow: java.lang.Integer flowFileMaxRollback> = v;
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor FF_ROLLBACK_PENALTY_ITERATIONS>;
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.DebugFlow: java.lang.Integer flowFileMaxPenalty> = v;
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor FF_EXCEPTION_ITERATIONS>;
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.DebugFlow: java.lang.Integer flowFileMaxException> = v;
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor NO_FF_EXCEPTION_ITERATIONS>;
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.DebugFlow: java.lang.Integer noFlowFileMaxException> = v;
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor NO_FF_YIELD_ITERATIONS>;
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.DebugFlow: java.lang.Integer noFlowFileMaxYield> = v;
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor NO_FF_SKIP_ITERATIONS>;
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.DebugFlow: java.lang.Integer noFlowFileMaxSkip> = v;
v = v.<org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.processors.standard.DebugFlow$FlowFileResponse curr_ff_resp>;
virtualinvoke v.<org.apache.nifi.processors.standard.DebugFlow$FlowFileResponse: void reset()>();
v = v.<org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.processors.standard.DebugFlow$NoFlowFileResponse curr_noff_resp>;
virtualinvoke v.<org.apache.nifi.processors.standard.DebugFlow$NoFlowFileResponse: void reset()>();
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor FF_EXCEPTION_CLASS>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = virtualinvoke v.<java.lang.Object: java.lang.String toString()>();
v = staticinvoke <java.lang.Class: java.lang.Class forName(java.lang.String)>(v);
v.<org.apache.nifi.processors.standard.DebugFlow: java.lang.Class flowFileExceptionClass> = v;
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor NO_FF_EXCEPTION_CLASS>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = virtualinvoke v.<java.lang.Object: java.lang.String toString()>();
v = staticinvoke <java.lang.Class: java.lang.Class forName(java.lang.String)>(v);
v.<org.apache.nifi.processors.standard.DebugFlow: java.lang.Class noFlowFileExceptionClass> = v;
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor ON_SCHEDULED_SLEEP_TIME>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit MILLISECONDS>;
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.Long asTimePeriod(java.util.concurrent.TimeUnit)>(v);
v = virtualinvoke v.<java.lang.Long: long longValue()>();
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor IGNORE_INTERRUPTS>;
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()>();
specialinvoke v.<org.apache.nifi.processors.standard.DebugFlow: void sleep(long,boolean)>(v, v);
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor ON_SCHEDULED_FAIL>;
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()>();
specialinvoke v.<org.apache.nifi.processors.standard.DebugFlow: void fail(boolean,java.lang.Class)>(v, class "Lorg/apache/nifi/annotation/lifecycle/OnScheduled;");
return;
}
public void onUnscheduled(org.apache.nifi.processor.ProcessContext) throws java.lang.InterruptedException
{
org.apache.nifi.processor.ProcessContext v;
long v;
org.apache.nifi.processors.standard.DebugFlow v;
org.apache.nifi.components.PropertyDescriptor v, v, v;
org.apache.nifi.components.PropertyValue v, v, v;
java.util.concurrent.TimeUnit v;
java.lang.Long v;
java.lang.Boolean v, v;
boolean v, v;
v := @this: org.apache.nifi.processors.standard.DebugFlow;
v := @parameter: org.apache.nifi.processor.ProcessContext;
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor ON_UNSCHEDULED_SLEEP_TIME>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit MILLISECONDS>;
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.Long asTimePeriod(java.util.concurrent.TimeUnit)>(v);
v = virtualinvoke v.<java.lang.Long: long longValue()>();
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor IGNORE_INTERRUPTS>;
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()>();
specialinvoke v.<org.apache.nifi.processors.standard.DebugFlow: void sleep(long,boolean)>(v, v);
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor ON_UNSCHEDULED_FAIL>;
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()>();
specialinvoke v.<org.apache.nifi.processors.standard.DebugFlow: void fail(boolean,java.lang.Class)>(v, class "Lorg/apache/nifi/annotation/lifecycle/OnUnscheduled;");
return;
}
public void onStopped(org.apache.nifi.processor.ProcessContext) throws java.lang.InterruptedException
{
long v;
org.apache.nifi.components.PropertyDescriptor v, v, v;
org.apache.nifi.components.PropertyValue v, v, v, v;
java.lang.Long v;
java.lang.Boolean v, v;
boolean v, v;
org.apache.nifi.processor.ProcessContext v;
org.apache.nifi.processors.standard.DebugFlow v;
java.util.concurrent.TimeUnit v;
v := @this: org.apache.nifi.processors.standard.DebugFlow;
v := @parameter: org.apache.nifi.processor.ProcessContext;
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor ON_STOPPED_SLEEP_TIME>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: org.apache.nifi.components.PropertyValue evaluateAttributeExpressions()>();
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit MILLISECONDS>;
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.Long asTimePeriod(java.util.concurrent.TimeUnit)>(v);
v = virtualinvoke v.<java.lang.Long: long longValue()>();
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor IGNORE_INTERRUPTS>;
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()>();
specialinvoke v.<org.apache.nifi.processors.standard.DebugFlow: void sleep(long,boolean)>(v, v);
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor ON_STOPPED_FAIL>;
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()>();
specialinvoke v.<org.apache.nifi.processors.standard.DebugFlow: void fail(boolean,java.lang.Class)>(v, class "Lorg/apache/nifi/annotation/lifecycle/OnStopped;");
return;
}
protected java.util.Collection customValidate(org.apache.nifi.components.ValidationContext)
{
org.apache.nifi.components.ValidationContext v;
long v;
org.apache.nifi.components.PropertyDescriptor v, v;
org.apache.nifi.components.PropertyValue v, v;
java.lang.Long v;
java.lang.Thread v;
java.lang.Boolean v;
org.apache.nifi.components.ValidationResult v;
boolean v;
org.apache.nifi.components.ValidationResult$Builder v, v, v, v;
java.util.Collection v;
java.util.Set v;
org.apache.nifi.processors.standard.DebugFlow v;
java.util.concurrent.TimeUnit v;
java.lang.InterruptedException v;
v := @this: org.apache.nifi.processors.standard.DebugFlow;
v := @parameter: org.apache.nifi.components.ValidationContext;
label:
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor CUSTOM_VALIDATE_SLEEP_TIME>;
v = interfaceinvoke v.<org.apache.nifi.components.ValidationContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit MILLISECONDS>;
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.Long asTimePeriod(java.util.concurrent.TimeUnit)>(v);
v = virtualinvoke v.<java.lang.Long: long longValue()>();
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor IGNORE_INTERRUPTS>;
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.Boolean asBoolean()>();
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
specialinvoke v.<org.apache.nifi.processors.standard.DebugFlow: void sleep(long,boolean)>(v, v);
label:
goto label;
label:
v := @caughtexception;
v = staticinvoke <java.lang.Thread: java.lang.Thread currentThread()>();
virtualinvoke v.<java.lang.Thread: void interrupt()>();
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 valid(boolean)>(0);
v = virtualinvoke v.<org.apache.nifi.components.ValidationResult$Builder: org.apache.nifi.components.ValidationResult$Builder subject(java.lang.String)>("Validation");
v = virtualinvoke v.<org.apache.nifi.components.ValidationResult$Builder: org.apache.nifi.components.ValidationResult$Builder explanation(java.lang.String)>("Processor Interrupted while performing validation");
v = virtualinvoke v.<org.apache.nifi.components.ValidationResult$Builder: org.apache.nifi.components.ValidationResult build()>();
v = staticinvoke <java.util.Collections: java.util.Set singleton(java.lang.Object)>(v);
return v;
label:
v = specialinvoke v.<org.apache.nifi.processor.AbstractProcessor: java.util.Collection customValidate(org.apache.nifi.components.ValidationContext)>(v);
return v;
catch java.lang.InterruptedException from label to label with label;
}
private void sleep(long, boolean) throws java.lang.InterruptedException
{
long v, v, v, v, v, v, v;
org.apache.nifi.processors.standard.DebugFlow v;
byte v, v;
java.lang.InterruptedException v;
java.lang.Thread v;
boolean v;
v := @this: org.apache.nifi.processors.standard.DebugFlow;
v := @parameter: long;
v := @parameter: boolean;
v = v cmp 0L;
if v <= 0 goto label;
v = staticinvoke <java.lang.System: long currentTimeMillis()>();
v = v + v;
label:
v = staticinvoke <java.lang.System: long currentTimeMillis()>();
v = v cmp v;
if v >= 0 goto label;
label:
v = staticinvoke <java.lang.System: long currentTimeMillis()>();
v = v - v;
v = staticinvoke <java.lang.Math: long max(long,long)>(1L, v);
staticinvoke <java.lang.Thread: void sleep(long)>(v);
label:
goto label;
label:
v := @caughtexception;
if v != 0 goto label;
v = staticinvoke <java.lang.Thread: java.lang.Thread currentThread()>();
virtualinvoke v.<java.lang.Thread: void interrupt()>();
throw v;
label:
return;
catch java.lang.InterruptedException from label to label with label;
}
private void fail(boolean, java.lang.Class)
{
java.lang.Class v;
org.apache.nifi.processors.standard.DebugFlow v;
java.lang.RuntimeException v;
java.lang.String v, v;
boolean v;
v := @this: org.apache.nifi.processors.standard.DebugFlow;
v := @parameter: boolean;
v := @parameter: java.lang.Class;
if v == 0 goto label;
v = new java.lang.RuntimeException;
v = virtualinvoke v.<java.lang.Class: java.lang.String getSimpleName()>();
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[])>("Failure configured for \u methods");
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.String)>(v);
throw v;
label:
return;
}
public void onTrigger(org.apache.nifi.processor.ProcessContext, org.apache.nifi.processor.ProcessSession) throws org.apache.nifi.processor.exception.ProcessException
{
java.lang.Integer 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;
java.lang.Thread v, v, v, v, v;
java.lang.reflect.Constructor v, v;
org.apache.nifi.processor.Relationship v, v;
java.lang.Class[] v, v;
org.apache.nifi.processor.ProcessSession v;
org.apache.nifi.flowfile.attributes.CoreAttributes v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.nifi.components.PropertyValue v, v, v, v, v, v, v, v, v, v, v, v;
int 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;
java.lang.Boolean v, v, v, v, v;
org.apache.nifi.processors.standard.DebugFlow$FlowFileResponseState v, v, v, v, v, v, v, v, v, v, v, v;
java.lang.Class v, v, v, v;
org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v, v, v, v, v, v, v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
boolean v, v, v, v, v;
org.apache.nifi.logging.ComponentLog v, v, v, v, v, v;
org.apache.nifi.processor.ProcessContext v;
java.util.concurrent.TimeUnit v, v, v, v, v;
byte[] v;
byte v, v, v, v, v;
java.lang.Long v, v, v, v, v;
java.lang.Object[] v, v, v, v, v, v, v, v;
long v, v, v, v, v;
org.apache.nifi.processors.standard.DebugFlow$NoFlowFileResponse v, v, v, v, v, v;
java.util.Random v;
org.apache.nifi.processors.standard.DebugFlow$FlowFileResponse v, v, v, v, v, v, v, v, v, v, v, v;
java.lang.Object v, v;
org.apache.nifi.processors.standard.DebugFlow v;
org.apache.nifi.processor.DataUnit v;
java.lang.Throwable v;
java.lang.Double v;
org.apache.nifi.processors.standard.DebugFlow$1 v;
org.apache.nifi.flowfile.FlowFile v;
org.apache.nifi.processors.standard.DebugFlow$NoFlowFileResponseState v, v, v, v, v, v;
java.lang.InterruptedException v, v, v, v, v;
v := @this: org.apache.nifi.processors.standard.DebugFlow;
v := @parameter: org.apache.nifi.processor.ProcessContext;
v := @parameter: org.apache.nifi.processor.ProcessSession;
v = virtualinvoke v.<org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.logging.ComponentLog getLogger()>();
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile get()>();
label:
v = 2;
label:
if v <= 0 goto label;
if v != null goto label;
v = v.<org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.processors.standard.DebugFlow$NoFlowFileResponse curr_noff_resp>;
v = virtualinvoke v.<org.apache.nifi.processors.standard.DebugFlow$NoFlowFileResponse: org.apache.nifi.processors.standard.DebugFlow$NoFlowFileResponseState state()>();
v = <org.apache.nifi.processors.standard.DebugFlow$NoFlowFileResponseState: org.apache.nifi.processors.standard.DebugFlow$NoFlowFileResponseState NO_FF_SKIP_RESPONSE>;
if v != v goto label;
v = v.<org.apache.nifi.processors.standard.DebugFlow: java.lang.Integer noFlowFileCurrSkip>;
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = v.<org.apache.nifi.processors.standard.DebugFlow: java.lang.Integer noFlowFileMaxSkip>;
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
if v >= v goto label;
v = v.<org.apache.nifi.processors.standard.DebugFlow: java.lang.Integer noFlowFileCurrSkip>;
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = v + 1;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v.<org.apache.nifi.processors.standard.DebugFlow: java.lang.Integer noFlowFileCurrSkip> = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void info(java.lang.String)>("DebugFlow skipping with no flow file");
label:
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor ON_TRIGGER_SLEEP_TIME>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit MILLISECONDS>;
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.Long asTimePeriod(java.util.concurrent.TimeUnit)>(v);
v = virtualinvoke v.<java.lang.Long: long longValue()>();
label:
v = v cmp 0L;
if v <= 0 goto label;
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor IGNORE_INTERRUPTS>;
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()>();
specialinvoke v.<org.apache.nifi.processors.standard.DebugFlow: void sleep(long,boolean)>(v, v);
v = virtualinvoke v.<org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.logging.ComponentLog getLogger()>();
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void info(java.lang.String)>("DebugFlow finishes sleeping at completion of its onTrigger() method");
label:
goto label;
label:
v := @caughtexception;
v = staticinvoke <java.lang.Thread: java.lang.Thread currentThread()>();
virtualinvoke v.<java.lang.Thread: void interrupt()>();
label:
return;
label:
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(0);
v.<org.apache.nifi.processors.standard.DebugFlow: java.lang.Integer noFlowFileCurrSkip> = v;
v = v.<org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.processors.standard.DebugFlow$NoFlowFileResponse curr_noff_resp>;
virtualinvoke v.<org.apache.nifi.processors.standard.DebugFlow$NoFlowFileResponse: void getNextCycle()>();
label:
v = v.<org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.processors.standard.DebugFlow$NoFlowFileResponse curr_noff_resp>;
v = virtualinvoke v.<org.apache.nifi.processors.standard.DebugFlow$NoFlowFileResponse: org.apache.nifi.processors.standard.DebugFlow$NoFlowFileResponseState state()>();
v = <org.apache.nifi.processors.standard.DebugFlow$NoFlowFileResponseState: org.apache.nifi.processors.standard.DebugFlow$NoFlowFileResponseState NO_FF_EXCEPTION_RESPONSE>;
if v != v goto label;
v = v.<org.apache.nifi.processors.standard.DebugFlow: java.lang.Integer noFlowFileCurrException>;
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = v.<org.apache.nifi.processors.standard.DebugFlow: java.lang.Integer noFlowFileMaxException>;
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
if v >= v goto label;
v = v.<org.apache.nifi.processors.standard.DebugFlow: java.lang.Integer noFlowFileCurrException>;
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = v + 1;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v.<org.apache.nifi.processors.standard.DebugFlow: java.lang.Integer noFlowFileCurrException> = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void info(java.lang.String)>("DebugFlow throwing NPE with no flow file");
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = virtualinvoke v.<java.lang.Class: java.lang.String getName()>();
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[])>("forced by \u0001");
v = v.<org.apache.nifi.processors.standard.DebugFlow: java.lang.Class noFlowFileExceptionClass>;
v = newarray (java.lang.Class)[1];
v[0] = class "Ljava/lang/String;";
v = virtualinvoke v.<java.lang.Class: java.lang.reflect.Constructor getConstructor(java.lang.Class[])>(v);
v = newarray (java.lang.Object)[1];
v[0] = v;
v = virtualinvoke v.<java.lang.reflect.Constructor: java.lang.Object newInstance(java.lang.Object[])>(v);
throw v;
label:
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(0);
v.<org.apache.nifi.processors.standard.DebugFlow: java.lang.Integer noFlowFileCurrException> = v;
v = v.<org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.processors.standard.DebugFlow$NoFlowFileResponse curr_noff_resp>;
virtualinvoke v.<org.apache.nifi.processors.standard.DebugFlow$NoFlowFileResponse: void getNextCycle()>();
label:
v = v.<org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.processors.standard.DebugFlow$NoFlowFileResponse curr_noff_resp>;
v = virtualinvoke v.<org.apache.nifi.processors.standard.DebugFlow$NoFlowFileResponse: org.apache.nifi.processors.standard.DebugFlow$NoFlowFileResponseState state()>();
v = <org.apache.nifi.processors.standard.DebugFlow$NoFlowFileResponseState: org.apache.nifi.processors.standard.DebugFlow$NoFlowFileResponseState NO_FF_YIELD_RESPONSE>;
if v != v goto label;
v = v.<org.apache.nifi.processors.standard.DebugFlow: java.lang.Integer noFlowFileCurrYield>;
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = v.<org.apache.nifi.processors.standard.DebugFlow: java.lang.Integer noFlowFileMaxYield>;
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
if v >= v goto label;
v = v.<org.apache.nifi.processors.standard.DebugFlow: java.lang.Integer noFlowFileCurrYield>;
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = v + 1;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v.<org.apache.nifi.processors.standard.DebugFlow: java.lang.Integer noFlowFileCurrYield> = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void info(java.lang.String)>("DebugFlow yielding with no flow file");
interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: void yield()>();
goto label;
label:
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(0);
v.<org.apache.nifi.processors.standard.DebugFlow: java.lang.Integer noFlowFileCurrYield> = v;
v = v.<org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.processors.standard.DebugFlow$NoFlowFileResponse curr_noff_resp>;
virtualinvoke v.<org.apache.nifi.processors.standard.DebugFlow$NoFlowFileResponse: void getNextCycle()>();
label:
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor ON_TRIGGER_SLEEP_TIME>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit MILLISECONDS>;
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.Long asTimePeriod(java.util.concurrent.TimeUnit)>(v);
v = virtualinvoke v.<java.lang.Long: long longValue()>();
label:
v = v cmp 0L;
if v <= 0 goto label;
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor IGNORE_INTERRUPTS>;
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()>();
specialinvoke v.<org.apache.nifi.processors.standard.DebugFlow: void sleep(long,boolean)>(v, v);
v = virtualinvoke v.<org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.logging.ComponentLog getLogger()>();
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void info(java.lang.String)>("DebugFlow finishes sleeping at completion of its onTrigger() method");
label:
goto label;
label:
v := @caughtexception;
v = staticinvoke <java.lang.Thread: java.lang.Thread currentThread()>();
virtualinvoke v.<java.lang.Thread: void interrupt()>();
label:
return;
label:
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor WRITE_ITERATIONS>;
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 = virtualinvoke v.<java.lang.Integer: int intValue()>();
if v <= 0 goto label;
if v != 1 goto label;
v = new java.util.Random;
specialinvoke v.<java.util.Random: void <init>()>();
v = 0;
label:
if v >= v goto label;
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor CONTENT_SIZE>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = <org.apache.nifi.processor.DataUnit: org.apache.nifi.processor.DataUnit B>;
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.Double asDataSize(org.apache.nifi.processor.DataUnit)>(v);
v = virtualinvoke v.<java.lang.Double: int intValue()>();
v = newarray (byte)[v];
virtualinvoke v.<java.util.Random: void nextBytes(byte[])>(v);
v = new org.apache.nifi.processors.standard.DebugFlow$1;
specialinvoke v.<org.apache.nifi.processors.standard.DebugFlow$1: void <init>(org.apache.nifi.processors.standard.DebugFlow,byte[])>(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);
v = v + 1;
goto label;
label:
v = v.<org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.processors.standard.DebugFlow$FlowFileResponse curr_ff_resp>;
v = virtualinvoke v.<org.apache.nifi.processors.standard.DebugFlow$FlowFileResponse: org.apache.nifi.processors.standard.DebugFlow$FlowFileResponseState state()>();
v = <org.apache.nifi.processors.standard.DebugFlow$FlowFileResponseState: org.apache.nifi.processors.standard.DebugFlow$FlowFileResponseState FF_SUCCESS_RESPONSE>;
if v != v goto label;
v = v.<org.apache.nifi.processors.standard.DebugFlow: java.lang.Integer flowFileCurrSuccess>;
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = v.<org.apache.nifi.processors.standard.DebugFlow: java.lang.Integer flowFileMaxSuccess>;
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
if v >= v goto label;
v = v.<org.apache.nifi.processors.standard.DebugFlow: java.lang.Integer flowFileCurrSuccess>;
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = v + 1;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v.<org.apache.nifi.processors.standard.DebugFlow: java.lang.Integer flowFileCurrSuccess> = v;
v = newarray (java.lang.Object)[2];
v = <org.apache.nifi.flowfile.attributes.CoreAttributes: org.apache.nifi.flowfile.attributes.CoreAttributes FILENAME>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.CoreAttributes: java.lang.String key()>();
v = interfaceinvoke v.<org.apache.nifi.flowfile.FlowFile: java.lang.String getAttribute(java.lang.String)>(v);
v[0] = v;
v = <org.apache.nifi.flowfile.attributes.CoreAttributes: org.apache.nifi.flowfile.attributes.CoreAttributes UUID>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.CoreAttributes: java.lang.String key()>();
v = interfaceinvoke v.<org.apache.nifi.flowfile.FlowFile: java.lang.String getAttribute(java.lang.String)>(v);
v[1] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void info(java.lang.String,java.lang.Object[])>("DebugFlow transferring to success file={} UUID={}", v);
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void transfer(org.apache.nifi.flowfile.FlowFile,org.apache.nifi.processor.Relationship)>(v, v);
goto label;
label:
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(0);
v.<org.apache.nifi.processors.standard.DebugFlow: java.lang.Integer flowFileCurrSuccess> = v;
v = v.<org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.processors.standard.DebugFlow$FlowFileResponse curr_ff_resp>;
virtualinvoke v.<org.apache.nifi.processors.standard.DebugFlow$FlowFileResponse: void getNextCycle()>();
label:
v = v.<org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.processors.standard.DebugFlow$FlowFileResponse curr_ff_resp>;
v = virtualinvoke v.<org.apache.nifi.processors.standard.DebugFlow$FlowFileResponse: org.apache.nifi.processors.standard.DebugFlow$FlowFileResponseState state()>();
v = <org.apache.nifi.processors.standard.DebugFlow$FlowFileResponseState: org.apache.nifi.processors.standard.DebugFlow$FlowFileResponseState FF_FAILURE_RESPONSE>;
if v != v goto label;
v = v.<org.apache.nifi.processors.standard.DebugFlow: java.lang.Integer flowFileCurrFailure>;
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = v.<org.apache.nifi.processors.standard.DebugFlow: java.lang.Integer flowFileMaxFailure>;
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
if v >= v goto label;
v = v.<org.apache.nifi.processors.standard.DebugFlow: java.lang.Integer flowFileCurrFailure>;
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = v + 1;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v.<org.apache.nifi.processors.standard.DebugFlow: java.lang.Integer flowFileCurrFailure> = v;
v = newarray (java.lang.Object)[2];
v = <org.apache.nifi.flowfile.attributes.CoreAttributes: org.apache.nifi.flowfile.attributes.CoreAttributes FILENAME>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.CoreAttributes: java.lang.String key()>();
v = interfaceinvoke v.<org.apache.nifi.flowfile.FlowFile: java.lang.String getAttribute(java.lang.String)>(v);
v[0] = v;
v = <org.apache.nifi.flowfile.attributes.CoreAttributes: org.apache.nifi.flowfile.attributes.CoreAttributes UUID>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.CoreAttributes: java.lang.String key()>();
v = interfaceinvoke v.<org.apache.nifi.flowfile.FlowFile: java.lang.String getAttribute(java.lang.String)>(v);
v[1] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void info(java.lang.String,java.lang.Object[])>("DebugFlow transferring to failure file={} UUID={}", v);
v = <org.apache.nifi.processors.standard.DebugFlow: 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 = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(0);
v.<org.apache.nifi.processors.standard.DebugFlow: java.lang.Integer flowFileCurrFailure> = v;
v = v.<org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.processors.standard.DebugFlow$FlowFileResponse curr_ff_resp>;
virtualinvoke v.<org.apache.nifi.processors.standard.DebugFlow$FlowFileResponse: void getNextCycle()>();
label:
v = v.<org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.processors.standard.DebugFlow$FlowFileResponse curr_ff_resp>;
v = virtualinvoke v.<org.apache.nifi.processors.standard.DebugFlow$FlowFileResponse: org.apache.nifi.processors.standard.DebugFlow$FlowFileResponseState state()>();
v = <org.apache.nifi.processors.standard.DebugFlow$FlowFileResponseState: org.apache.nifi.processors.standard.DebugFlow$FlowFileResponseState FF_ROLLBACK_RESPONSE>;
if v != v goto label;
v = v.<org.apache.nifi.processors.standard.DebugFlow: java.lang.Integer flowFileCurrRollback>;
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = v.<org.apache.nifi.processors.standard.DebugFlow: java.lang.Integer flowFileMaxRollback>;
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
if v >= v goto label;
v = v.<org.apache.nifi.processors.standard.DebugFlow: java.lang.Integer flowFileCurrRollback>;
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = v + 1;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v.<org.apache.nifi.processors.standard.DebugFlow: java.lang.Integer flowFileCurrRollback> = v;
v = newarray (java.lang.Object)[2];
v = <org.apache.nifi.flowfile.attributes.CoreAttributes: org.apache.nifi.flowfile.attributes.CoreAttributes FILENAME>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.CoreAttributes: java.lang.String key()>();
v = interfaceinvoke v.<org.apache.nifi.flowfile.FlowFile: java.lang.String getAttribute(java.lang.String)>(v);
v[0] = v;
v = <org.apache.nifi.flowfile.attributes.CoreAttributes: org.apache.nifi.flowfile.attributes.CoreAttributes UUID>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.CoreAttributes: java.lang.String key()>();
v = interfaceinvoke v.<org.apache.nifi.flowfile.FlowFile: java.lang.String getAttribute(java.lang.String)>(v);
v[1] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void info(java.lang.String,java.lang.Object[])>("DebugFlow rolling back (no penalty) file={} UUID={}", v);
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void rollback()>();
goto label;
label:
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(0);
v.<org.apache.nifi.processors.standard.DebugFlow: java.lang.Integer flowFileCurrRollback> = v;
v = v.<org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.processors.standard.DebugFlow$FlowFileResponse curr_ff_resp>;
virtualinvoke v.<org.apache.nifi.processors.standard.DebugFlow$FlowFileResponse: void getNextCycle()>();
label:
v = v.<org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.processors.standard.DebugFlow$FlowFileResponse curr_ff_resp>;
v = virtualinvoke v.<org.apache.nifi.processors.standard.DebugFlow$FlowFileResponse: org.apache.nifi.processors.standard.DebugFlow$FlowFileResponseState state()>();
v = <org.apache.nifi.processors.standard.DebugFlow$FlowFileResponseState: org.apache.nifi.processors.standard.DebugFlow$FlowFileResponseState FF_YIELD_RESPONSE>;
if v != v goto label;
v = v.<org.apache.nifi.processors.standard.DebugFlow: java.lang.Integer flowFileCurrYield>;
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = v.<org.apache.nifi.processors.standard.DebugFlow: java.lang.Integer flowFileMaxYield>;
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
if v >= v goto label;
v = v.<org.apache.nifi.processors.standard.DebugFlow: java.lang.Integer flowFileCurrYield>;
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = v + 1;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v.<org.apache.nifi.processors.standard.DebugFlow: java.lang.Integer flowFileCurrYield> = v;
v = newarray (java.lang.Object)[2];
v = <org.apache.nifi.flowfile.attributes.CoreAttributes: org.apache.nifi.flowfile.attributes.CoreAttributes FILENAME>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.CoreAttributes: java.lang.String key()>();
v = interfaceinvoke v.<org.apache.nifi.flowfile.FlowFile: java.lang.String getAttribute(java.lang.String)>(v);
v[0] = v;
v = <org.apache.nifi.flowfile.attributes.CoreAttributes: org.apache.nifi.flowfile.attributes.CoreAttributes UUID>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.CoreAttributes: java.lang.String key()>();
v = interfaceinvoke v.<org.apache.nifi.flowfile.FlowFile: java.lang.String getAttribute(java.lang.String)>(v);
v[1] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void info(java.lang.String,java.lang.Object[])>("DebugFlow yielding file={} UUID={}", v);
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void rollback()>();
interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: void yield()>();
label:
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor ON_TRIGGER_SLEEP_TIME>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit MILLISECONDS>;
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.Long asTimePeriod(java.util.concurrent.TimeUnit)>(v);
v = virtualinvoke v.<java.lang.Long: long longValue()>();
label:
v = v cmp 0L;
if v <= 0 goto label;
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor IGNORE_INTERRUPTS>;
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()>();
specialinvoke v.<org.apache.nifi.processors.standard.DebugFlow: void sleep(long,boolean)>(v, v);
v = virtualinvoke v.<org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.logging.ComponentLog getLogger()>();
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void info(java.lang.String)>("DebugFlow finishes sleeping at completion of its onTrigger() method");
label:
goto label;
label:
v := @caughtexception;
v = staticinvoke <java.lang.Thread: java.lang.Thread currentThread()>();
virtualinvoke v.<java.lang.Thread: void interrupt()>();
label:
return;
label:
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(0);
v.<org.apache.nifi.processors.standard.DebugFlow: java.lang.Integer flowFileCurrYield> = v;
v = v.<org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.processors.standard.DebugFlow$FlowFileResponse curr_ff_resp>;
virtualinvoke v.<org.apache.nifi.processors.standard.DebugFlow$FlowFileResponse: void getNextCycle()>();
label:
v = v.<org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.processors.standard.DebugFlow$FlowFileResponse curr_ff_resp>;
v = virtualinvoke v.<org.apache.nifi.processors.standard.DebugFlow$FlowFileResponse: org.apache.nifi.processors.standard.DebugFlow$FlowFileResponseState state()>();
v = <org.apache.nifi.processors.standard.DebugFlow$FlowFileResponseState: org.apache.nifi.processors.standard.DebugFlow$FlowFileResponseState FF_PENALTY_RESPONSE>;
if v != v goto label;
v = v.<org.apache.nifi.processors.standard.DebugFlow: java.lang.Integer flowFileCurrPenalty>;
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = v.<org.apache.nifi.processors.standard.DebugFlow: java.lang.Integer flowFileMaxPenalty>;
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
if v >= v goto label;
v = v.<org.apache.nifi.processors.standard.DebugFlow: java.lang.Integer flowFileCurrPenalty>;
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = v + 1;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v.<org.apache.nifi.processors.standard.DebugFlow: java.lang.Integer flowFileCurrPenalty> = v;
v = newarray (java.lang.Object)[2];
v = <org.apache.nifi.flowfile.attributes.CoreAttributes: org.apache.nifi.flowfile.attributes.CoreAttributes FILENAME>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.CoreAttributes: java.lang.String key()>();
v = interfaceinvoke v.<org.apache.nifi.flowfile.FlowFile: java.lang.String getAttribute(java.lang.String)>(v);
v[0] = v;
v = <org.apache.nifi.flowfile.attributes.CoreAttributes: org.apache.nifi.flowfile.attributes.CoreAttributes UUID>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.CoreAttributes: java.lang.String key()>();
v = interfaceinvoke v.<org.apache.nifi.flowfile.FlowFile: java.lang.String getAttribute(java.lang.String)>(v);
v[1] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void info(java.lang.String,java.lang.Object[])>("DebugFlow rolling back (with penalty) file={} UUID={}", v);
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void rollback(boolean)>(1);
goto label;
label:
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(0);
v.<org.apache.nifi.processors.standard.DebugFlow: java.lang.Integer flowFileCurrPenalty> = v;
v = v.<org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.processors.standard.DebugFlow$FlowFileResponse curr_ff_resp>;
virtualinvoke v.<org.apache.nifi.processors.standard.DebugFlow$FlowFileResponse: void getNextCycle()>();
label:
v = v.<org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.processors.standard.DebugFlow$FlowFileResponse curr_ff_resp>;
v = virtualinvoke v.<org.apache.nifi.processors.standard.DebugFlow$FlowFileResponse: org.apache.nifi.processors.standard.DebugFlow$FlowFileResponseState state()>();
v = <org.apache.nifi.processors.standard.DebugFlow$FlowFileResponseState: org.apache.nifi.processors.standard.DebugFlow$FlowFileResponseState FF_EXCEPTION_RESPONSE>;
if v != v goto label;
v = v.<org.apache.nifi.processors.standard.DebugFlow: java.lang.Integer flowFileCurrException>;
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = v.<org.apache.nifi.processors.standard.DebugFlow: java.lang.Integer flowFileMaxException>;
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
if v >= v goto label;
v = v.<org.apache.nifi.processors.standard.DebugFlow: java.lang.Integer flowFileCurrException>;
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = v + 1;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v.<org.apache.nifi.processors.standard.DebugFlow: java.lang.Integer flowFileCurrException> = v;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = virtualinvoke v.<java.lang.Class: java.lang.String getName()>();
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[])>("forced by \u0001");
v = newarray (java.lang.Object)[2];
v = <org.apache.nifi.flowfile.attributes.CoreAttributes: org.apache.nifi.flowfile.attributes.CoreAttributes FILENAME>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.CoreAttributes: java.lang.String key()>();
v = interfaceinvoke v.<org.apache.nifi.flowfile.FlowFile: java.lang.String getAttribute(java.lang.String)>(v);
v[0] = v;
v = <org.apache.nifi.flowfile.attributes.CoreAttributes: org.apache.nifi.flowfile.attributes.CoreAttributes UUID>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.CoreAttributes: java.lang.String key()>();
v = interfaceinvoke v.<org.apache.nifi.flowfile.FlowFile: java.lang.String getAttribute(java.lang.String)>(v);
v[1] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void info(java.lang.String,java.lang.Object[])>("DebugFlow throwing NPE file={} UUID={}", v);
v = v.<org.apache.nifi.processors.standard.DebugFlow: java.lang.Class flowFileExceptionClass>;
v = newarray (java.lang.Class)[1];
v[0] = class "Ljava/lang/String;";
v = virtualinvoke v.<java.lang.Class: java.lang.reflect.Constructor getConstructor(java.lang.Class[])>(v);
v = newarray (java.lang.Object)[1];
v[0] = v;
v = virtualinvoke v.<java.lang.reflect.Constructor: java.lang.Object newInstance(java.lang.Object[])>(v);
throw v;
label:
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(0);
v.<org.apache.nifi.processors.standard.DebugFlow: java.lang.Integer flowFileCurrException> = v;
v = v.<org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.processors.standard.DebugFlow$FlowFileResponse curr_ff_resp>;
virtualinvoke v.<org.apache.nifi.processors.standard.DebugFlow$FlowFileResponse: void getNextCycle()>();
label:
v = v - 1;
goto label;
label:
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor ON_TRIGGER_SLEEP_TIME>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit MILLISECONDS>;
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.Long asTimePeriod(java.util.concurrent.TimeUnit)>(v);
v = virtualinvoke v.<java.lang.Long: long longValue()>();
label:
v = v cmp 0L;
if v <= 0 goto label;
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor IGNORE_INTERRUPTS>;
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()>();
specialinvoke v.<org.apache.nifi.processors.standard.DebugFlow: void sleep(long,boolean)>(v, v);
v = virtualinvoke v.<org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.logging.ComponentLog getLogger()>();
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void info(java.lang.String)>("DebugFlow finishes sleeping at completion of its onTrigger() method");
label:
goto label;
label:
v := @caughtexception;
v = staticinvoke <java.lang.Thread: java.lang.Thread currentThread()>();
virtualinvoke v.<java.lang.Thread: void interrupt()>();
goto label;
label:
v := @caughtexception;
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor ON_TRIGGER_SLEEP_TIME>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit MILLISECONDS>;
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.Long asTimePeriod(java.util.concurrent.TimeUnit)>(v);
v = virtualinvoke v.<java.lang.Long: long longValue()>();
label:
v = v cmp 0L;
if v <= 0 goto label;
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor IGNORE_INTERRUPTS>;
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()>();
specialinvoke v.<org.apache.nifi.processors.standard.DebugFlow: void sleep(long,boolean)>(v, v);
v = virtualinvoke v.<org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.logging.ComponentLog getLogger()>();
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void info(java.lang.String)>("DebugFlow finishes sleeping at completion of its onTrigger() method");
label:
goto label;
label:
v := @caughtexception;
v = staticinvoke <java.lang.Thread: java.lang.Thread currentThread()>();
virtualinvoke v.<java.lang.Thread: void interrupt()>();
label:
throw v;
label:
return;
catch java.lang.InterruptedException from label to label with label;
catch java.lang.InterruptedException from label to label with label;
catch java.lang.InterruptedException from label to label with label;
catch java.lang.InterruptedException 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.lang.Throwable from label to label with label;
catch java.lang.InterruptedException from label to label with label;
}
static void <clinit>()
{
org.apache.nifi.processors.standard.DebugFlow$RuntimeExceptionValidator v, v;
org.apache.nifi.processor.Relationship v, v;
org.apache.nifi.expression.ExpressionLanguageScope v, v;
org.apache.nifi.components.PropertyDescriptor 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.components.PropertyDescriptor$Builder v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.lang.String[] v, v, v, v;
org.apache.nifi.components.Validator v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.nifi.processor.Relationship$Builder 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)>("success");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship$Builder description(java.lang.String)>("FlowFiles processed successfully.");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship build()>();
<org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.processor.Relationship REL_SUCCESS> = v;
v = new org.apache.nifi.processor.Relationship$Builder;
specialinvoke v.<org.apache.nifi.processor.Relationship$Builder: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship$Builder name(java.lang.String)>("failure");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship$Builder description(java.lang.String)>("FlowFiles that failed to process.");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship build()>();
<org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.processor.Relationship REL_FAILURE> = 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)>("FlowFile Success Iterations");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("Number of FlowFiles to forward to success relationship.");
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)>("1");
v = <org.apache.nifi.processor.util.StandardValidators: org.apache.nifi.components.Validator NON_NEGATIVE_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 build()>();
<org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor FF_SUCCESS_ITERATIONS> = 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)>("FlowFile Failure Iterations");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("Number of FlowFiles to forward to failure relationship.");
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)>("0");
v = <org.apache.nifi.processor.util.StandardValidators: org.apache.nifi.components.Validator NON_NEGATIVE_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 build()>();
<org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor FF_FAILURE_ITERATIONS> = 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)>("FlowFile Rollback Iterations");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("Number of FlowFiles to roll back (without penalty).");
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)>("0");
v = <org.apache.nifi.processor.util.StandardValidators: org.apache.nifi.components.Validator NON_NEGATIVE_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 build()>();
<org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor FF_ROLLBACK_ITERATIONS> = 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)>("FlowFile Rollback Yield Iterations");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("Number of FlowFiles to roll back and yield.");
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)>("0");
v = <org.apache.nifi.processor.util.StandardValidators: org.apache.nifi.components.Validator NON_NEGATIVE_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 build()>();
<org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor FF_ROLLBACK_YIELD_ITERATIONS> = 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)>("FlowFile Rollback Penalty Iterations");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("Number of FlowFiles to roll back with penalty.");
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)>("0");
v = <org.apache.nifi.processor.util.StandardValidators: org.apache.nifi.components.Validator NON_NEGATIVE_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 build()>();
<org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor FF_ROLLBACK_PENALTY_ITERATIONS> = 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)>("FlowFile Exception Iterations");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("Number of FlowFiles to throw exception.");
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)>("0");
v = <org.apache.nifi.processor.util.StandardValidators: org.apache.nifi.components.Validator NON_NEGATIVE_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 build()>();
<org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor FF_EXCEPTION_ITERATIONS> = 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)>("FlowFile Exception Class");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("Exception class to be thrown (must extend java.lang.RuntimeException).");
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)>("java.lang.RuntimeException");
v = new org.apache.nifi.processors.standard.DebugFlow$RuntimeExceptionValidator;
specialinvoke v.<org.apache.nifi.processors.standard.DebugFlow$RuntimeExceptionValidator: 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 build()>();
<org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor FF_EXCEPTION_CLASS> = 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)>("No FlowFile Skip Iterations");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("Number of times to skip onTrigger if no FlowFile.");
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)>("1");
v = <org.apache.nifi.processor.util.StandardValidators: org.apache.nifi.components.Validator NON_NEGATIVE_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 build()>();
<org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor NO_FF_SKIP_ITERATIONS> = 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)>("No FlowFile Exception Iterations");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("Number of times to throw NPE exception if no FlowFile.");
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)>("0");
v = <org.apache.nifi.processor.util.StandardValidators: org.apache.nifi.components.Validator NON_NEGATIVE_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 build()>();
<org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor NO_FF_EXCEPTION_ITERATIONS> = 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)>("No FlowFile Yield Iterations");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("Number of times to yield if no FlowFile.");
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)>("0");
v = <org.apache.nifi.processor.util.StandardValidators: org.apache.nifi.components.Validator NON_NEGATIVE_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 build()>();
<org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor NO_FF_YIELD_ITERATIONS> = 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)>("No FlowFile Exception Class");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("Exception class to be thrown if no FlowFile (must extend java.lang.RuntimeException).");
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)>("java.lang.RuntimeException");
v = new org.apache.nifi.processors.standard.DebugFlow$RuntimeExceptionValidator;
specialinvoke v.<org.apache.nifi.processors.standard.DebugFlow$RuntimeExceptionValidator: 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 build()>();
<org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor NO_FF_EXCEPTION_CLASS> = 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)>("Write Iterations");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("Number of times to write to the FlowFile");
v = <org.apache.nifi.processor.util.StandardValidators: org.apache.nifi.components.Validator NON_NEGATIVE_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 required(boolean)>(1);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder defaultValue(java.lang.String)>("0");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor WRITE_ITERATIONS> = 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)>("Content Size");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("The number of bytes to write each time that the FlowFile is written to");
v = <org.apache.nifi.processor.util.StandardValidators: org.apache.nifi.components.Validator DATA_SIZE_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)>("1 KB");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor CONTENT_SIZE> = 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)>("@OnScheduled Pause Time");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("Specifies how long the processor should sleep in the @OnScheduled method, so that the processor can be forced to take a long time to start up");
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)>("0 sec");
v = <org.apache.nifi.processor.util.StandardValidators: org.apache.nifi.components.Validator TIME_PERIOD_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.DebugFlow: org.apache.nifi.components.PropertyDescriptor ON_SCHEDULED_SLEEP_TIME> = 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)>("Fail When @OnScheduled called");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("Specifies whether or not the Processor should throw an Exception when the methods annotated with @OnScheduled are called");
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.DebugFlow: org.apache.nifi.components.PropertyDescriptor ON_SCHEDULED_FAIL> = 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)>("@OnUnscheduled Pause Time");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("Specifies how long the processor should sleep in the @OnUnscheduled method, so that the processor can be forced to take a long time to respond when user clicks stop");
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)>("0 sec");
v = <org.apache.nifi.processor.util.StandardValidators: org.apache.nifi.components.Validator TIME_PERIOD_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.DebugFlow: org.apache.nifi.components.PropertyDescriptor ON_UNSCHEDULED_SLEEP_TIME> = 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)>("Fail When @OnUnscheduled called");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("Specifies whether or not the Processor should throw an Exception when the methods annotated with @OnUnscheduled are called");
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.DebugFlow: org.apache.nifi.components.PropertyDescriptor ON_UNSCHEDULED_FAIL> = 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)>("@OnStopped Pause Time");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("Specifies how long the processor should sleep in the @OnStopped method, so that the processor can be forced to take a long time to shutdown");
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)>("0 sec");
v = <org.apache.nifi.processor.util.StandardValidators: org.apache.nifi.components.Validator TIME_PERIOD_VALIDATOR>;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder addValidator(org.apache.nifi.components.Validator)>(v);
v = <org.apache.nifi.expression.ExpressionLanguageScope: org.apache.nifi.expression.ExpressionLanguageScope VARIABLE_REGISTRY>;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder expressionLanguageSupported(org.apache.nifi.expression.ExpressionLanguageScope)>(v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor ON_STOPPED_SLEEP_TIME> = 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)>("Fail When @OnStopped called");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("Specifies whether or not the Processor should throw an Exception when the methods annotated with @OnStopped are called");
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.DebugFlow: org.apache.nifi.components.PropertyDescriptor ON_STOPPED_FAIL> = 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)>("OnTrigger Pause Time");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("Specifies how long the processor should sleep in the onTrigger() method, so that the processor can be forced to take a long time to perform its task");
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)>("0 sec");
v = <org.apache.nifi.processor.util.StandardValidators: org.apache.nifi.components.Validator TIME_PERIOD_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.DebugFlow: org.apache.nifi.components.PropertyDescriptor ON_TRIGGER_SLEEP_TIME> = 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)>("CustomValidate Pause Time");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder displayName(java.lang.String)>("CustomValidate Pause Time");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("Specifies how long the processor should sleep in the customValidate() method");
v = <org.apache.nifi.processor.util.StandardValidators: org.apache.nifi.components.Validator TIME_PERIOD_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)>("0 sec");
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.DebugFlow: org.apache.nifi.components.PropertyDescriptor CUSTOM_VALIDATE_SLEEP_TIME> = 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 Interrupts When Paused");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("If the Processor\'s thread(s) are sleeping (due to one of the \"Pause Time\" properties above), and the thread is interrupted, this indicates whether the Processor should ignore the interrupt and continue sleeping or if it should allow itself to be interrupted.");
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 = 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$Builder required(boolean)>(1);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor IGNORE_INTERRUPTS> = v;
return;
}
}