public class org.apache.nifi.processors.standard.FetchFile extends org.apache.nifi.processor.AbstractProcessor
{
static final org.apache.nifi.components.AllowableValue COMPLETION_NONE;
static final org.apache.nifi.components.AllowableValue COMPLETION_MOVE;
static final org.apache.nifi.components.AllowableValue COMPLETION_DELETE;
static final org.apache.nifi.components.AllowableValue CONFLICT_REPLACE;
static final org.apache.nifi.components.AllowableValue CONFLICT_KEEP_INTACT;
static final org.apache.nifi.components.AllowableValue CONFLICT_FAIL;
static final org.apache.nifi.components.AllowableValue CONFLICT_RENAME;
static final org.apache.nifi.components.PropertyDescriptor FILENAME;
static final org.apache.nifi.components.PropertyDescriptor COMPLETION_STRATEGY;
static final org.apache.nifi.components.PropertyDescriptor MOVE_DESTINATION_DIR;
static final org.apache.nifi.components.PropertyDescriptor CONFLICT_STRATEGY;
static final org.apache.nifi.components.PropertyDescriptor FILE_NOT_FOUND_LOG_LEVEL;
static final org.apache.nifi.components.PropertyDescriptor PERM_DENIED_LOG_LEVEL;
static final org.apache.nifi.processor.Relationship REL_SUCCESS;
static final org.apache.nifi.processor.Relationship REL_NOT_FOUND;
static final org.apache.nifi.processor.Relationship REL_PERMISSION_DENIED;
static final org.apache.nifi.processor.Relationship REL_FAILURE;
public void <init>()
{
org.apache.nifi.processors.standard.FetchFile v;
v := @this: org.apache.nifi.processors.standard.FetchFile;
specialinvoke v.<org.apache.nifi.processor.AbstractProcessor: void <init>()>();
return;
}
protected java.util.List getSupportedPropertyDescriptors()
{
org.apache.nifi.processors.standard.FetchFile v;
org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v;
java.util.ArrayList v;
v := @this: org.apache.nifi.processors.standard.FetchFile;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = <org.apache.nifi.processors.standard.FetchFile: org.apache.nifi.components.PropertyDescriptor FILENAME>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.FetchFile: org.apache.nifi.components.PropertyDescriptor COMPLETION_STRATEGY>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.FetchFile: org.apache.nifi.components.PropertyDescriptor MOVE_DESTINATION_DIR>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.FetchFile: org.apache.nifi.components.PropertyDescriptor CONFLICT_STRATEGY>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.FetchFile: org.apache.nifi.components.PropertyDescriptor FILE_NOT_FOUND_LOG_LEVEL>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.FetchFile: org.apache.nifi.components.PropertyDescriptor PERM_DENIED_LOG_LEVEL>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
return v;
}
public java.util.Set getRelationships()
{
java.util.HashSet v;
org.apache.nifi.processors.standard.FetchFile v;
org.apache.nifi.processor.Relationship v, v, v, v;
v := @this: org.apache.nifi.processors.standard.FetchFile;
v = new java.util.HashSet;
specialinvoke v.<java.util.HashSet: void <init>()>();
v = <org.apache.nifi.processors.standard.FetchFile: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.FetchFile: org.apache.nifi.processor.Relationship REL_NOT_FOUND>;
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.FetchFile: org.apache.nifi.processor.Relationship REL_PERMISSION_DENIED>;
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.FetchFile: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
return v;
}
protected java.util.Collection customValidate(org.apache.nifi.components.ValidationContext)
{
org.apache.nifi.processors.standard.FetchFile v;
org.apache.nifi.components.ValidationContext v;
org.apache.nifi.components.PropertyDescriptor v, v, v, v, v;
java.util.ArrayList v;
org.apache.nifi.components.PropertyValue v, v;
java.lang.String v, v, v, v, v, v, v;
org.apache.nifi.components.ValidationResult v;
boolean v, v;
org.apache.nifi.components.ValidationResult$Builder v, v, v, v, v;
org.apache.nifi.components.AllowableValue v, v;
v := @this: org.apache.nifi.processors.standard.FetchFile;
v := @parameter: org.apache.nifi.components.ValidationContext;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = <org.apache.nifi.processors.standard.FetchFile: org.apache.nifi.components.AllowableValue COMPLETION_MOVE>;
v = virtualinvoke v.<org.apache.nifi.components.AllowableValue: java.lang.String getValue()>();
v = <org.apache.nifi.processors.standard.FetchFile: org.apache.nifi.components.PropertyDescriptor COMPLETION_STRATEGY>;
v = interfaceinvoke v.<org.apache.nifi.components.ValidationContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.String getValue()>();
v = virtualinvoke v.<java.lang.String: boolean equalsIgnoreCase(java.lang.String)>(v);
if v == 0 goto label;
v = <org.apache.nifi.processors.standard.FetchFile: org.apache.nifi.components.PropertyDescriptor MOVE_DESTINATION_DIR>;
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: boolean isSet()>();
if v != 0 goto label;
v = new org.apache.nifi.components.ValidationResult$Builder;
specialinvoke v.<org.apache.nifi.components.ValidationResult$Builder: void <init>()>();
v = <org.apache.nifi.processors.standard.FetchFile: org.apache.nifi.components.PropertyDescriptor MOVE_DESTINATION_DIR>;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor: java.lang.String getName()>();
v = virtualinvoke v.<org.apache.nifi.components.ValidationResult$Builder: org.apache.nifi.components.ValidationResult$Builder subject(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.nifi.components.ValidationResult$Builder: org.apache.nifi.components.ValidationResult$Builder input(java.lang.String)>(null);
v = virtualinvoke v.<org.apache.nifi.components.ValidationResult$Builder: org.apache.nifi.components.ValidationResult$Builder valid(boolean)>(0);
v = <org.apache.nifi.processors.standard.FetchFile: org.apache.nifi.components.PropertyDescriptor MOVE_DESTINATION_DIR>;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor: java.lang.String getName()>();
v = <org.apache.nifi.processors.standard.FetchFile: org.apache.nifi.components.PropertyDescriptor COMPLETION_STRATEGY>;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor: java.lang.String getName()>();
v = <org.apache.nifi.processors.standard.FetchFile: org.apache.nifi.components.AllowableValue COMPLETION_MOVE>;
v = virtualinvoke v.<org.apache.nifi.components.AllowableValue: java.lang.String getDisplayName()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String,java.lang.String)>(v, v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u must be specified if \u is set to \u0001");
v = virtualinvoke v.<org.apache.nifi.components.ValidationResult$Builder: org.apache.nifi.components.ValidationResult$Builder explanation(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.nifi.components.ValidationResult$Builder: org.apache.nifi.components.ValidationResult build()>();
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
label:
return v;
}
public void onTrigger(org.apache.nifi.processor.ProcessContext, org.apache.nifi.processor.ProcessSession) throws org.apache.nifi.processor.exception.ProcessException
{
org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v;
java.nio.file.attribute.FileAttribute[] v;
java.nio.file.Path v, v;
org.apache.nifi.components.AllowableValue v, v;
java.lang.Exception v;
org.apache.nifi.util.StopWatch v;
java.lang.Throwable v, v;
java.lang.Object[] v, v, v, v, v, v, v;
long v;
org.apache.nifi.provenance.ProvenanceReporter v, v, v;
org.apache.nifi.processor.Relationship 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;
java.nio.file.LinkOption[] v, v, v;
org.apache.nifi.processor.ProcessSession v;
java.io.File v, v, v;
java.lang.Runnable v;
org.apache.nifi.components.PropertyValue v, v, v, v, v, v, v, v;
java.net.URI v, v;
boolean v, v, v, v, v, v, v, v, v, v, v;
org.apache.nifi.flowfile.FlowFile v, v, v, v, v;
org.apache.nifi.processors.standard.FetchFile v;
org.apache.nifi.logging.ComponentLog v, v, v, v, v, v, v;
org.apache.nifi.logging.LogLevel v, v;
org.apache.nifi.processor.ProcessContext v;
java.io.FileInputStream v;
java.util.concurrent.TimeUnit v;
v := @this: org.apache.nifi.processors.standard.FetchFile;
v := @parameter: org.apache.nifi.processor.ProcessContext;
v := @parameter: org.apache.nifi.processor.ProcessSession;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile get()>();
if v != null goto label;
return;
label:
v = new org.apache.nifi.util.StopWatch;
specialinvoke v.<org.apache.nifi.util.StopWatch: void <init>(boolean)>(1);
v = <org.apache.nifi.processors.standard.FetchFile: org.apache.nifi.components.PropertyDescriptor FILENAME>;
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 = <org.apache.nifi.processors.standard.FetchFile: org.apache.nifi.components.PropertyDescriptor FILE_NOT_FOUND_LOG_LEVEL>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.String getValue()>();
v = staticinvoke <org.apache.nifi.logging.LogLevel: org.apache.nifi.logging.LogLevel valueOf(java.lang.String)>(v);
v = <org.apache.nifi.processors.standard.FetchFile: org.apache.nifi.components.PropertyDescriptor PERM_DENIED_LOG_LEVEL>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.String getValue()>();
v = staticinvoke <org.apache.nifi.logging.LogLevel: org.apache.nifi.logging.LogLevel valueOf(java.lang.String)>(v);
v = new java.io.File;
specialinvoke v.<java.io.File: void <init>(java.lang.String)>(v);
v = virtualinvoke v.<java.io.File: java.nio.file.Path toPath()>();
v = newarray (java.nio.file.LinkOption)[0];
v = staticinvoke <java.nio.file.Files: boolean exists(java.nio.file.Path,java.nio.file.LinkOption[])>(v, v);
if v != 0 goto label;
v = newarray (java.nio.file.LinkOption)[0];
v = staticinvoke <java.nio.file.Files: boolean notExists(java.nio.file.Path,java.nio.file.LinkOption[])>(v, v);
if v != 0 goto label;
v = virtualinvoke v.<org.apache.nifi.processors.standard.FetchFile: org.apache.nifi.logging.ComponentLog getLogger()>();
v = newarray (java.lang.Object)[2];
v[0] = v;
v[1] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void log(org.apache.nifi.logging.LogLevel,java.lang.String,java.lang.Object[])>(v, "Could not fetch file {} from file system for {} because the existence of the file cannot be verified; routing to failure", v);
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile penalize(org.apache.nifi.flowfile.FlowFile)>(v);
v = <org.apache.nifi.processors.standard.FetchFile: 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);
return;
label:
v = newarray (java.nio.file.LinkOption)[0];
v = staticinvoke <java.nio.file.Files: boolean exists(java.nio.file.Path,java.nio.file.LinkOption[])>(v, v);
if v != 0 goto label;
v = virtualinvoke v.<org.apache.nifi.processors.standard.FetchFile: org.apache.nifi.logging.ComponentLog getLogger()>();
v = newarray (java.lang.Object)[2];
v[0] = v;
v[1] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void log(org.apache.nifi.logging.LogLevel,java.lang.String,java.lang.Object[])>(v, "Could not fetch file {} from file system for {} because the file does not exist; routing to not.found", v);
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.provenance.ProvenanceReporter getProvenanceReporter()>();
v = <org.apache.nifi.processors.standard.FetchFile: org.apache.nifi.processor.Relationship REL_NOT_FOUND>;
interfaceinvoke v.<org.apache.nifi.provenance.ProvenanceReporter: void route(org.apache.nifi.flowfile.FlowFile,org.apache.nifi.processor.Relationship)>(v, v);
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile penalize(org.apache.nifi.flowfile.FlowFile)>(v);
v = <org.apache.nifi.processors.standard.FetchFile: org.apache.nifi.processor.Relationship REL_NOT_FOUND>;
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.System: java.lang.String getProperty(java.lang.String)>("user.name");
v = virtualinvoke v.<org.apache.nifi.processors.standard.FetchFile: boolean isReadable(java.io.File)>(v);
if v != 0 goto label;
v = virtualinvoke v.<org.apache.nifi.processors.standard.FetchFile: 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 log(org.apache.nifi.logging.LogLevel,java.lang.String,java.lang.Object[])>(v, "Could not fetch file {} from file system for {} due to user {} not having sufficient permissions to read the file; routing to permission.denied", v);
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.provenance.ProvenanceReporter getProvenanceReporter()>();
v = <org.apache.nifi.processors.standard.FetchFile: org.apache.nifi.processor.Relationship REL_PERMISSION_DENIED>;
interfaceinvoke v.<org.apache.nifi.provenance.ProvenanceReporter: void route(org.apache.nifi.flowfile.FlowFile,org.apache.nifi.processor.Relationship)>(v, v);
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile penalize(org.apache.nifi.flowfile.FlowFile)>(v);
v = <org.apache.nifi.processors.standard.FetchFile: org.apache.nifi.processor.Relationship REL_PERMISSION_DENIED>;
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.processors.standard.FetchFile: org.apache.nifi.components.PropertyDescriptor COMPLETION_STRATEGY>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.String getValue()>();
v = <org.apache.nifi.processors.standard.FetchFile: org.apache.nifi.components.PropertyDescriptor MOVE_DESTINATION_DIR>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: org.apache.nifi.components.PropertyValue evaluateAttributeExpressions(org.apache.nifi.flowfile.FlowFile)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.String getValue()>();
if v == null goto label;
v = new java.io.File;
specialinvoke v.<java.io.File: void <init>(java.lang.String)>(v);
v = <org.apache.nifi.processors.standard.FetchFile: org.apache.nifi.components.AllowableValue COMPLETION_MOVE>;
v = virtualinvoke v.<org.apache.nifi.components.AllowableValue: java.lang.String getValue()>();
v = virtualinvoke v.<java.lang.String: boolean equalsIgnoreCase(java.lang.String)>(v);
if v == 0 goto label;
v = virtualinvoke v.<java.io.File: boolean exists()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.nifi.processors.standard.FetchFile: boolean isWritable(java.io.File)>(v);
if v == 0 goto label;
v = virtualinvoke v.<org.apache.nifi.processors.standard.FetchFile: boolean isDirectory(java.io.File)>(v);
if v != 0 goto label;
label:
v = virtualinvoke v.<org.apache.nifi.processors.standard.FetchFile: org.apache.nifi.logging.ComponentLog getLogger()>();
v = newarray (java.lang.Object)[4];
v[0] = v;
v[1] = v;
v[2] = v;
v[3] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void error(java.lang.String,java.lang.Object[])>("Could not fetch file {} from file system for {} because Completion Strategy is configured to move the original file to {}, but that is not a directory or user {} does not have permissions to write to that directory", v);
v = <org.apache.nifi.processors.standard.FetchFile: 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);
return;
label:
v = virtualinvoke v.<java.io.File: boolean exists()>();
if v != 0 goto label;
label:
v = virtualinvoke v.<java.io.File: java.nio.file.Path toPath()>();
v = newarray (java.nio.file.attribute.FileAttribute)[0];
staticinvoke <java.nio.file.Files: java.nio.file.Path createDirectories(java.nio.file.Path,java.nio.file.attribute.FileAttribute[])>(v, v);
label:
goto label;
label:
v := @caughtexception;
v = virtualinvoke v.<org.apache.nifi.processors.standard.FetchFile: org.apache.nifi.logging.ComponentLog getLogger()>();
v = newarray (java.lang.Object)[5];
v[0] = v;
v[1] = v;
v[2] = v;
v = virtualinvoke v.<java.lang.Exception: java.lang.String getMessage()>();
v[3] = v;
v[4] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void error(java.lang.String,java.lang.Object[])>("Could not fetch file {} from file system for {} because Completion Strategy is configured to move the original file to {}, but that directory does not exist and could not be created due to: {}", v);
v = <org.apache.nifi.processors.standard.FetchFile: 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);
return;
label:
v = <org.apache.nifi.processors.standard.FetchFile: org.apache.nifi.components.PropertyDescriptor CONFLICT_STRATEGY>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.String getValue()>();
v = <org.apache.nifi.processors.standard.FetchFile: org.apache.nifi.components.AllowableValue CONFLICT_FAIL>;
v = virtualinvoke v.<org.apache.nifi.components.AllowableValue: java.lang.String getValue()>();
v = virtualinvoke v.<java.lang.String: boolean equalsIgnoreCase(java.lang.String)>(v);
if v == 0 goto label;
v = new java.io.File;
v = virtualinvoke v.<java.io.File: java.lang.String getName()>();
specialinvoke v.<java.io.File: void <init>(java.io.File,java.lang.String)>(v, v);
v = virtualinvoke v.<java.io.File: boolean exists()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.nifi.processors.standard.FetchFile: org.apache.nifi.logging.ComponentLog getLogger()>();
v = newarray (java.lang.Object)[4];
v[0] = v;
v[1] = v;
v[2] = v;
v = virtualinvoke v.<java.io.File: java.lang.String getName()>();
v[3] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void error(java.lang.String,java.lang.Object[])>("Could not fetch file {} from file system for {} because Completion Strategy is configured to move the original file to {}, but a file with name {} already exists in that directory and the Move Conflict Strategy is configured for failure", v);
v = <org.apache.nifi.processors.standard.FetchFile: 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);
return;
label:
v = new java.io.FileInputStream;
specialinvoke v.<java.io.FileInputStream: void <init>(java.io.File)>(v);
label:
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile importFrom(java.io.InputStream,org.apache.nifi.flowfile.FlowFile)>(v, v);
label:
virtualinvoke v.<java.io.FileInputStream: void close()>();
goto label;
label:
v := @caughtexception;
throw v;
label:
v := @caughtexception;
v = virtualinvoke v.<org.apache.nifi.processors.standard.FetchFile: org.apache.nifi.logging.ComponentLog getLogger()>();
v = newarray (java.lang.Object)[4];
v[0] = v;
v[1] = v;
v = virtualinvoke v.<java.lang.Exception: java.lang.String toString()>();
v[2] = v;
v[3] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void error(java.lang.String,java.lang.Object[])>("Could not fetch file {} from file system for {} due to {}; routing to failure", v);
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile penalize(org.apache.nifi.flowfile.FlowFile)>(v);
v = <org.apache.nifi.processors.standard.FetchFile: 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);
return;
label:
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.provenance.ProvenanceReporter getProvenanceReporter()>();
v = virtualinvoke v.<java.io.File: java.net.URI toURI()>();
v = virtualinvoke v.<java.net.URI: java.lang.String toString()>();
v = virtualinvoke v.<java.io.File: java.net.URI toURI()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.net.URI)>(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[])>("Replaced content of FlowFile with contents of \u0001");
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit MILLISECONDS>;
v = virtualinvoke v.<org.apache.nifi.util.StopWatch: long getElapsed(java.util.concurrent.TimeUnit)>(v);
interfaceinvoke v.<org.apache.nifi.provenance.ProvenanceReporter: void fetch(org.apache.nifi.flowfile.FlowFile,java.lang.String,java.lang.String,long)>(v, v, v, v);
v = <org.apache.nifi.processors.standard.FetchFile: 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);
v = staticinvoke <org.apache.nifi.processors.standard.FetchFile$lambda_onTrigger_0__83: java.lang.Runnable bootstrap$(org.apache.nifi.processors.standard.FetchFile,java.lang.String,java.io.File,java.lang.String,org.apache.nifi.flowfile.FlowFile,org.apache.nifi.processor.ProcessContext)>(v, v, v, v, v, v);
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void commitAsync(java.lang.Runnable)>(v);
return;
catch java.lang.Exception from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.io.IOException from label to label with label;
catch org.apache.nifi.processor.exception.FlowFileAccessException from label to label with label;
}
private void performCompletionAction(java.lang.String, java.io.File, java.lang.String, org.apache.nifi.flowfile.FlowFile, org.apache.nifi.processor.ProcessContext)
{
org.apache.nifi.components.PropertyDescriptor v;
org.apache.nifi.components.PropertyValue v;
java.nio.file.Path v;
boolean v, v, v, v, v, v, v;
org.apache.nifi.flowfile.FlowFile v;
java.util.UUID v, v;
org.apache.nifi.components.AllowableValue v, v, v, v, v;
org.apache.nifi.processors.standard.FetchFile v;
java.lang.Object[] v;
org.apache.nifi.logging.ComponentLog v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.nifi.processor.ProcessContext v;
java.io.IOException v, v, v;
java.io.File v, v, v, v;
v := @this: org.apache.nifi.processors.standard.FetchFile;
v := @parameter: java.lang.String;
v := @parameter: java.io.File;
v := @parameter: java.lang.String;
v := @parameter: org.apache.nifi.flowfile.FlowFile;
v := @parameter: org.apache.nifi.processor.ProcessContext;
v = null;
v = <org.apache.nifi.processors.standard.FetchFile: org.apache.nifi.components.AllowableValue COMPLETION_DELETE>;
v = virtualinvoke v.<org.apache.nifi.components.AllowableValue: java.lang.String getValue()>();
v = virtualinvoke v.<java.lang.String: boolean equalsIgnoreCase(java.lang.String)>(v);
if v == 0 goto label;
label:
virtualinvoke v.<org.apache.nifi.processors.standard.FetchFile: void delete(java.io.File)>(v);
label:
goto label;
label:
v := @caughtexception;
v = v;
goto label;
label:
v = <org.apache.nifi.processors.standard.FetchFile: org.apache.nifi.components.AllowableValue COMPLETION_MOVE>;
v = virtualinvoke v.<org.apache.nifi.components.AllowableValue: java.lang.String getValue()>();
v = virtualinvoke v.<java.lang.String: boolean equalsIgnoreCase(java.lang.String)>(v);
if v == 0 goto label;
v = new java.io.File;
specialinvoke v.<java.io.File: void <init>(java.lang.String)>(v);
v = new java.io.File;
v = virtualinvoke v.<java.io.File: java.lang.String getName()>();
specialinvoke v.<java.io.File: void <init>(java.io.File,java.lang.String)>(v, v);
label:
v = virtualinvoke v.<java.io.File: boolean exists()>();
if v == 0 goto label;
v = <org.apache.nifi.processors.standard.FetchFile: org.apache.nifi.components.PropertyDescriptor CONFLICT_STRATEGY>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.String getValue()>();
v = <org.apache.nifi.processors.standard.FetchFile: org.apache.nifi.components.AllowableValue CONFLICT_KEEP_INTACT>;
v = virtualinvoke v.<org.apache.nifi.components.AllowableValue: java.lang.String getValue()>();
v = virtualinvoke v.<java.lang.String: boolean equalsIgnoreCase(java.lang.String)>(v);
if v == 0 goto label;
v = virtualinvoke v.<java.io.File: java.nio.file.Path toPath()>();
staticinvoke <java.nio.file.Files: void delete(java.nio.file.Path)>(v);
goto label;
label:
v = <org.apache.nifi.processors.standard.FetchFile: org.apache.nifi.components.AllowableValue CONFLICT_RENAME>;
v = virtualinvoke v.<org.apache.nifi.components.AllowableValue: java.lang.String getValue()>();
v = virtualinvoke v.<java.lang.String: boolean equalsIgnoreCase(java.lang.String)>(v);
if v == 0 goto label;
v = virtualinvoke v.<java.io.File: java.lang.String getName()>();
v = virtualinvoke v.<java.lang.String: boolean contains(java.lang.CharSequence)>(".");
if v == 0 goto label;
v = staticinvoke <org.apache.commons.lang.StringUtils: java.lang.String substringBeforeLast(java.lang.String,java.lang.String)>(v, ".");
v = staticinvoke <java.util.UUID: java.util.UUID randomUUID()>();
v = virtualinvoke v.<java.util.UUID: java.lang.String toString()>();
v = staticinvoke <org.apache.commons.lang.StringUtils: java.lang.String substringAfterLast(java.lang.String,java.lang.String)>(v, ".");
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String,java.lang.String)>(v, v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u0001-\u.\u0001");
goto label;
label:
v = staticinvoke <java.util.UUID: java.util.UUID randomUUID()>();
v = virtualinvoke v.<java.util.UUID: java.lang.String toString()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String)>(v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u0001-\u0001");
label:
v = new java.io.File;
specialinvoke v.<java.io.File: void <init>(java.io.File,java.lang.String)>(v, v);
virtualinvoke v.<org.apache.nifi.processors.standard.FetchFile: void move(java.io.File,java.io.File,boolean)>(v, v, 0);
goto label;
label:
v = <org.apache.nifi.processors.standard.FetchFile: org.apache.nifi.components.AllowableValue CONFLICT_REPLACE>;
v = virtualinvoke v.<org.apache.nifi.components.AllowableValue: java.lang.String getValue()>();
v = virtualinvoke v.<java.lang.String: boolean equalsIgnoreCase(java.lang.String)>(v);
if v == 0 goto label;
virtualinvoke v.<org.apache.nifi.processors.standard.FetchFile: void move(java.io.File,java.io.File,boolean)>(v, v, 1);
goto label;
label:
virtualinvoke v.<org.apache.nifi.processors.standard.FetchFile: void move(java.io.File,java.io.File,boolean)>(v, v, 0);
label:
goto label;
label:
v := @caughtexception;
v = v;
label:
if v == null goto label;
v = virtualinvoke v.<org.apache.nifi.processors.standard.FetchFile: org.apache.nifi.logging.ComponentLog getLogger()>();
v = newarray (java.lang.Object)[4];
v[0] = v;
v[1] = v;
v[2] = v;
v[3] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void warn(java.lang.String,java.lang.Object[])>("Successfully fetched the content from {} for {} but failed to perform Completion Action due to {}; routing to success", v);
label:
return;
catch java.io.IOException from label to label with label;
catch java.io.IOException from label to label with label;
}
protected void move(java.io.File, java.io.File, boolean) throws java.io.IOException
{
java.nio.file.CopyOption[] v;
org.apache.nifi.processors.standard.FetchFile v;
java.io.File v, v, v;
java.nio.file.StandardCopyOption v;
java.nio.file.attribute.FileAttribute[] v;
java.nio.file.Path v, v, v;
boolean v, v;
v := @this: org.apache.nifi.processors.standard.FetchFile;
v := @parameter: java.io.File;
v := @parameter: java.io.File;
v := @parameter: boolean;
v = virtualinvoke v.<java.io.File: java.io.File getParentFile()>();
v = virtualinvoke v.<java.io.File: java.nio.file.Path toPath()>();
v = virtualinvoke v.<java.io.File: boolean exists()>();
if v != 0 goto label;
v = virtualinvoke v.<java.io.File: java.nio.file.Path toPath()>();
v = newarray (java.nio.file.attribute.FileAttribute)[0];
staticinvoke <java.nio.file.Files: java.nio.file.Path createDirectories(java.nio.file.Path,java.nio.file.attribute.FileAttribute[])>(v, v);
label:
if v == 0 goto label;
v = newarray (java.nio.file.CopyOption)[1];
v = <java.nio.file.StandardCopyOption: java.nio.file.StandardCopyOption REPLACE_EXISTING>;
v[0] = v;
goto label;
label:
v = newarray (java.nio.file.CopyOption)[0];
label:
v = virtualinvoke v.<java.io.File: java.nio.file.Path toPath()>();
staticinvoke <java.nio.file.Files: java.nio.file.Path move(java.nio.file.Path,java.nio.file.Path,java.nio.file.CopyOption[])>(v, v, v);
return;
}
protected void delete(java.io.File) throws java.io.IOException
{
org.apache.nifi.processors.standard.FetchFile v;
java.nio.file.Path v;
java.io.File v;
v := @this: org.apache.nifi.processors.standard.FetchFile;
v := @parameter: java.io.File;
v = virtualinvoke v.<java.io.File: java.nio.file.Path toPath()>();
staticinvoke <java.nio.file.Files: void delete(java.nio.file.Path)>(v);
return;
}
protected boolean isReadable(java.io.File)
{
org.apache.nifi.processors.standard.FetchFile v;
java.io.File v;
boolean v;
v := @this: org.apache.nifi.processors.standard.FetchFile;
v := @parameter: java.io.File;
v = virtualinvoke v.<java.io.File: boolean canRead()>();
return v;
}
protected boolean isWritable(java.io.File)
{
org.apache.nifi.processors.standard.FetchFile v;
java.io.File v;
boolean v;
v := @this: org.apache.nifi.processors.standard.FetchFile;
v := @parameter: java.io.File;
v = virtualinvoke v.<java.io.File: boolean canWrite()>();
return v;
}
protected boolean isDirectory(java.io.File)
{
org.apache.nifi.processors.standard.FetchFile v;
java.io.File v;
boolean v;
v := @this: org.apache.nifi.processors.standard.FetchFile;
v := @parameter: java.io.File;
v = virtualinvoke v.<java.io.File: boolean isDirectory()>();
return v;
}
static void <clinit>()
{
org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v;
org.apache.nifi.components.AllowableValue v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.nifi.logging.LogLevel[] v, v;
org.apache.nifi.processor.Relationship v, v, v, v;
java.lang.String 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;
org.apache.nifi.expression.ExpressionLanguageScope v, v, v;
org.apache.nifi.components.AllowableValue[] v, v;
org.apache.nifi.logging.LogLevel 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, 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)>("None", "None", "Leave the file as-is");
<org.apache.nifi.processors.standard.FetchFile: org.apache.nifi.components.AllowableValue COMPLETION_NONE> = 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)>("Move File", "Move File", "Moves the file to the directory specified by the <Move Destination Directory> property");
<org.apache.nifi.processors.standard.FetchFile: org.apache.nifi.components.AllowableValue COMPLETION_MOVE> = 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)>("Delete File", "Delete File", "Deletes the original file from the file system");
<org.apache.nifi.processors.standard.FetchFile: org.apache.nifi.components.AllowableValue COMPLETION_DELETE> = 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)>("Replace File", "Replace File", "The newly ingested file should replace the existing file in the Destination Directory");
<org.apache.nifi.processors.standard.FetchFile: org.apache.nifi.components.AllowableValue CONFLICT_REPLACE> = 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)>("Keep Existing", "Keep Existing", "The existing file should in the Destination Directory should stay intact and the newly ingested file should be deleted");
<org.apache.nifi.processors.standard.FetchFile: org.apache.nifi.components.AllowableValue CONFLICT_KEEP_INTACT> = 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", "The existing destination file should remain intact and the incoming FlowFile should be routed to failure");
<org.apache.nifi.processors.standard.FetchFile: org.apache.nifi.components.AllowableValue CONFLICT_FAIL> = 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)>("Rename", "Rename", "The existing destination file should remain intact. The newly ingested file should be moved to the destination directory but be renamed to a random filename");
<org.apache.nifi.processors.standard.FetchFile: org.apache.nifi.components.AllowableValue CONFLICT_RENAME> = 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)>("File to Fetch");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("The fully-qualified filename of the file to fetch from the file system");
v = <org.apache.nifi.processor.util.StandardValidators: org.apache.nifi.components.Validator NON_EMPTY_VALIDATOR>;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder addValidator(org.apache.nifi.components.Validator)>(v);
v = <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)>("${absolute.path}/${filename}");
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.FetchFile: org.apache.nifi.components.PropertyDescriptor FILENAME> = 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)>("Completion Strategy");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("Specifies what to do with the original file on the file system once it has been pulled into NiFi");
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 (org.apache.nifi.components.AllowableValue)[3];
v = <org.apache.nifi.processors.standard.FetchFile: org.apache.nifi.components.AllowableValue COMPLETION_NONE>;
v[0] = v;
v = <org.apache.nifi.processors.standard.FetchFile: org.apache.nifi.components.AllowableValue COMPLETION_MOVE>;
v[1] = v;
v = <org.apache.nifi.processors.standard.FetchFile: org.apache.nifi.components.AllowableValue COMPLETION_DELETE>;
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.FetchFile: org.apache.nifi.components.AllowableValue COMPLETION_NONE>;
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$Builder required(boolean)>(1);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.FetchFile: org.apache.nifi.components.PropertyDescriptor COMPLETION_STRATEGY> = v;
v = new org.apache.nifi.components.PropertyDescriptor$Builder;
specialinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder name(java.lang.String)>("Move Destination Directory");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("The directory to the move the original file to once it has been fetched from the file system. This property is ignored unless the Completion Strategy is set to \"Move File\". If the directory does not exist, it will be created.");
v = <org.apache.nifi.expression.ExpressionLanguageScope: org.apache.nifi.expression.ExpressionLanguageScope FLOWFILE_ATTRIBUTES>;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder expressionLanguageSupported(org.apache.nifi.expression.ExpressionLanguageScope)>(v);
v = <org.apache.nifi.processor.util.StandardValidators: org.apache.nifi.components.Validator NON_EMPTY_VALIDATOR>;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder addValidator(org.apache.nifi.components.Validator)>(v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder required(boolean)>(0);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.FetchFile: org.apache.nifi.components.PropertyDescriptor MOVE_DESTINATION_DIR> = 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)>("Move Conflict Strategy");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("If Completion Strategy is set to Move File and a file already exists in the destination directory with the same name, this property specifies how that naming conflict should be resolved");
v = newarray (org.apache.nifi.components.AllowableValue)[4];
v = <org.apache.nifi.processors.standard.FetchFile: org.apache.nifi.components.AllowableValue CONFLICT_RENAME>;
v[0] = v;
v = <org.apache.nifi.processors.standard.FetchFile: org.apache.nifi.components.AllowableValue CONFLICT_REPLACE>;
v[1] = v;
v = <org.apache.nifi.processors.standard.FetchFile: org.apache.nifi.components.AllowableValue CONFLICT_KEEP_INTACT>;
v[2] = v;
v = <org.apache.nifi.processors.standard.FetchFile: org.apache.nifi.components.AllowableValue CONFLICT_FAIL>;
v[3] = 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.FetchFile: org.apache.nifi.components.AllowableValue CONFLICT_RENAME>;
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$Builder required(boolean)>(1);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.FetchFile: org.apache.nifi.components.PropertyDescriptor CONFLICT_STRATEGY> = v;
v = new org.apache.nifi.components.PropertyDescriptor$Builder;
specialinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder name(java.lang.String)>("Log level when file not found");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("Log level to use in case the file does not exist when the processor is triggered");
v = staticinvoke <org.apache.nifi.logging.LogLevel: org.apache.nifi.logging.LogLevel[] values()>();
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder allowableValues(java.lang.Enum[])>(v);
v = <org.apache.nifi.logging.LogLevel: org.apache.nifi.logging.LogLevel ERROR>;
v = virtualinvoke v.<org.apache.nifi.logging.LogLevel: java.lang.String toString()>();
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$Builder required(boolean)>(1);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.FetchFile: org.apache.nifi.components.PropertyDescriptor FILE_NOT_FOUND_LOG_LEVEL> = 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)>("Log level when permission denied");
v = staticinvoke <java.lang.System: java.lang.String getProperty(java.lang.String)>("user.name");
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[])>("Log level to use in case user \u does not have sufficient permissions to read the file");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>(v);
v = staticinvoke <org.apache.nifi.logging.LogLevel: org.apache.nifi.logging.LogLevel[] values()>();
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder allowableValues(java.lang.Enum[])>(v);
v = <org.apache.nifi.logging.LogLevel: org.apache.nifi.logging.LogLevel ERROR>;
v = virtualinvoke v.<org.apache.nifi.logging.LogLevel: java.lang.String toString()>();
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$Builder required(boolean)>(1);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.FetchFile: org.apache.nifi.components.PropertyDescriptor PERM_DENIED_LOG_LEVEL> = 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)>("Any FlowFile that is successfully fetched from the file system will be transferred to this Relationship.");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship build()>();
<org.apache.nifi.processors.standard.FetchFile: 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)>("not.found");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship$Builder description(java.lang.String)>("Any FlowFile that could not be fetched from the file system because the file could not be found will be transferred to this Relationship.");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship build()>();
<org.apache.nifi.processors.standard.FetchFile: org.apache.nifi.processor.Relationship REL_NOT_FOUND> = 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)>("permission.denied");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship$Builder description(java.lang.String)>("Any FlowFile that could not be fetched from the file system due to the user running NiFi not having sufficient permissions will be transferred to this Relationship.");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship build()>();
<org.apache.nifi.processors.standard.FetchFile: org.apache.nifi.processor.Relationship REL_PERMISSION_DENIED> = 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)>("Any FlowFile that could not be fetched from the file system for any reason other than insufficient permissions or the file not existing will be transferred to this Relationship.");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship build()>();
<org.apache.nifi.processors.standard.FetchFile: org.apache.nifi.processor.Relationship REL_FAILURE> = v;
return;
}
}