public class org.apache.nifi.processors.standard.GetFile extends org.apache.nifi.processor.AbstractProcessor
{
public static final org.apache.nifi.components.PropertyDescriptor DIRECTORY;
public static final org.apache.nifi.components.PropertyDescriptor RECURSE;
public static final org.apache.nifi.components.PropertyDescriptor KEEP_SOURCE_FILE;
public static final org.apache.nifi.components.PropertyDescriptor FILE_FILTER;
public static final org.apache.nifi.components.PropertyDescriptor PATH_FILTER;
public static final org.apache.nifi.components.PropertyDescriptor MIN_AGE;
public static final org.apache.nifi.components.PropertyDescriptor MAX_AGE;
public static final org.apache.nifi.components.PropertyDescriptor MIN_SIZE;
public static final org.apache.nifi.components.PropertyDescriptor MAX_SIZE;
public static final org.apache.nifi.components.PropertyDescriptor IGNORE_HIDDEN_FILES;
public static final org.apache.nifi.components.PropertyDescriptor POLLING_INTERVAL;
public static final org.apache.nifi.components.PropertyDescriptor BATCH_SIZE;
public static final java.lang.String FILE_CREATION_TIME_ATTRIBUTE;
public static final java.lang.String FILE_LAST_MODIFY_TIME_ATTRIBUTE;
public static final java.lang.String FILE_LAST_ACCESS_TIME_ATTRIBUTE;
public static final java.lang.String FILE_OWNER_ATTRIBUTE;
public static final java.lang.String FILE_GROUP_ATTRIBUTE;
public static final java.lang.String FILE_PERMISSIONS_ATTRIBUTE;
public static final java.lang.String FILE_MODIFY_DATE_ATTR_FORMAT;
public static final org.apache.nifi.processor.Relationship REL_SUCCESS;
private java.util.List properties;
private java.util.Set relationships;
private final java.util.concurrent.BlockingQueue fileQueue;
private final java.util.Set inProcess;
private final java.util.Set recentlyProcessed;
private final java.util.concurrent.locks.Lock queueLock;
private final java.util.concurrent.locks.Lock listingLock;
private final java.util.concurrent.atomic.AtomicLong queueLastUpdated;
public void <init>()
{
java.util.HashSet v, v;
java.util.concurrent.atomic.AtomicLong v;
java.util.concurrent.locks.ReentrantLock v, v;
org.apache.nifi.processors.standard.GetFile v;
java.util.concurrent.LinkedBlockingQueue v;
v := @this: org.apache.nifi.processors.standard.GetFile;
specialinvoke v.<org.apache.nifi.processor.AbstractProcessor: void <init>()>();
v = new java.util.concurrent.LinkedBlockingQueue;
specialinvoke v.<java.util.concurrent.LinkedBlockingQueue: void <init>()>();
v.<org.apache.nifi.processors.standard.GetFile: java.util.concurrent.BlockingQueue fileQueue> = v;
v = new java.util.HashSet;
specialinvoke v.<java.util.HashSet: void <init>()>();
v.<org.apache.nifi.processors.standard.GetFile: java.util.Set inProcess> = v;
v = new java.util.HashSet;
specialinvoke v.<java.util.HashSet: void <init>()>();
v.<org.apache.nifi.processors.standard.GetFile: java.util.Set recentlyProcessed> = v;
v = new java.util.concurrent.locks.ReentrantLock;
specialinvoke v.<java.util.concurrent.locks.ReentrantLock: void <init>()>();
v.<org.apache.nifi.processors.standard.GetFile: java.util.concurrent.locks.Lock queueLock> = v;
v = new java.util.concurrent.locks.ReentrantLock;
specialinvoke v.<java.util.concurrent.locks.ReentrantLock: void <init>()>();
v.<org.apache.nifi.processors.standard.GetFile: java.util.concurrent.locks.Lock listingLock> = v;
v = new java.util.concurrent.atomic.AtomicLong;
specialinvoke v.<java.util.concurrent.atomic.AtomicLong: void <init>(long)>(0L);
v.<org.apache.nifi.processors.standard.GetFile: java.util.concurrent.atomic.AtomicLong queueLastUpdated> = v;
return;
}
protected void init(org.apache.nifi.processor.ProcessorInitializationContext)
{
org.apache.nifi.processors.standard.GetFile v;
org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v, v, v, v, v, v, v;
java.util.ArrayList v;
java.util.HashSet v;
org.apache.nifi.processor.Relationship v;
java.util.Set v;
java.util.List v;
org.apache.nifi.processor.ProcessorInitializationContext v;
v := @this: org.apache.nifi.processors.standard.GetFile;
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.GetFile: org.apache.nifi.components.PropertyDescriptor DIRECTORY>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.GetFile: org.apache.nifi.components.PropertyDescriptor FILE_FILTER>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.GetFile: org.apache.nifi.components.PropertyDescriptor PATH_FILTER>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.GetFile: org.apache.nifi.components.PropertyDescriptor BATCH_SIZE>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.GetFile: org.apache.nifi.components.PropertyDescriptor KEEP_SOURCE_FILE>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.GetFile: org.apache.nifi.components.PropertyDescriptor RECURSE>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.GetFile: org.apache.nifi.components.PropertyDescriptor POLLING_INTERVAL>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.GetFile: org.apache.nifi.components.PropertyDescriptor IGNORE_HIDDEN_FILES>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.GetFile: org.apache.nifi.components.PropertyDescriptor MIN_AGE>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.GetFile: org.apache.nifi.components.PropertyDescriptor MAX_AGE>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.GetFile: org.apache.nifi.components.PropertyDescriptor MIN_SIZE>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.GetFile: org.apache.nifi.components.PropertyDescriptor MAX_SIZE>;
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.GetFile: java.util.List properties> = v;
v = new java.util.HashSet;
specialinvoke v.<java.util.HashSet: void <init>()>();
v = <org.apache.nifi.processors.standard.GetFile: org.apache.nifi.processor.Relationship REL_SUCCESS>;
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.GetFile: java.util.Set relationships> = v;
return;
}
protected java.util.List getSupportedPropertyDescriptors()
{
java.util.List v;
org.apache.nifi.processors.standard.GetFile v;
v := @this: org.apache.nifi.processors.standard.GetFile;
v = v.<org.apache.nifi.processors.standard.GetFile: java.util.List properties>;
return v;
}
public java.util.Set getRelationships()
{
java.util.Set v;
org.apache.nifi.processors.standard.GetFile v;
v := @this: org.apache.nifi.processors.standard.GetFile;
v = v.<org.apache.nifi.processors.standard.GetFile: java.util.Set relationships>;
return v;
}
public void onScheduled(org.apache.nifi.processor.ProcessContext)
{
org.apache.nifi.processor.ProcessContext v;
java.util.concurrent.BlockingQueue v;
org.apache.nifi.processors.standard.GetFile v;
v := @this: org.apache.nifi.processors.standard.GetFile;
v := @parameter: org.apache.nifi.processor.ProcessContext;
v = v.<org.apache.nifi.processors.standard.GetFile: java.util.concurrent.BlockingQueue fileQueue>;
interfaceinvoke v.<java.util.concurrent.BlockingQueue: void clear()>();
return;
}
private java.io.FileFilter createFileFilter(org.apache.nifi.processor.ProcessContext, java.nio.file.Path)
{
org.apache.nifi.processors.standard.GetFile$1 v;
org.apache.nifi.processors.standard.GetFile v;
org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v, v, v, v;
org.apache.nifi.components.PropertyValue v, v, v, v, v, v, v, v, v;
java.lang.Long v, v;
java.nio.file.Path v;
boolean v, v, v;
java.util.regex.Pattern v, v;
org.apache.nifi.processor.DataUnit v, v;
java.lang.Double v, v;
long v, v;
java.lang.Boolean v, v, v;
java.lang.String v, v;
org.apache.nifi.processor.ProcessContext v;
java.util.concurrent.TimeUnit v, v;
v := @this: org.apache.nifi.processors.standard.GetFile;
v := @parameter: org.apache.nifi.processor.ProcessContext;
v := @parameter: java.nio.file.Path;
v = <org.apache.nifi.processors.standard.GetFile: org.apache.nifi.components.PropertyDescriptor MIN_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: long longValue()>();
v = <org.apache.nifi.processors.standard.GetFile: org.apache.nifi.components.PropertyDescriptor MAX_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 = <org.apache.nifi.processors.standard.GetFile: org.apache.nifi.components.PropertyDescriptor MIN_AGE>;
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.GetFile: org.apache.nifi.components.PropertyDescriptor MAX_AGE>;
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 = <org.apache.nifi.processors.standard.GetFile: org.apache.nifi.components.PropertyDescriptor IGNORE_HIDDEN_FILES>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.Boolean asBoolean()>();
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
v = <org.apache.nifi.processors.standard.GetFile: org.apache.nifi.components.PropertyDescriptor FILE_FILTER>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.String getValue()>();
v = staticinvoke <java.util.regex.Pattern: java.util.regex.Pattern compile(java.lang.String)>(v);
v = <org.apache.nifi.processors.standard.GetFile: org.apache.nifi.components.PropertyDescriptor RECURSE>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.Boolean asBoolean()>();
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
v = <org.apache.nifi.processors.standard.GetFile: org.apache.nifi.components.PropertyDescriptor PATH_FILTER>;
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()>();
if v == 0 goto label;
if v != null goto label;
label:
v = null;
goto label;
label:
v = staticinvoke <java.util.regex.Pattern: java.util.regex.Pattern compile(java.lang.String)>(v);
label:
v = <org.apache.nifi.processors.standard.GetFile: org.apache.nifi.components.PropertyDescriptor KEEP_SOURCE_FILE>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.Boolean asBoolean()>();
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
v = new org.apache.nifi.processors.standard.GetFile$1;
specialinvoke v.<org.apache.nifi.processors.standard.GetFile$1: void <init>(org.apache.nifi.processors.standard.GetFile,long,java.lang.Double,long,java.lang.Long,boolean,java.util.regex.Pattern,java.nio.file.Path,boolean,java.util.regex.Pattern)>(v, v, v, v, v, v, v, v, v, v);
return v;
}
private java.util.Set performListing(java.io.File, java.io.FileFilter, boolean)
{
java.lang.IllegalStateException v;
org.apache.nifi.processors.standard.GetFile v;
java.util.HashSet v;
int v, v;
java.lang.String v;
java.nio.file.Path v;
boolean v, v, v, v, v, v;
java.util.Set v;
java.io.File v, v;
java.io.FileFilter v;
java.io.File[] v;
v := @this: org.apache.nifi.processors.standard.GetFile;
v := @parameter: java.io.File;
v := @parameter: java.io.FileFilter;
v := @parameter: boolean;
v = virtualinvoke v.<java.io.File: java.nio.file.Path toPath()>();
v = staticinvoke <java.nio.file.Files: boolean isWritable(java.nio.file.Path)>(v);
if v == 0 goto label;
v = staticinvoke <java.nio.file.Files: boolean isReadable(java.nio.file.Path)>(v);
if v != 0 goto label;
label:
v = new java.lang.IllegalStateException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.io.File)>(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[])>("Directory \'\u0001\' does not have sufficient permissions (i.e., not writable and readable)");
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>(v);
throw v;
label:
v = new java.util.HashSet;
specialinvoke v.<java.util.HashSet: void <init>()>();
v = virtualinvoke v.<java.io.File: boolean exists()>();
if v != 0 goto label;
return v;
label:
v = virtualinvoke v.<java.io.File: java.io.File[] listFiles()>();
if v != null goto label;
return v;
label:
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = virtualinvoke v.<java.io.File: boolean isDirectory()>();
if v == 0 goto label;
if v == 0 goto label;
v = specialinvoke v.<org.apache.nifi.processors.standard.GetFile: java.util.Set performListing(java.io.File,java.io.FileFilter,boolean)>(v, v, v);
interfaceinvoke v.<java.util.Set: boolean addAll(java.util.Collection)>(v);
goto label;
label:
v = interfaceinvoke v.<java.io.FileFilter: boolean accept(java.io.File)>(v);
if v == 0 goto label;
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
label:
v = v + 1;
goto label;
label:
return v;
}
protected java.util.Map getAttributesFromFile(java.nio.file.Path)
{
org.apache.nifi.processors.standard.GetFile v;
java.util.Date v, v, v;
java.nio.file.attribute.FileTime v, v, v;
java.util.Locale v;
java.nio.file.Path v;
boolean v, v, v;
java.nio.file.attribute.PosixFileAttributes v, v;
java.nio.file.attribute.FileAttributeView v, v, v;
java.util.Set v;
java.lang.Exception v, v, v;
java.text.SimpleDateFormat v;
java.util.HashMap v;
long v, v, v;
java.nio.file.attribute.GroupPrincipal v;
java.nio.file.attribute.UserPrincipal v;
java.lang.String v, v, v, v, v, v;
java.nio.file.LinkOption[] v, v, v;
java.nio.file.FileStore v;
java.io.IOException v;
java.nio.file.attribute.BasicFileAttributes v;
v := @this: org.apache.nifi.processors.standard.GetFile;
v := @parameter: java.nio.file.Path;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
label:
v = staticinvoke <java.nio.file.Files: java.nio.file.FileStore getFileStore(java.nio.file.Path)>(v);
v = virtualinvoke v.<java.nio.file.FileStore: boolean supportsFileAttributeView(java.lang.String)>("basic");
if v == 0 goto label;
label:
v = new java.text.SimpleDateFormat;
v = <java.util.Locale: java.util.Locale US>;
specialinvoke v.<java.text.SimpleDateFormat: void <init>(java.lang.String,java.util.Locale)>("yyyy-MM-dd\'T\'HH:mm:ssZ", v);
v = newarray (java.nio.file.LinkOption)[0];
v = staticinvoke <java.nio.file.Files: java.nio.file.attribute.FileAttributeView getFileAttributeView(java.nio.file.Path,java.lang.Class,java.nio.file.LinkOption[])>(v, class "Ljava/nio/file/attribute/BasicFileAttributeView;", v);
v = interfaceinvoke v.<java.nio.file.attribute.BasicFileAttributeView: java.nio.file.attribute.BasicFileAttributes readAttributes()>();
v = new java.util.Date;
v = interfaceinvoke v.<java.nio.file.attribute.BasicFileAttributes: java.nio.file.attribute.FileTime lastModifiedTime()>();
v = virtualinvoke v.<java.nio.file.attribute.FileTime: long toMillis()>();
specialinvoke v.<java.util.Date: void <init>(long)>(v);
v = virtualinvoke v.<java.text.DateFormat: java.lang.String format(java.util.Date)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("file.lastModifiedTime", v);
v = new java.util.Date;
v = interfaceinvoke v.<java.nio.file.attribute.BasicFileAttributes: java.nio.file.attribute.FileTime creationTime()>();
v = virtualinvoke v.<java.nio.file.attribute.FileTime: long toMillis()>();
specialinvoke v.<java.util.Date: void <init>(long)>(v);
v = virtualinvoke v.<java.text.DateFormat: java.lang.String format(java.util.Date)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("file.creationTime", v);
v = new java.util.Date;
v = interfaceinvoke v.<java.nio.file.attribute.BasicFileAttributes: java.nio.file.attribute.FileTime lastAccessTime()>();
v = virtualinvoke v.<java.nio.file.attribute.FileTime: long toMillis()>();
specialinvoke v.<java.util.Date: void <init>(long)>(v);
v = virtualinvoke v.<java.text.DateFormat: java.lang.String format(java.util.Date)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("file.lastAccessTime", v);
label:
goto label;
label:
v := @caughtexception;
label:
v = virtualinvoke v.<java.nio.file.FileStore: boolean supportsFileAttributeView(java.lang.String)>("owner");
if v == 0 goto label;
label:
v = newarray (java.nio.file.LinkOption)[0];
v = staticinvoke <java.nio.file.Files: java.nio.file.attribute.FileAttributeView getFileAttributeView(java.nio.file.Path,java.lang.Class,java.nio.file.LinkOption[])>(v, class "Ljava/nio/file/attribute/FileOwnerAttributeView;", v);
v = interfaceinvoke v.<java.nio.file.attribute.FileOwnerAttributeView: java.nio.file.attribute.UserPrincipal getOwner()>();
v = interfaceinvoke v.<java.nio.file.attribute.UserPrincipal: java.lang.String getName()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("file.owner", v);
label:
goto label;
label:
v := @caughtexception;
label:
v = virtualinvoke v.<java.nio.file.FileStore: boolean supportsFileAttributeView(java.lang.String)>("posix");
if v == 0 goto label;
label:
v = newarray (java.nio.file.LinkOption)[0];
v = staticinvoke <java.nio.file.Files: java.nio.file.attribute.FileAttributeView getFileAttributeView(java.nio.file.Path,java.lang.Class,java.nio.file.LinkOption[])>(v, class "Ljava/nio/file/attribute/PosixFileAttributeView;", v);
v = interfaceinvoke v.<java.nio.file.attribute.PosixFileAttributeView: java.nio.file.attribute.PosixFileAttributes readAttributes()>();
v = interfaceinvoke v.<java.nio.file.attribute.PosixFileAttributes: java.util.Set permissions()>();
v = staticinvoke <java.nio.file.attribute.PosixFilePermissions: java.lang.String toString(java.util.Set)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("file.permissions", v);
v = interfaceinvoke v.<java.nio.file.attribute.PosixFileAttributeView: java.nio.file.attribute.PosixFileAttributes readAttributes()>();
v = interfaceinvoke v.<java.nio.file.attribute.PosixFileAttributes: java.nio.file.attribute.GroupPrincipal group()>();
v = interfaceinvoke v.<java.nio.file.attribute.GroupPrincipal: java.lang.String getName()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("file.group", v);
label:
goto label;
label:
v := @caughtexception;
label:
goto label;
label:
v := @caughtexception;
label:
return v;
catch java.lang.Exception from label to label with label;
catch java.lang.Exception from label to label with label;
catch java.lang.Exception from label to label with label;
catch java.io.IOException from label to label with label;
}
public void onTrigger(org.apache.nifi.processor.ProcessContext, org.apache.nifi.processor.ProcessSession) throws org.apache.nifi.processor.exception.ProcessException
{
java.lang.Integer v;
org.apache.nifi.components.PropertyDescriptor v, v, v, v, v;
byte v;
java.lang.Long v;
java.util.Map v;
java.nio.file.Path v, v, v, v, v, v, v;
java.util.Set v, v, v, v, v, v, v, v, v, v, v, v;
java.util.concurrent.BlockingQueue v, v, v, v, v;
java.lang.Exception v;
java.lang.Throwable v, v, v, v, v, v, v, v;
java.lang.Object[] v;
long v, v, v, v, v, v, v, v, v;
java.util.ArrayList v;
org.apache.nifi.provenance.ProvenanceReporter v;
org.apache.nifi.processor.Relationship v;
java.lang.String v, v, v, v, v, v, v, v, v, v;
org.apache.nifi.processor.ProcessSession v;
java.io.File v;
java.util.concurrent.atomic.AtomicLong v, v;
java.util.concurrent.locks.Lock v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.io.FileFilter v;
org.apache.nifi.flowfile.attributes.CoreAttributes v, v, v;
java.util.ListIterator v;
org.apache.nifi.processors.standard.GetFile v;
org.apache.nifi.components.PropertyValue v, v, v, v, v, v;
java.net.URI v;
boolean v, v, v, v, v, v, v, v, v;
org.apache.nifi.flowfile.FlowFile v;
org.apache.nifi.logging.ComponentLog v;
int v, v, v;
java.lang.Boolean v, v;
org.apache.nifi.processor.ProcessContext v;
java.util.concurrent.TimeUnit v, v, v;
java.lang.Object v, v;
v := @this: org.apache.nifi.processors.standard.GetFile;
v := @parameter: org.apache.nifi.processor.ProcessContext;
v := @parameter: org.apache.nifi.processor.ProcessSession;
v = new java.io.File;
v = <org.apache.nifi.processors.standard.GetFile: org.apache.nifi.components.PropertyDescriptor DIRECTORY>;
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()>();
specialinvoke v.<java.io.File: void <init>(java.lang.String)>(v);
v = <org.apache.nifi.processors.standard.GetFile: org.apache.nifi.components.PropertyDescriptor KEEP_SOURCE_FILE>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.Boolean asBoolean()>();
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
v = virtualinvoke v.<org.apache.nifi.processors.standard.GetFile: org.apache.nifi.logging.ComponentLog getLogger()>();
v = virtualinvoke v.<java.io.File: java.nio.file.Path toPath()>();
v = specialinvoke v.<org.apache.nifi.processors.standard.GetFile: java.io.FileFilter createFileFilter(org.apache.nifi.processor.ProcessContext,java.nio.file.Path)>(v, v);
v = v.<org.apache.nifi.processors.standard.GetFile: java.util.concurrent.BlockingQueue fileQueue>;
v = interfaceinvoke v.<java.util.concurrent.BlockingQueue: int size()>();
if v >= 100 goto label;
v = <org.apache.nifi.processors.standard.GetFile: org.apache.nifi.components.PropertyDescriptor POLLING_INTERVAL>;
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 = v.<org.apache.nifi.processors.standard.GetFile: java.util.concurrent.atomic.AtomicLong queueLastUpdated>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicLong: long get()>();
v = staticinvoke <java.lang.System: long currentTimeMillis()>();
v = v - v;
v = v cmp v;
if v >= 0 goto label;
v = v.<org.apache.nifi.processors.standard.GetFile: java.util.concurrent.locks.Lock listingLock>;
v = interfaceinvoke v.<java.util.concurrent.locks.Lock: boolean tryLock()>();
if v == 0 goto label;
label:
v = <org.apache.nifi.processors.standard.GetFile: org.apache.nifi.components.PropertyDescriptor RECURSE>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.Boolean asBoolean()>();
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
v = specialinvoke v.<org.apache.nifi.processors.standard.GetFile: java.util.Set performListing(java.io.File,java.io.FileFilter,boolean)>(v, v, v);
v = v.<org.apache.nifi.processors.standard.GetFile: java.util.concurrent.locks.Lock queueLock>;
interfaceinvoke v.<java.util.concurrent.locks.Lock: void lock()>();
label:
v = v.<org.apache.nifi.processors.standard.GetFile: java.util.Set inProcess>;
interfaceinvoke v.<java.util.Set: boolean removeAll(java.util.Collection)>(v);
if v != 0 goto label;
v = v.<org.apache.nifi.processors.standard.GetFile: java.util.Set recentlyProcessed>;
interfaceinvoke v.<java.util.Set: boolean removeAll(java.util.Collection)>(v);
label:
v = v.<org.apache.nifi.processors.standard.GetFile: java.util.concurrent.BlockingQueue fileQueue>;
interfaceinvoke v.<java.util.concurrent.BlockingQueue: void clear()>();
v = v.<org.apache.nifi.processors.standard.GetFile: java.util.concurrent.BlockingQueue fileQueue>;
interfaceinvoke v.<java.util.concurrent.BlockingQueue: boolean addAll(java.util.Collection)>(v);
v = v.<org.apache.nifi.processors.standard.GetFile: java.util.concurrent.atomic.AtomicLong queueLastUpdated>;
v = staticinvoke <java.lang.System: long currentTimeMillis()>();
virtualinvoke v.<java.util.concurrent.atomic.AtomicLong: void set(long)>(v);
v = v.<org.apache.nifi.processors.standard.GetFile: java.util.Set recentlyProcessed>;
interfaceinvoke v.<java.util.Set: void clear()>();
v = interfaceinvoke v.<java.util.Set: boolean isEmpty()>();
if v == 0 goto label;
interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: void yield()>();
label:
v = v.<org.apache.nifi.processors.standard.GetFile: java.util.concurrent.locks.Lock queueLock>;
interfaceinvoke v.<java.util.concurrent.locks.Lock: void unlock()>();
goto label;
label:
v := @caughtexception;
v = v.<org.apache.nifi.processors.standard.GetFile: java.util.concurrent.locks.Lock queueLock>;
interfaceinvoke v.<java.util.concurrent.locks.Lock: void unlock()>();
throw v;
label:
v = v.<org.apache.nifi.processors.standard.GetFile: java.util.concurrent.locks.Lock listingLock>;
interfaceinvoke v.<java.util.concurrent.locks.Lock: void unlock()>();
goto label;
label:
v := @caughtexception;
v = v.<org.apache.nifi.processors.standard.GetFile: java.util.concurrent.locks.Lock listingLock>;
interfaceinvoke v.<java.util.concurrent.locks.Lock: void unlock()>();
throw v;
label:
v = <org.apache.nifi.processors.standard.GetFile: org.apache.nifi.components.PropertyDescriptor BATCH_SIZE>;
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()>();
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>(int)>(v);
v = v.<org.apache.nifi.processors.standard.GetFile: java.util.concurrent.locks.Lock queueLock>;
interfaceinvoke v.<java.util.concurrent.locks.Lock: void lock()>();
label:
v = v.<org.apache.nifi.processors.standard.GetFile: java.util.concurrent.BlockingQueue fileQueue>;
interfaceinvoke v.<java.util.concurrent.BlockingQueue: int drainTo(java.util.Collection,int)>(v, v);
v = interfaceinvoke v.<java.util.List: boolean isEmpty()>();
if v == 0 goto label;
label:
v = v.<org.apache.nifi.processors.standard.GetFile: java.util.concurrent.locks.Lock queueLock>;
interfaceinvoke v.<java.util.concurrent.locks.Lock: void unlock()>();
return;
label:
v = v.<org.apache.nifi.processors.standard.GetFile: java.util.Set inProcess>;
interfaceinvoke v.<java.util.Set: boolean addAll(java.util.Collection)>(v);
label:
v = v.<org.apache.nifi.processors.standard.GetFile: java.util.concurrent.locks.Lock queueLock>;
interfaceinvoke v.<java.util.concurrent.locks.Lock: void unlock()>();
goto label;
label:
v := @caughtexception;
v = v.<org.apache.nifi.processors.standard.GetFile: java.util.concurrent.locks.Lock queueLock>;
interfaceinvoke v.<java.util.concurrent.locks.Lock: void unlock()>();
throw v;
label:
v = interfaceinvoke v.<java.util.List: java.util.ListIterator listIterator()>();
v = null;
label:
v = virtualinvoke v.<java.io.File: java.nio.file.Path toPath()>();
label:
v = interfaceinvoke v.<java.util.ListIterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.ListIterator: java.lang.Object next()>();
v = virtualinvoke v.<java.io.File: java.nio.file.Path toPath()>();
v = interfaceinvoke v.<java.nio.file.Path: java.nio.file.Path getParent()>();
v = interfaceinvoke v.<java.nio.file.Path: java.nio.file.Path relativize(java.nio.file.Path)>(v);
v = interfaceinvoke v.<java.nio.file.Path: java.lang.String toString()>();
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[])>("\u0001/");
v = virtualinvoke v.<java.lang.String: boolean isEmpty()>();
if v == 0 goto label;
v = "./";
label:
v = interfaceinvoke v.<java.nio.file.Path: java.nio.file.Path toAbsolutePath()>();
v = interfaceinvoke v.<java.nio.file.Path: java.nio.file.Path getParent()>();
v = interfaceinvoke v.<java.nio.file.Path: java.lang.String toString()>();
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[])>("\u0001/");
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile create()>();
v = staticinvoke <java.lang.System: long nanoTime()>();
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile importFrom(java.nio.file.Path,boolean,org.apache.nifi.flowfile.FlowFile)>(v, v, v);
v = staticinvoke <java.lang.System: long nanoTime()>();
v = v - v;
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit MILLISECONDS>;
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit NANOSECONDS>;
v = virtualinvoke v.<java.util.concurrent.TimeUnit: long convert(long,java.util.concurrent.TimeUnit)>(v, v);
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 = virtualinvoke v.<java.io.File: 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);
v = <org.apache.nifi.flowfile.attributes.CoreAttributes: org.apache.nifi.flowfile.attributes.CoreAttributes PATH>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.CoreAttributes: java.lang.String key()>();
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.flowfile.attributes.CoreAttributes: org.apache.nifi.flowfile.attributes.CoreAttributes ABSOLUTE_PATH>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.CoreAttributes: java.lang.String key()>();
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 = virtualinvoke v.<org.apache.nifi.processors.standard.GetFile: java.util.Map getAttributesFromFile(java.nio.file.Path)>(v);
v = interfaceinvoke v.<java.util.Map: int size()>();
if v <= 0 goto label;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile putAllAttributes(org.apache.nifi.flowfile.FlowFile,java.util.Map)>(v, v);
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()>();
interfaceinvoke v.<org.apache.nifi.provenance.ProvenanceReporter: void receive(org.apache.nifi.flowfile.FlowFile,java.lang.String,long)>(v, v, v);
v = <org.apache.nifi.processors.standard.GetFile: 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 = newarray (java.lang.Object)[1];
v[0] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void info(java.lang.String,java.lang.Object[])>("added {} to flow", v);
v = virtualinvoke v.<org.apache.nifi.processors.standard.GetFile: boolean isScheduled()>();
if v != 0 goto label;
v = v.<org.apache.nifi.processors.standard.GetFile: java.util.concurrent.locks.Lock queueLock>;
interfaceinvoke v.<java.util.concurrent.locks.Lock: void lock()>();
label:
v = interfaceinvoke v.<java.util.ListIterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.ListIterator: java.lang.Object next()>();
v = v.<org.apache.nifi.processors.standard.GetFile: java.util.concurrent.BlockingQueue fileQueue>;
interfaceinvoke v.<java.util.concurrent.BlockingQueue: boolean add(java.lang.Object)>(v);
v = v.<org.apache.nifi.processors.standard.GetFile: java.util.Set inProcess>;
interfaceinvoke v.<java.util.Set: boolean remove(java.lang.Object)>(v);
goto label;
label:
v = v.<org.apache.nifi.processors.standard.GetFile: java.util.concurrent.locks.Lock queueLock>;
interfaceinvoke v.<java.util.concurrent.locks.Lock: void unlock()>();
goto label;
label:
v := @caughtexception;
v = v.<org.apache.nifi.processors.standard.GetFile: java.util.concurrent.locks.Lock queueLock>;
interfaceinvoke v.<java.util.concurrent.locks.Lock: void unlock()>();
throw v;
label:
v = v.<org.apache.nifi.processors.standard.GetFile: java.util.concurrent.locks.Lock queueLock>;
interfaceinvoke v.<java.util.concurrent.locks.Lock: void lock()>();
label:
v = v.<org.apache.nifi.processors.standard.GetFile: java.util.Set inProcess>;
interfaceinvoke v.<java.util.Set: boolean removeAll(java.util.Collection)>(v);
v = v.<org.apache.nifi.processors.standard.GetFile: java.util.Set recentlyProcessed>;
interfaceinvoke v.<java.util.Set: boolean addAll(java.util.Collection)>(v);
label:
v = v.<org.apache.nifi.processors.standard.GetFile: java.util.concurrent.locks.Lock queueLock>;
interfaceinvoke v.<java.util.concurrent.locks.Lock: void unlock()>();
goto label;
label:
v := @caughtexception;
v = v.<org.apache.nifi.processors.standard.GetFile: java.util.concurrent.locks.Lock queueLock>;
interfaceinvoke v.<java.util.concurrent.locks.Lock: void unlock()>();
throw v;
label:
v := @caughtexception;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void error(java.lang.String,java.lang.Throwable)>("Failed to retrieve files due to {}", v);
if v == null goto label;
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void remove(org.apache.nifi.flowfile.FlowFile)>(v);
label:
v = v.<org.apache.nifi.processors.standard.GetFile: java.util.concurrent.locks.Lock queueLock>;
interfaceinvoke v.<java.util.concurrent.locks.Lock: void lock()>();
label:
v = v.<org.apache.nifi.processors.standard.GetFile: java.util.Set inProcess>;
interfaceinvoke v.<java.util.Set: boolean removeAll(java.util.Collection)>(v);
v = v.<org.apache.nifi.processors.standard.GetFile: java.util.Set recentlyProcessed>;
interfaceinvoke v.<java.util.Set: boolean addAll(java.util.Collection)>(v);
label:
v = v.<org.apache.nifi.processors.standard.GetFile: java.util.concurrent.locks.Lock queueLock>;
interfaceinvoke v.<java.util.concurrent.locks.Lock: void unlock()>();
goto label;
label:
v := @caughtexception;
v = v.<org.apache.nifi.processors.standard.GetFile: java.util.concurrent.locks.Lock queueLock>;
interfaceinvoke v.<java.util.concurrent.locks.Lock: void unlock()>();
throw v;
label:
v := @caughtexception;
v = v.<org.apache.nifi.processors.standard.GetFile: java.util.concurrent.locks.Lock queueLock>;
interfaceinvoke v.<java.util.concurrent.locks.Lock: void lock()>();
label:
v = v.<org.apache.nifi.processors.standard.GetFile: java.util.Set inProcess>;
interfaceinvoke v.<java.util.Set: boolean removeAll(java.util.Collection)>(v);
v = v.<org.apache.nifi.processors.standard.GetFile: java.util.Set recentlyProcessed>;
interfaceinvoke v.<java.util.Set: boolean addAll(java.util.Collection)>(v);
label:
v = v.<org.apache.nifi.processors.standard.GetFile: java.util.concurrent.locks.Lock queueLock>;
interfaceinvoke v.<java.util.concurrent.locks.Lock: void unlock()>();
goto label;
label:
v := @caughtexception;
v = v.<org.apache.nifi.processors.standard.GetFile: java.util.concurrent.locks.Lock queueLock>;
interfaceinvoke v.<java.util.concurrent.locks.Lock: void unlock()>();
throw v;
label:
throw v;
label:
return;
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.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.lang.Exception 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;
}
static void <clinit>()
{
org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.nifi.processor.Relationship v;
java.lang.String 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;
org.apache.nifi.expression.ExpressionLanguageScope v;
java.lang.String[] v, v, v;
org.apache.nifi.components.Validator v, v, v, v, v, v, v, v, v;
org.apache.nifi.processor.Relationship$Builder v, v, v;
java.util.concurrent.TimeUnit 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)>("Input Directory");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("The input directory from which to pull files");
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 createDirectoryExistsValidator(boolean,boolean)>(1, 0);
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.GetFile: org.apache.nifi.components.PropertyDescriptor DIRECTORY> = 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)>("Recurse Subdirectories");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("Indicates whether or not to pull files from subdirectories");
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.GetFile: org.apache.nifi.components.PropertyDescriptor RECURSE> = 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)>("Keep Source File");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("If true, the file is not deleted after it has been copied to the Content Repository; this causes the file to be picked up continually and is useful for testing purposes.  If not keeping original NiFi will need write permissions on the directory it is pulling from otherwise it will ignore the file.");
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.GetFile: org.apache.nifi.components.PropertyDescriptor KEEP_SOURCE_FILE> = 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 Filter");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("Only files whose names match the given regular expression will be picked 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)>("[^\\.].*");
v = <org.apache.nifi.processor.util.StandardValidators: org.apache.nifi.components.Validator REGULAR_EXPRESSION_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.GetFile: org.apache.nifi.components.PropertyDescriptor FILE_FILTER> = 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)>("Path Filter");
v = <org.apache.nifi.processors.standard.GetFile: org.apache.nifi.components.PropertyDescriptor RECURSE>;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor: 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[])>("When \u is true, then only subdirectories whose path matches the given regular expression will be scanned");
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 = <org.apache.nifi.processor.util.StandardValidators: org.apache.nifi.components.Validator REGULAR_EXPRESSION_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.GetFile: org.apache.nifi.components.PropertyDescriptor PATH_FILTER> = 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)>("Minimum File Age");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("The minimum age that a file must be in order to be pulled; any file younger than this amount of time (according to last modification date) will be ignored");
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 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 build()>();
<org.apache.nifi.processors.standard.GetFile: org.apache.nifi.components.PropertyDescriptor MIN_AGE> = 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 File Age");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("The maximum age that a file must be in order to be pulled; any file older than this amount of time (according to last modification date) will be ignored");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder required(boolean)>(0);
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit MILLISECONDS>;
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit NANOSECONDS>;
v = staticinvoke <org.apache.nifi.processor.util.StandardValidators: org.apache.nifi.components.Validator createTimePeriodValidator(long,java.util.concurrent.TimeUnit,long,java.util.concurrent.TimeUnit)>(100L, v, 9223372036854775807L, v);
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.GetFile: org.apache.nifi.components.PropertyDescriptor MAX_AGE> = 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)>("Minimum File Size");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("The minimum size that a file must be in order to be pulled");
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 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 defaultValue(java.lang.String)>("0 B");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.GetFile: org.apache.nifi.components.PropertyDescriptor MIN_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)>("Maximum File Size");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("The maximum size that a file can be in order to be pulled");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder required(boolean)>(0);
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 build()>();
<org.apache.nifi.processors.standard.GetFile: org.apache.nifi.components.PropertyDescriptor MAX_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)>("Ignore Hidden Files");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("Indicates whether or not hidden files should be ignored");
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$Builder required(boolean)>(1);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.GetFile: org.apache.nifi.components.PropertyDescriptor IGNORE_HIDDEN_FILES> = 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)>("Polling Interval");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("Indicates how long to wait before performing a directory listing");
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 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 build()>();
<org.apache.nifi.processors.standard.GetFile: org.apache.nifi.components.PropertyDescriptor POLLING_INTERVAL> = 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)>("Batch Size");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("The maximum number of files to pull in each iteration");
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 POSITIVE_INTEGER_VALIDATOR>;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder addValidator(org.apache.nifi.components.Validator)>(v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder defaultValue(java.lang.String)>("10");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.GetFile: org.apache.nifi.components.PropertyDescriptor BATCH_SIZE> = 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)>("All files are routed to success");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship build()>();
<org.apache.nifi.processors.standard.GetFile: org.apache.nifi.processor.Relationship REL_SUCCESS> = v;
return;
}
}