public class org.apache.nifi.processors.standard.RetryFlowFile extends org.apache.nifi.processor.AbstractProcessor
{
private java.util.List properties;
private java.util.Set relationships;
private java.lang.String retryAttribute;
private java.lang.Boolean penalizeRetried;
private java.lang.Boolean failOnOverwrite;
private java.lang.String reuseMode;
private java.lang.String lastRetriedBy;
public static final org.apache.nifi.components.PropertyDescriptor RETRY_ATTRIBUTE;
public static final org.apache.nifi.components.PropertyDescriptor MAXIMUM_RETRIES;
public static final org.apache.nifi.components.PropertyDescriptor PENALIZE_RETRIED;
public static final org.apache.nifi.components.PropertyDescriptor FAIL_ON_OVERWRITE;
public static final org.apache.nifi.components.AllowableValue FAIL_ON_REUSE;
public static final org.apache.nifi.components.AllowableValue WARN_ON_REUSE;
public static final org.apache.nifi.components.AllowableValue RESET_ON_REUSE;
public static final org.apache.nifi.components.PropertyDescriptor REUSE_MODE;
public static final org.apache.nifi.processor.Relationship RETRY;
public static final org.apache.nifi.processor.Relationship RETRIES_EXCEEDED;
public static final org.apache.nifi.processor.Relationship FAILURE;
public void <init>()
{
org.apache.nifi.processors.standard.RetryFlowFile v;
v := @this: org.apache.nifi.processors.standard.RetryFlowFile;
specialinvoke v.<org.apache.nifi.processor.AbstractProcessor: void <init>()>();
return;
}
public java.util.Set getRelationships()
{
java.util.Set v;
org.apache.nifi.processors.standard.RetryFlowFile v;
v := @this: org.apache.nifi.processors.standard.RetryFlowFile;
v = v.<org.apache.nifi.processors.standard.RetryFlowFile: java.util.Set relationships>;
return v;
}
protected void init(org.apache.nifi.processor.ProcessorInitializationContext)
{
org.apache.nifi.processors.standard.RetryFlowFile v;
java.util.Set v;
org.apache.nifi.components.PropertyDescriptor v, v, v, v, v;
java.util.ArrayList v;
java.util.HashSet v;
java.util.List v;
org.apache.nifi.processor.Relationship v, v, v;
org.apache.nifi.processor.ProcessorInitializationContext v;
v := @this: org.apache.nifi.processors.standard.RetryFlowFile;
v := @parameter: org.apache.nifi.processor.ProcessorInitializationContext;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = <org.apache.nifi.processors.standard.RetryFlowFile: org.apache.nifi.components.PropertyDescriptor RETRY_ATTRIBUTE>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.RetryFlowFile: org.apache.nifi.components.PropertyDescriptor MAXIMUM_RETRIES>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.RetryFlowFile: org.apache.nifi.components.PropertyDescriptor PENALIZE_RETRIED>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.RetryFlowFile: org.apache.nifi.components.PropertyDescriptor FAIL_ON_OVERWRITE>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.RetryFlowFile: org.apache.nifi.components.PropertyDescriptor REUSE_MODE>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = staticinvoke <java.util.Collections: java.util.List unmodifiableList(java.util.List)>(v);
v.<org.apache.nifi.processors.standard.RetryFlowFile: java.util.List properties> = v;
v = new java.util.HashSet;
specialinvoke v.<java.util.HashSet: void <init>()>();
v = <org.apache.nifi.processors.standard.RetryFlowFile: org.apache.nifi.processor.Relationship RETRY>;
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.RetryFlowFile: org.apache.nifi.processor.Relationship RETRIES_EXCEEDED>;
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.RetryFlowFile: org.apache.nifi.processor.Relationship FAILURE>;
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
v = staticinvoke <java.util.Collections: java.util.Set unmodifiableSet(java.util.Set)>(v);
v.<org.apache.nifi.processors.standard.RetryFlowFile: java.util.Set relationships> = v;
return;
}
protected org.apache.nifi.components.PropertyDescriptor getSupportedDynamicPropertyDescriptor(java.lang.String)
{
org.apache.nifi.components.Validator v;
org.apache.nifi.processors.standard.RetryFlowFile v;
org.apache.nifi.expression.ExpressionLanguageScope v;
org.apache.nifi.components.PropertyDescriptor v;
org.apache.nifi.components.PropertyDescriptor$Builder v, v, v, v, v, v, v;
java.lang.String v, v;
v := @this: org.apache.nifi.processors.standard.RetryFlowFile;
v := @parameter: java.lang.String;
v = new org.apache.nifi.components.PropertyDescriptor$Builder;
specialinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder name(java.lang.String)>(v);
v = 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[])>("Attribute \u will be placed on FlowFiles exceeding the retry count");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder required(boolean)>(0);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder dynamic(boolean)>(1);
v = <org.apache.nifi.processor.util.StandardValidators: org.apache.nifi.components.Validator NON_EMPTY_EL_VALIDATOR>;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder addValidator(org.apache.nifi.components.Validator)>(v);
v = <org.apache.nifi.expression.ExpressionLanguageScope: org.apache.nifi.expression.ExpressionLanguageScope FLOWFILE_ATTRIBUTES>;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder expressionLanguageSupported(org.apache.nifi.expression.ExpressionLanguageScope)>(v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
return v;
}
protected java.util.List getSupportedPropertyDescriptors()
{
java.util.List v;
org.apache.nifi.processors.standard.RetryFlowFile v;
v := @this: org.apache.nifi.processors.standard.RetryFlowFile;
v = v.<org.apache.nifi.processors.standard.RetryFlowFile: java.util.List properties>;
return v;
}
public void onScheduled(org.apache.nifi.processor.ProcessContext)
{
org.apache.nifi.processors.standard.RetryFlowFile v;
org.apache.nifi.components.PropertyDescriptor v, v, v, v;
org.apache.nifi.components.PropertyValue v, v, v, v, v;
java.lang.Boolean v, v;
java.lang.String v, v, v, v;
org.apache.nifi.processor.ProcessContext v;
v := @this: org.apache.nifi.processors.standard.RetryFlowFile;
v := @parameter: org.apache.nifi.processor.ProcessContext;
v = <org.apache.nifi.processors.standard.RetryFlowFile: org.apache.nifi.components.PropertyDescriptor RETRY_ATTRIBUTE>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: org.apache.nifi.components.PropertyValue evaluateAttributeExpressions()>();
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.String getValue()>();
v.<org.apache.nifi.processors.standard.RetryFlowFile: java.lang.String retryAttribute> = v;
v = <org.apache.nifi.processors.standard.RetryFlowFile: org.apache.nifi.components.PropertyDescriptor PENALIZE_RETRIED>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.Boolean asBoolean()>();
v.<org.apache.nifi.processors.standard.RetryFlowFile: java.lang.Boolean penalizeRetried> = v;
v = <org.apache.nifi.processors.standard.RetryFlowFile: org.apache.nifi.components.PropertyDescriptor FAIL_ON_OVERWRITE>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.Boolean asBoolean()>();
v.<org.apache.nifi.processors.standard.RetryFlowFile: java.lang.Boolean failOnOverwrite> = v;
v = <org.apache.nifi.processors.standard.RetryFlowFile: org.apache.nifi.components.PropertyDescriptor REUSE_MODE>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.String getValue()>();
v.<org.apache.nifi.processors.standard.RetryFlowFile: java.lang.String reuseMode> = v;
v = v.<org.apache.nifi.processors.standard.RetryFlowFile: java.lang.String retryAttribute>;
v = virtualinvoke v.<java.lang.String: java.lang.String concat(java.lang.String)>(".uuid");
v.<org.apache.nifi.processors.standard.RetryFlowFile: java.lang.String lastRetriedBy> = v;
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;
org.apache.nifi.components.PropertyDescriptor v;
byte v;
java.util.Map v;
java.util.Set v;
java.lang.Object[] v, v, v, v;
org.apache.nifi.processors.standard.RetryFlowFile v;
org.apache.nifi.processor.Relationship v, v, v, v, v, v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.lang.NumberFormatException v, v;
org.apache.nifi.processor.ProcessSession v;
org.apache.nifi.components.PropertyValue v, v, v, v;
boolean v, v, v, v, v, v, v, v, v, v;
org.apache.nifi.flowfile.FlowFile v, v, v, v, v;
org.apache.nifi.logging.ComponentLog v, v, v, v, v, v;
int v, v, v, v, v, v, v;
java.lang.Boolean v, v;
org.apache.nifi.logging.LogLevel v;
java.util.Iterator v;
org.apache.nifi.processor.ProcessContext v;
java.lang.Object v;
v := @this: org.apache.nifi.processors.standard.RetryFlowFile;
v := @parameter: org.apache.nifi.processor.ProcessContext;
v := @parameter: org.apache.nifi.processor.ProcessSession;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile get()>();
if null != v goto label;
return;
label:
v = v.<org.apache.nifi.processors.standard.RetryFlowFile: java.lang.String retryAttribute>;
v = interfaceinvoke v.<org.apache.nifi.flowfile.FlowFile: java.lang.String getAttribute(java.lang.String)>(v);
label:
if null != v goto label;
v = 1;
goto label;
label:
v = virtualinvoke v.<java.lang.String: java.lang.String trim()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(java.lang.String)>(v);
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = v + 1;
label:
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
label:
goto label;
label:
v := @caughtexception;
v = v.<org.apache.nifi.processors.standard.RetryFlowFile: java.lang.Boolean failOnOverwrite>;
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
if v == 0 goto label;
v = <org.apache.nifi.processors.standard.RetryFlowFile: org.apache.nifi.processor.Relationship FAILURE>;
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void transfer(org.apache.nifi.flowfile.FlowFile,org.apache.nifi.processor.Relationship)>(v, v);
return;
label:
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(1);
label:
v = v.<org.apache.nifi.processors.standard.RetryFlowFile: java.lang.String lastRetriedBy>;
v = interfaceinvoke v.<org.apache.nifi.flowfile.FlowFile: java.lang.String getAttribute(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.nifi.processors.standard.RetryFlowFile: java.lang.String getIdentifier()>();
v = staticinvoke <org.apache.nifi.util.StringUtils: boolean isBlank(java.lang.String)>(v);
if v != 0 goto label;
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
v = <org.apache.nifi.logging.LogLevel: org.apache.nifi.logging.LogLevel DEBUG>;
v = v.<org.apache.nifi.processors.standard.RetryFlowFile: java.lang.String reuseMode>;
v = -1;
v = virtualinvoke v.<java.lang.String: int hashCode()>();
lookupswitch(v)
{
case 3135262: goto label;
case 3641990: goto label;
case 108404047: goto label;
default: goto label;
};
label:
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>("fail");
if v == 0 goto label;
v = 0;
goto label;
label:
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>("warn");
if v == 0 goto label;
v = 1;
goto label;
label:
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>("reset");
if v == 0 goto label;
v = 2;
label:
tableswitch(v)
{
case 0: goto label;
case 1: goto label;
case 2: goto label;
default: goto label;
};
label:
v = virtualinvoke v.<org.apache.nifi.processors.standard.RetryFlowFile: org.apache.nifi.logging.ComponentLog getLogger()>();
v = newarray (java.lang.Object)[1];
v[0] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void error(java.lang.String,java.lang.Object[])>("FlowFile {} was previously retried with the same attribute by a different processor. Route to \'failure\'", v);
v = virtualinvoke v.<org.apache.nifi.processors.standard.RetryFlowFile: org.apache.nifi.logging.ComponentLog getLogger()>();
v = newarray (java.lang.Object)[3];
v[0] = v;
v[1] = v;
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = v - 1;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[2] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void debug(java.lang.String,java.lang.Object[])>("Current Processor: {}, Previous Processor: {}, Previous Retry: {}", v);
v = <org.apache.nifi.processors.standard.RetryFlowFile: org.apache.nifi.processor.Relationship FAILURE>;
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void transfer(org.apache.nifi.flowfile.FlowFile,org.apache.nifi.processor.Relationship)>(v, v);
return;
label:
v = <org.apache.nifi.logging.LogLevel: org.apache.nifi.logging.LogLevel WARN>;
label:
v = virtualinvoke v.<org.apache.nifi.processors.standard.RetryFlowFile: org.apache.nifi.logging.ComponentLog getLogger()>();
v = newarray (java.lang.Object)[1];
v[0] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void log(org.apache.nifi.logging.LogLevel,java.lang.String,java.lang.Object[])>(v, "FlowFile {} was previously retried with the same attribute by a different processor. Reset the current retry count to \'1\'. Consider changing the retry attribute for this processor.", v);
v = virtualinvoke v.<org.apache.nifi.processors.standard.RetryFlowFile: org.apache.nifi.logging.ComponentLog getLogger()>();
v = newarray (java.lang.Object)[3];
v[0] = v;
v[1] = v;
v[2] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void debug(java.lang.String,java.lang.Object[])>("Current Processor: {}, Previous Processor: {}, Previous Retry: {}", v);
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(1);
label:
v = <org.apache.nifi.processors.standard.RetryFlowFile: org.apache.nifi.components.PropertyDescriptor MAXIMUM_RETRIES>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: org.apache.nifi.components.PropertyValue evaluateAttributeExpressions(org.apache.nifi.flowfile.FlowFile)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.Integer asInteger()>();
if null != v goto label;
v = virtualinvoke v.<org.apache.nifi.processors.standard.RetryFlowFile: org.apache.nifi.logging.ComponentLog getLogger()>();
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void warn(java.lang.String)>("Could not obtain maximum retries off of FlowFile, route to \'failure\'");
v = <org.apache.nifi.processors.standard.RetryFlowFile: org.apache.nifi.processor.Relationship FAILURE>;
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void transfer(org.apache.nifi.flowfile.FlowFile,org.apache.nifi.processor.Relationship)>(v, v);
label:
return;
label:
v := @caughtexception;
v = virtualinvoke v.<org.apache.nifi.processors.standard.RetryFlowFile: org.apache.nifi.logging.ComponentLog getLogger()>();
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void warn(java.lang.String)>("Maximum Retries was not a number for this FlowFile, route to \'failure\'");
v = <org.apache.nifi.processors.standard.RetryFlowFile: org.apache.nifi.processor.Relationship FAILURE>;
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void transfer(org.apache.nifi.flowfile.FlowFile,org.apache.nifi.processor.Relationship)>(v, v);
return;
label:
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
if v <= v goto label;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: java.util.Map getProperties()>();
v = interfaceinvoke v.<java.util.Map: java.util.Set keySet()>();
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor: boolean isDynamic()>();
if v == 0 goto label;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: org.apache.nifi.components.PropertyValue evaluateAttributeExpressions(org.apache.nifi.flowfile.FlowFile)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.String getValue()>();
v = staticinvoke <org.apache.nifi.util.StringUtils: boolean isBlank(java.lang.String)>(v);
if v != 0 goto label;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor: java.lang.String getName()>();
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile putAttribute(org.apache.nifi.flowfile.FlowFile,java.lang.String,java.lang.String)>(v, v, v);
goto label;
label:
v = v.<org.apache.nifi.processors.standard.RetryFlowFile: java.lang.String retryAttribute>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile removeAttribute(org.apache.nifi.flowfile.FlowFile,java.lang.String)>(v, v);
v = v.<org.apache.nifi.processors.standard.RetryFlowFile: java.lang.String lastRetriedBy>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile removeAttribute(org.apache.nifi.flowfile.FlowFile,java.lang.String)>(v, v);
v = <org.apache.nifi.processors.standard.RetryFlowFile: org.apache.nifi.processor.Relationship RETRIES_EXCEEDED>;
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 = v.<org.apache.nifi.processors.standard.RetryFlowFile: java.lang.Boolean penalizeRetried>;
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
if v == 0 goto label;
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile penalize(org.apache.nifi.flowfile.FlowFile)>(v);
label:
v = v.<org.apache.nifi.processors.standard.RetryFlowFile: java.lang.String retryAttribute>;
v = staticinvoke <java.lang.String: java.lang.String valueOf(java.lang.Object)>(v);
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile putAttribute(org.apache.nifi.flowfile.FlowFile,java.lang.String,java.lang.String)>(v, v, v);
v = v.<org.apache.nifi.processors.standard.RetryFlowFile: java.lang.String lastRetriedBy>;
v = virtualinvoke v.<org.apache.nifi.processors.standard.RetryFlowFile: java.lang.String getIdentifier()>();
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile putAttribute(org.apache.nifi.flowfile.FlowFile,java.lang.String,java.lang.String)>(v, v, v);
v = <org.apache.nifi.processors.standard.RetryFlowFile: org.apache.nifi.processor.Relationship RETRY>;
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void transfer(org.apache.nifi.flowfile.FlowFile,org.apache.nifi.processor.Relationship)>(v, v);
label:
return;
catch java.lang.NumberFormatException from label to label with label;
catch java.lang.NumberFormatException from label to label with label;
}
static void <clinit>()
{
org.apache.nifi.components.PropertyDescriptor v, v, v, v, v;
org.apache.nifi.components.AllowableValue v, v, v, v, v, v, v;
org.apache.nifi.processor.Relationship v, v, v;
java.lang.String v;
org.apache.nifi.components.PropertyDescriptor$Builder v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.nifi.expression.ExpressionLanguageScope v, v;
org.apache.nifi.components.AllowableValue[] v;
java.lang.String[] v, v;
org.apache.nifi.components.Validator v, v;
org.apache.nifi.processor.Relationship$Builder v, v, v, v, v, v, v, v, v, v;
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)>("retry-attribute");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder displayName(java.lang.String)>("Retry Attribute");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("The name of the attribute that contains the current retry count for the FlowFile. WARNING: If the name matches an attribute already on the FlowFile that does not contain a numerical value, the processor will either overwrite that attribute with \'1\' or fail based on configuration.");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder required(boolean)>(1);
v = <org.apache.nifi.processor.util.StandardValidators: org.apache.nifi.components.Validator NON_EMPTY_EL_VALIDATOR>;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder addValidator(org.apache.nifi.components.Validator)>(v);
v = <org.apache.nifi.expression.ExpressionLanguageScope: org.apache.nifi.expression.ExpressionLanguageScope 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$Builder defaultValue(java.lang.String)>("flowfile.retries");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.RetryFlowFile: org.apache.nifi.components.PropertyDescriptor RETRY_ATTRIBUTE> = v;
v = new org.apache.nifi.components.PropertyDescriptor$Builder;
specialinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder name(java.lang.String)>("maximum-retries");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder displayName(java.lang.String)>("Maximum Retries");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("The maximum number of times a FlowFile can be retried before being passed to the \'retries_exceeded\' relationship");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder required(boolean)>(1);
v = staticinvoke <org.apache.nifi.processor.util.StandardValidators: org.apache.nifi.components.Validator createLongValidator(long,long,boolean)>(1L, 2147483647L, 1);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder addValidator(org.apache.nifi.components.Validator)>(v);
v = <org.apache.nifi.expression.ExpressionLanguageScope: org.apache.nifi.expression.ExpressionLanguageScope FLOWFILE_ATTRIBUTES>;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder expressionLanguageSupported(org.apache.nifi.expression.ExpressionLanguageScope)>(v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder defaultValue(java.lang.String)>("3");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.RetryFlowFile: org.apache.nifi.components.PropertyDescriptor MAXIMUM_RETRIES> = 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)>("penalize-retries");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder displayName(java.lang.String)>("Penalize Retries");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("If set to \'true\', this Processor will penalize input FlowFiles before passing them to the \'retry\' relationship. This does not apply to the \'retries_exceeded\' relationship.");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder required(boolean)>(1);
v = newarray (java.lang.String)[2];
v[0] = "true";
v[1] = "false";
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder allowableValues(java.lang.String[])>(v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder defaultValue(java.lang.String)>("true");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.RetryFlowFile: org.apache.nifi.components.PropertyDescriptor PENALIZE_RETRIED> = 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 on Non-numerical Overwrite");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("If the FlowFile already has the attribute defined in \'Retry Attribute\' that is *not* a number, fail the FlowFile instead of resetting that value to \'1\'");
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.RetryFlowFile: org.apache.nifi.components.PropertyDescriptor FAIL_ON_OVERWRITE> = v;
v = new org.apache.nifi.components.AllowableValue;
specialinvoke v.<org.apache.nifi.components.AllowableValue: void <init>(java.lang.String,java.lang.String,java.lang.String)>("fail", "Fail on Reuse", "If the RetryFlowFile\'s UUID does not match the FlowFile\'s retry UUID, fail the FlowFile regardless of current retry count");
<org.apache.nifi.processors.standard.RetryFlowFile: org.apache.nifi.components.AllowableValue FAIL_ON_REUSE> = v;
v = new org.apache.nifi.components.AllowableValue;
specialinvoke v.<org.apache.nifi.components.AllowableValue: void <init>(java.lang.String,java.lang.String,java.lang.String)>("warn", "Warn on Reuse", "If the RetryFlowFile\'s UUID does not match the FlowFile\'s retry UUID, log a warning message before resetting the retry attribute and UUID for this instance");
<org.apache.nifi.processors.standard.RetryFlowFile: org.apache.nifi.components.AllowableValue WARN_ON_REUSE> = v;
v = new org.apache.nifi.components.AllowableValue;
specialinvoke v.<org.apache.nifi.components.AllowableValue: void <init>(java.lang.String,java.lang.String,java.lang.String)>("reset", "Reset Reuse", "If the RetryFlowFile\'s UUID does not match the FlowFile\'s retry UUID, log a debug message before resetting the retry attribute and UUID for this instance");
<org.apache.nifi.processors.standard.RetryFlowFile: org.apache.nifi.components.AllowableValue RESET_ON_REUSE> = 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)>("reuse-mode");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder displayName(java.lang.String)>("Reuse Mode");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("Defines how the Processor behaves if the retry FlowFile has a different retry UUID than the instance that received the FlowFile. This generally means that the attribute was not reset after being successfully retried by a previous instance of this processor.");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder required(boolean)>(1);
v = newarray (org.apache.nifi.components.AllowableValue)[3];
v = <org.apache.nifi.processors.standard.RetryFlowFile: org.apache.nifi.components.AllowableValue FAIL_ON_REUSE>;
v[0] = v;
v = <org.apache.nifi.processors.standard.RetryFlowFile: org.apache.nifi.components.AllowableValue WARN_ON_REUSE>;
v[1] = v;
v = <org.apache.nifi.processors.standard.RetryFlowFile: org.apache.nifi.components.AllowableValue RESET_ON_REUSE>;
v[2] = v;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder allowableValues(org.apache.nifi.components.AllowableValue[])>(v);
v = <org.apache.nifi.processors.standard.RetryFlowFile: org.apache.nifi.components.AllowableValue FAIL_ON_REUSE>;
v = virtualinvoke v.<org.apache.nifi.components.AllowableValue: java.lang.String getValue()>();
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder defaultValue(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.RetryFlowFile: org.apache.nifi.components.PropertyDescriptor REUSE_MODE> = 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)>("retry");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship$Builder description(java.lang.String)>("Input FlowFile has not exceeded the configured maximum retry count, pass this relationship back to the input Processor to create a limited feedback loop.");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship build()>();
<org.apache.nifi.processors.standard.RetryFlowFile: org.apache.nifi.processor.Relationship RETRY> = 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)>("retries_exceeded");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship$Builder description(java.lang.String)>("Input FlowFile has exceeded the configured maximum retry count, do not pass this relationship back to the input Processor to terminate the limited feedback loop.");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship build()>();
<org.apache.nifi.processors.standard.RetryFlowFile: org.apache.nifi.processor.Relationship RETRIES_EXCEEDED> = 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)>("The processor is configured such that a non-numerical value on \'Retry Attribute\' results in a failure instead of resetting that value to \'1\'. This will immediately terminate the limited feedback loop. Might also include when \'Maximum Retries\' contains attribute expression language that does not resolve to an Integer.");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship$Builder autoTerminateDefault(boolean)>(1);
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship build()>();
<org.apache.nifi.processors.standard.RetryFlowFile: org.apache.nifi.processor.Relationship FAILURE> = v;
return;
}
}