public class org.apache.nifi.processors.standard.TailFile extends org.apache.nifi.processor.AbstractProcessor { static final java.lang.String MAP_PREFIX; private static final byte[] NEW_LINE_BYTES; static final org.apache.nifi.components.AllowableValue LOCATION_LOCAL; static final org.apache.nifi.components.AllowableValue LOCATION_REMOTE; static final org.apache.nifi.components.AllowableValue MODE_SINGLEFILE; static final org.apache.nifi.components.AllowableValue MODE_MULTIFILE; static final org.apache.nifi.components.AllowableValue START_BEGINNING_OF_TIME; static final org.apache.nifi.components.AllowableValue START_CURRENT_FILE; static final org.apache.nifi.components.AllowableValue START_CURRENT_TIME; static final org.apache.nifi.components.PropertyDescriptor BASE_DIRECTORY; static final org.apache.nifi.components.PropertyDescriptor MODE; static final org.apache.nifi.components.PropertyDescriptor FILENAME; static final org.apache.nifi.components.PropertyDescriptor ROLLING_FILENAME_PATTERN; static final org.apache.nifi.components.PropertyDescriptor POST_ROLLOVER_TAIL_PERIOD; static final org.apache.nifi.components.PropertyDescriptor STATE_LOCATION; static final org.apache.nifi.components.PropertyDescriptor START_POSITION; static final org.apache.nifi.components.PropertyDescriptor RECURSIVE; static final org.apache.nifi.components.PropertyDescriptor LOOKUP_FREQUENCY; static final org.apache.nifi.components.PropertyDescriptor MAXIMUM_AGE; static final org.apache.nifi.components.PropertyDescriptor REREAD_ON_NUL; static final org.apache.nifi.components.PropertyDescriptor LINE_START_PATTERN; static final org.apache.nifi.components.PropertyDescriptor MAX_BUFFER_LENGTH; static final org.apache.nifi.components.PropertyDescriptor PRE_ALLOCATED_BUFFER_SIZE; static final org.apache.nifi.processor.Relationship REL_SUCCESS; private volatile java.util.Map states; private volatile java.util.concurrent.atomic.AtomicLong lastLookup; private volatile java.util.concurrent.atomic.AtomicBoolean isMultiChanging; private volatile boolean requireStateLookup; private volatile java.io.ByteArrayOutputStream linesBuffer; private volatile java.util.regex.Pattern lineStartPattern; private volatile long maxBufferBytes; private volatile int preAllocatedBufferSize; public void () { org.apache.nifi.processors.standard.TailFile v; java.util.concurrent.atomic.AtomicLong v; java.io.ByteArrayOutputStream v; java.util.concurrent.atomic.AtomicBoolean v; java.util.HashMap v; v := @this: org.apache.nifi.processors.standard.TailFile; specialinvoke v.()>(); v = new java.util.HashMap; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.atomic.AtomicLong; specialinvoke v.(long)>(0L); v. = v; v = new java.util.concurrent.atomic.AtomicBoolean; specialinvoke v.(boolean)>(0); v. = v; v. = 1; v = new java.io.ByteArrayOutputStream; specialinvoke v.()>(); v. = v; return; } protected java.util.List getSupportedPropertyDescriptors() { org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.util.ArrayList v; org.apache.nifi.processors.standard.TailFile v; v := @this: org.apache.nifi.processors.standard.TailFile; v = new java.util.ArrayList; specialinvoke v.()>(); v = ; interfaceinvoke v.(v); v = ; interfaceinvoke v.(v); v = ; interfaceinvoke v.(v); v = ; interfaceinvoke v.(v); v = ; interfaceinvoke v.(v); v = ; interfaceinvoke v.(v); v = ; interfaceinvoke v.(v); v = ; interfaceinvoke v.(v); v = ; interfaceinvoke v.(v); v = ; interfaceinvoke v.(v); v = ; interfaceinvoke v.(v); v = ; interfaceinvoke v.(v); v = ; interfaceinvoke v.(v); v = ; interfaceinvoke v.(v); return v; } public java.util.Set getRelationships() { org.apache.nifi.processors.standard.TailFile v; java.util.Set v; org.apache.nifi.processor.Relationship v; v := @this: org.apache.nifi.processors.standard.TailFile; v = ; v = staticinvoke (v); return v; } public void onPropertyModified(org.apache.nifi.components.PropertyDescriptor, java.lang.String, java.lang.String) { org.apache.nifi.processors.standard.TailFile v; java.util.HashMap v; org.apache.nifi.components.PropertyDescriptor v, v; java.lang.String v, v; boolean v, v; v := @this: org.apache.nifi.processors.standard.TailFile; v := @parameter: org.apache.nifi.components.PropertyDescriptor; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v = virtualinvoke v.(); if v == 0 goto label; v = ; v = virtualinvoke v.(v); if v == 0 goto label; v = new java.util.HashMap; specialinvoke v.()>(); v. = v; label: return; } protected java.util.Collection customValidate(org.apache.nifi.components.ValidationContext) { org.apache.nifi.components.ValidationContext v; org.apache.nifi.components.PropertyDescriptor v, v, v, v; java.util.ArrayList v; org.apache.nifi.components.PropertyValue v, v, v; java.lang.String v, v, v, v, v, v; org.apache.nifi.components.ValidationResult v, v; boolean v, v; org.apache.nifi.components.ValidationResult$Builder v, v, v, v, v, v, v, v; org.apache.nifi.processors.standard.TailFile v; java.util.Collection v; org.apache.nifi.components.AllowableValue v; java.io.File v; v := @this: org.apache.nifi.processors.standard.TailFile; v := @parameter: org.apache.nifi.components.ValidationContext; v = new java.util.ArrayList; v = specialinvoke v.(v); specialinvoke v.(java.util.Collection)>(v); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = ; v = virtualinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = interfaceinvoke v.(); if v != null goto label; v = new org.apache.nifi.components.ValidationResult$Builder; specialinvoke v.()>(); v = ; v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(0); v = virtualinvoke v.("Base directory property cannot be empty in Multifile mode."); v = virtualinvoke v.(); interfaceinvoke v.(v); goto label; label: v = new java.io.File; specialinvoke v.(java.lang.String)>(v); v = virtualinvoke v.(); if v != 0 goto label; v = new org.apache.nifi.components.ValidationResult$Builder; specialinvoke v.()>(); v = ; v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(0); v = dynamicinvoke "makeConcatWithConstants" (v) ("\u is not a directory."); v = virtualinvoke v.(v); v = virtualinvoke v.(); interfaceinvoke v.(v); label: return v; } public void onPrimaryNodeChange() { org.apache.nifi.processors.standard.TailFile v; v := @this: org.apache.nifi.processors.standard.TailFile; v. = 1; return; } private java.util.List lookup(org.apache.nifi.processor.ProcessContext) { java.util.Date v; org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v, v; org.apache.nifi.components.PropertyValue v, v, v, v, v, v, v, v, v, v; java.lang.Long v; boolean v, v; org.apache.nifi.components.AllowableValue v; java.util.List v; long v, v; java.util.ArrayList v; java.lang.Boolean v; java.lang.String v, v, v, v, v, v; org.apache.nifi.processors.standard.TailFile v; org.apache.nifi.processor.ProcessContext v; java.util.concurrent.TimeUnit v; java.util.concurrent.atomic.AtomicLong v; v := @this: org.apache.nifi.processors.standard.TailFile; v := @parameter: org.apache.nifi.processor.ProcessContext; v = v.; v = new java.util.Date; specialinvoke v.()>(); v = virtualinvoke v.(); virtualinvoke v.(v); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); if v != null goto label; v = 9223372036854775807L; goto label; label: v = ; v = interfaceinvoke v.(v); v = ; v = interfaceinvoke v.(v); v = virtualinvoke v.(); label: v = new java.util.ArrayList; specialinvoke v.()>(); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = ; v = virtualinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = virtualinvoke v.(); v = specialinvoke v.(v, v, v, v); interfaceinvoke v.(v); goto label; label: v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = interfaceinvoke v.(); interfaceinvoke v.(v); label: return v; } public void compileRegex(org.apache.nifi.processor.ProcessContext) { java.lang.Double v, v; long v; org.apache.nifi.components.PropertyDescriptor v, v, v; org.apache.nifi.components.PropertyValue v, v, v; int v; java.lang.String v; org.apache.nifi.processors.standard.TailFile v; org.apache.nifi.processor.ProcessContext v; java.util.regex.Pattern v; org.apache.nifi.processor.DataUnit v, v; v := @this: org.apache.nifi.processors.standard.TailFile; v := @parameter: org.apache.nifi.processor.ProcessContext; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); if v != null goto label; v = null; goto label; label: v = staticinvoke (v); label: v. = v; v = ; v = interfaceinvoke v.(v); v = ; v = interfaceinvoke v.(v); v = virtualinvoke v.(); v. = v; v = ; v = interfaceinvoke v.(v); v = ; v = interfaceinvoke v.(v); v = virtualinvoke v.(); v. = v; return; } public void recoverState(org.apache.nifi.processor.ProcessContext) throws java.io.IOException { org.apache.nifi.components.PropertyDescriptor v, v; org.apache.nifi.components.PropertyValue v, v; byte v; org.apache.nifi.components.state.Scope v; java.util.Map v, v, v, v; boolean v, v, v, v, v; java.util.function.Predicate v; java.util.Set v, v; org.apache.nifi.components.AllowableValue v; org.apache.nifi.components.state.StateMap v; java.util.List v; java.util.stream.Stream v; java.lang.Object[] v; java.util.concurrent.atomic.AtomicBoolean v; java.util.HashMap v; long v; org.apache.nifi.logging.ComponentLog v; int v; java.lang.String v, v, v, v, v; org.apache.nifi.processors.standard.TailFile v; java.util.Iterator v; org.apache.nifi.components.state.StateManager v; org.apache.nifi.processor.ProcessContext v; java.lang.Object v, v, v; v := @this: org.apache.nifi.processors.standard.TailFile; v := @parameter: org.apache.nifi.processor.ProcessContext; v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = ; v = virtualinvoke v.(); v = virtualinvoke v.(v); virtualinvoke v.(v); v = specialinvoke v.(v); v = specialinvoke v.(v); v = interfaceinvoke v.(); v = interfaceinvoke v.(v); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = v cmp -1L; if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); if v == 0 goto label; label: v = staticinvoke (); specialinvoke v.(v, v, 1, v); v = staticinvoke (); specialinvoke v.(v, v, v); return; label: v = interfaceinvoke v.(); v = interfaceinvoke v.("filename"); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = staticinvoke (); v = interfaceinvoke v.(v); if v != 0 goto label; v = new java.util.HashMap; v = interfaceinvoke v.(); specialinvoke v.(int)>(v); v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("file.0.\u0001"); v = interfaceinvoke v.(v); interfaceinvoke v.(v, v); goto label; label: v = interfaceinvoke v.("position"); interfaceinvoke v.("file.0.length", v); v = staticinvoke (v); v = virtualinvoke v.(); v = newarray (java.lang.Object)[1]; v[0] = v; interfaceinvoke v.("statesMap has been migrated. {}", v); label: specialinvoke v.(v, v, 0, v); specialinvoke v.(v, v, v); return; } private void initStates(java.util.List, java.util.Map, boolean, java.lang.String) { java.nio.ByteBuffer v; java.util.Map v, v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.processors.standard.TailFile$TailFileObject v, v; boolean v, v, v, v, v, v, v, v, v, v, v; java.util.Set v, v, v, v; java.util.List v; java.lang.String[] v; java.util.ArrayList v; org.apache.nifi.processors.standard.TailFile$TailFileState v; int v, v, v, v, v, v; java.lang.String v, v; org.apache.nifi.processors.standard.TailFile v; java.util.Iterator v, v, v, v; java.lang.Object v, v, v, v, v, v, v, v, v; v := @this: org.apache.nifi.processors.standard.TailFile; v := @parameter: java.util.List; v := @parameter: java.util.Map; v := @parameter: boolean; v := @parameter: java.lang.String; v = 0; if v == 0 goto label; v = v.; interfaceinvoke v.(); goto label; label: v = v.; v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); if v != 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.("filename"); if v == 0 goto label; v = interfaceinvoke v.(v); v = interfaceinvoke v.(v); if v == 0 goto label; v = virtualinvoke v.("\\."); v = v[1]; v = staticinvoke (v); v = v.; v = interfaceinvoke v.(v); v = new org.apache.nifi.processors.standard.TailFile$TailFileObject; v = v.; specialinvoke v.(int,java.util.Map,int)>(v, v, v); interfaceinvoke v.(v, v); goto label; label: v = new java.util.ArrayList; specialinvoke v.()>(); v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(v); if v != 0 goto label; interfaceinvoke v.(v); v = v.; v = interfaceinvoke v.(v); specialinvoke v.(v); goto label; label: v = v.; v = interfaceinvoke v.(); interfaceinvoke v.(v); v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v.; v = interfaceinvoke v.(v); v = virtualinvoke v.(); if v > v goto label; v = v.; v = interfaceinvoke v.(v); v = virtualinvoke v.(); v = v + 1; goto label; label: v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); if v != 0 goto label; v = v.; v = interfaceinvoke v.(v); if v != 0 goto label; label: v = new org.apache.nifi.processors.standard.TailFile$TailFileState; v = v.; v = staticinvoke (v); specialinvoke v.(java.lang.String,java.io.File,java.nio.channels.FileChannel,long,long,long,java.util.zip.Checksum,java.nio.ByteBuffer)>(v, null, null, 0L, 0L, 0L, null, v); v = v.; v = new org.apache.nifi.processors.standard.TailFile$TailFileObject; specialinvoke v.(int,org.apache.nifi.processors.standard.TailFile$TailFileState)>(v, v); interfaceinvoke v.(v, v); v = v + 1; goto label; label: return; } private void recoverState(org.apache.nifi.processor.ProcessContext, java.util.List, java.util.Map) throws java.io.IOException { org.apache.nifi.processors.standard.TailFile v; java.util.List v; java.util.Iterator v; java.util.Map v; org.apache.nifi.processor.ProcessContext v; java.lang.Object v; boolean v; v := @this: org.apache.nifi.processors.standard.TailFile; v := @parameter: org.apache.nifi.processor.ProcessContext; v := @parameter: java.util.List; v := @parameter: java.util.Map; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); specialinvoke v.(v, v, v); goto label; label: return; } private java.util.List getFilesToTail(java.lang.String, java.lang.String, boolean, long) { java.util.Date v; java.util.regex.Matcher v; byte v; boolean v, v, v, v, v, v; java.util.Collection v; java.util.regex.Pattern v; java.util.concurrent.atomic.AtomicBoolean v; long v, v, v, v; java.util.ArrayList v; int v, v; java.lang.String v, v, v, v, v, v, v, v, v, v; org.apache.nifi.processors.standard.TailFile v; java.util.Iterator v; java.io.File v; java.lang.Object v; v := @this: org.apache.nifi.processors.standard.TailFile; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v := @parameter: boolean; v := @parameter: long; v = new java.io.File; specialinvoke v.(java.lang.String)>(v); v = staticinvoke (v, null, v); v = new java.util.ArrayList; specialinvoke v.()>(); v = ; v = virtualinvoke v.(v); if v == 0 goto label; v = virtualinvoke v.(); v = v - 1; v = virtualinvoke v.(0, v); goto label; label: v = v; label: v = ; v = virtualinvoke v.("/"); if v == 0 goto label; v = ; v = dynamicinvoke "makeConcatWithConstants" (v, v, v) ("\u0001\u0001\u0001"); goto label; label: v = ; v = staticinvoke (v); v = dynamicinvoke "makeConcatWithConstants" (v, v, v) ("\u0001\u0001\u0001"); label: v = staticinvoke (v); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); if v == 0 goto label; v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = new java.util.Date; specialinvoke v.()>(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = v - v; v = v cmp v; if v >= 0 goto label; interfaceinvoke v.(v); goto label; label: interfaceinvoke v.(v); goto label; label: return v; } private void recoverState(org.apache.nifi.processor.ProcessContext, java.util.Map, java.lang.String) throws java.io.IOException { byte v, v; java.lang.Long v, v, v, v; java.util.Map v, v, v, v, v, v, v; java.nio.file.Path v; org.apache.nifi.stream.io.NullOutputStream v; java.lang.Throwable v, v; java.lang.Object[] v, v, v; long v, v, v, v, v, v, v, v, v; org.apache.nifi.processors.standard.TailFile$TailFileState v, v, v; java.nio.file.OpenOption[] v; java.lang.String v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.processors.standard.TailFile v; java.io.File v, v; java.util.zip.CRC32 v; java.util.zip.CheckedInputStream v; java.nio.ByteBuffer v; boolean v, v, v, v, v, v; java.nio.file.StandardOpenOption v; java.io.EOFException v; org.apache.nifi.logging.ComponentLog v, v, v, v, v, v; java.util.zip.Checksum v; int v, v; org.apache.nifi.processor.ProcessContext v; java.io.FileInputStream v; java.lang.Object v, v, v, v, v, v, v, v, v, v, v; java.nio.channels.FileChannel v; v := @this: org.apache.nifi.processors.standard.TailFile; v := @parameter: org.apache.nifi.processor.ProcessContext; v := @parameter: java.util.Map; v := @parameter: java.lang.String; v = v.; v = interfaceinvoke v.(v); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("file.\u."); v = dynamicinvoke "makeConcatWithConstants" (v) ("\u0001filename"); v = interfaceinvoke v.(v); if v != 0 goto label; specialinvoke v.(v); return; label: v = dynamicinvoke "makeConcatWithConstants" (v) ("\u0001position"); v = interfaceinvoke v.(v); if v != 0 goto label; specialinvoke v.(v); return; label: v = dynamicinvoke "makeConcatWithConstants" (v) ("\u0001timestamp"); v = interfaceinvoke v.(v); if v != 0 goto label; specialinvoke v.(v); return; label: v = dynamicinvoke "makeConcatWithConstants" (v) ("\u0001length"); v = interfaceinvoke v.(v); if v != 0 goto label; specialinvoke v.(v); return; label: v = dynamicinvoke "makeConcatWithConstants" (v) ("\u0001checksum"); v = interfaceinvoke v.(v); if v == null goto label; v = 1; goto label; label: v = 0; label: v = dynamicinvoke "makeConcatWithConstants" (v) ("\u0001filename"); v = interfaceinvoke v.(v); v = dynamicinvoke "makeConcatWithConstants" (v) ("\u0001position"); v = interfaceinvoke v.(v); v = staticinvoke (v); v = dynamicinvoke "makeConcatWithConstants" (v) ("\u0001timestamp"); v = interfaceinvoke v.(v); v = staticinvoke (v); v = dynamicinvoke "makeConcatWithConstants" (v) ("\u0001length"); v = interfaceinvoke v.(v); v = staticinvoke (v); v = null; v = null; if v == 0 goto label; v = virtualinvoke v.(v); if v == 0 goto label; v = v.; v = interfaceinvoke v.(v); v = staticinvoke (v); v = staticinvoke (v); virtualinvoke v.(v); v = new java.util.zip.CRC32; specialinvoke v.()>(); v = new java.io.File; specialinvoke v.(java.lang.String)>(v); v = virtualinvoke v.(); v = v cmp v; if v < 0 goto label; v = new java.io.FileInputStream; specialinvoke v.(java.io.File)>(v); label: v = new java.util.zip.CheckedInputStream; specialinvoke v.(java.io.InputStream,java.util.zip.Checksum)>(v, v); label: v = new org.apache.nifi.stream.io.NullOutputStream; specialinvoke v.()>(); v = v.; v = interfaceinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(); staticinvoke (v, v, v); label: goto label; label: v := @caughtexception; v = virtualinvoke v.(); interfaceinvoke v.("When recovering state, file being tailed has less data than was stored in the state. Assuming rollover. Will begin tailing current file from beginning."); label: v = virtualinvoke v.(); v = interfaceinvoke v.(); v = v.; v = interfaceinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(); v = v cmp v; if v != 0 goto label; v = virtualinvoke v.(); interfaceinvoke v.("When recovering state, checksum of tailed file matches the stored checksum. Will resume where left off."); v = v; v = virtualinvoke v.(); v = newarray (java.nio.file.OpenOption)[1]; v = ; v[0] = v; v = staticinvoke (v, v); v = virtualinvoke v.(); v = newarray (java.lang.Object)[2]; v[0] = v; v[1] = v; interfaceinvoke v.("Created FileChannel {} for {} in recoverState", v); virtualinvoke v.(v); goto label; label: v = virtualinvoke v.(); interfaceinvoke v.("When recovering state, checksum of tailed file does not match the stored checksum. Will begin tailing current file from beginning."); label: virtualinvoke v.(); goto label; label: v := @caughtexception; throw v; label: virtualinvoke v.(); goto label; label: v := @caughtexception; throw v; label: v = virtualinvoke v.(); v = newarray (java.lang.Object)[2]; v = virtualinvoke v.(); v = staticinvoke (v); v[0] = v; v = staticinvoke (v); v[1] = v; interfaceinvoke v.("When recovering state, existing file to tail is only {} bytes but position flag is {}; this indicates that the file has rotated. Will begin tailing current file from beginning.", v); label: v = v.; v = interfaceinvoke v.(v); v = new org.apache.nifi.processors.standard.TailFile$TailFileState; v = v.; v = staticinvoke (v); specialinvoke v.(java.lang.String,java.io.File,java.nio.channels.FileChannel,long,long,long,java.util.zip.Checksum,java.nio.ByteBuffer)>(v, v, v, v, v, v, v, v); virtualinvoke v.(v); goto label; label: specialinvoke v.(v); label: v = virtualinvoke v.(); v = newarray (java.lang.Object)[1]; v = v.; v = interfaceinvoke v.(v); v = virtualinvoke v.(); v[0] = v; interfaceinvoke v.("Recovered state {}", v); return; catch java.io.EOFException from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; } private void resetState(java.lang.String) { org.apache.nifi.processors.standard.TailFile v; java.nio.ByteBuffer v; org.apache.nifi.processors.standard.TailFile$TailFileState v; java.util.Map v, v; int v; java.lang.Object v, v; java.lang.String v; v := @this: org.apache.nifi.processors.standard.TailFile; v := @parameter: java.lang.String; v = v.; v = interfaceinvoke v.(v); virtualinvoke v.(null); v = v.; v = interfaceinvoke v.(v); v = new org.apache.nifi.processors.standard.TailFile$TailFileState; v = v.; v = staticinvoke (v); specialinvoke v.(java.lang.String,java.io.File,java.nio.channels.FileChannel,long,long,long,java.util.zip.Checksum,java.nio.ByteBuffer)>(v, null, null, 0L, 0L, 0L, null, v); virtualinvoke v.(v); return; } public void cleanup(org.apache.nifi.processor.ProcessContext) { java.io.ByteArrayOutputStream v, v; long v, v, v, v; java.nio.ByteBuffer v; java.util.zip.Checksum v; org.apache.nifi.processors.standard.TailFile$TailFileState v, v; java.util.Map v; int v; java.lang.String v; boolean v, v; org.apache.nifi.processors.standard.TailFile v; java.util.Iterator v; java.util.Collection v; org.apache.nifi.processor.ProcessContext v; java.io.File v; java.lang.Object v; v := @this: org.apache.nifi.processors.standard.TailFile; v := @parameter: org.apache.nifi.processor.ProcessContext; v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); specialinvoke v.(v); v = virtualinvoke v.(); v = new org.apache.nifi.processors.standard.TailFile$TailFileState; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = v - v; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); specialinvoke v.(java.lang.String,java.io.File,java.nio.channels.FileChannel,long,long,long,java.util.zip.Checksum,java.nio.ByteBuffer,boolean)>(v, v, null, v, v, v, v, v, v); virtualinvoke v.(v); specialinvoke v.(v, null, v); goto label; label: v = v.; virtualinvoke v.(); return; } private void cleanReader(org.apache.nifi.processors.standard.TailFile$TailFileObject) { org.apache.nifi.processors.standard.TailFile v; java.lang.Object[] v; java.io.IOException v; org.apache.nifi.logging.ComponentLog v, v; org.apache.nifi.processors.standard.TailFile$TailFileState v, v; org.apache.nifi.processors.standard.TailFile$TailFileObject v; java.nio.channels.FileChannel v; v := @this: org.apache.nifi.processors.standard.TailFile; v := @parameter: org.apache.nifi.processors.standard.TailFile$TailFileObject; v = virtualinvoke v.(); if v != null goto label; return; label: v = virtualinvoke v.(); v = virtualinvoke v.(); if v != null goto label; return; label: virtualinvoke v.(); v = virtualinvoke v.(); v = newarray (java.lang.Object)[1]; v[0] = v; interfaceinvoke v.("Closed FileChannel {}", v); label: goto label; label: v := @caughtexception; v = virtualinvoke v.(); interfaceinvoke v.("Failed to close file handle during cleanup"); label: return; 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.util.Date v; java.lang.Integer v; org.apache.nifi.components.PropertyDescriptor v, v, v; org.apache.nifi.components.PropertyValue v, v; byte v; java.lang.Long v; org.apache.nifi.components.state.Scope v, v; java.util.Map v, v, v, v; boolean v, v, v, v; java.util.Set v, v; org.apache.nifi.components.state.StateMap v, v; java.util.List v, v; java.util.regex.Pattern v; org.apache.nifi.processors.standard.TailFile$NulCharacterEncounteredException v; java.lang.Object[] v; java.io.ByteArrayOutputStream v; java.util.concurrent.atomic.AtomicBoolean v; java.util.HashMap v; long v, v, v, v; org.apache.nifi.logging.ComponentLog v, v, v, v, v; int v, v; java.lang.String v, v, v; org.apache.nifi.processors.standard.TailFile v; java.util.Iterator v; org.apache.nifi.processor.ProcessContext v; java.io.IOException v, v, v; org.apache.nifi.processor.ProcessSession v; java.util.concurrent.TimeUnit v; java.util.concurrent.atomic.AtomicLong v; java.lang.Object v; v := @this: org.apache.nifi.processors.standard.TailFile; v := @parameter: org.apache.nifi.processor.ProcessContext; v := @parameter: org.apache.nifi.processor.ProcessSession; v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = new java.util.Date; specialinvoke v.()>(); v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = v - v; v = ; v = interfaceinvoke v.(v); v = ; v = interfaceinvoke v.(v); v = virtualinvoke v.(); v = v cmp v; if v <= 0 goto label; label: v = specialinvoke v.(v); v = specialinvoke v.(v); v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); specialinvoke v.(v, v, 0, v); label: goto label; label: v := @caughtexception; v = virtualinvoke v.(); interfaceinvoke v.("Exception raised while attempting to recover state about where the tailing last left off", v); interfaceinvoke v.(); return; label: v = v.; if v == 0 goto label; label: virtualinvoke v.(v); label: goto label; label: v := @caughtexception; v = virtualinvoke v.(); interfaceinvoke v.("Exception raised while attempting to recover state about where the tailing last left off", v); interfaceinvoke v.(); return; label: v. = 0; label: v = v.; v = interfaceinvoke v.(); if v == 0 goto label; interfaceinvoke v.(); return; label: v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); label: specialinvoke v.(v, v, v); label: goto label; label: v := @caughtexception; v = virtualinvoke v.(); v = ; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("NUL character encountered in \u and \'\u0001\' is set to \'true\', yielding."); interfaceinvoke v.(v); interfaceinvoke v.(); return; label: v = v.; if v == null goto label; v = v.; v = virtualinvoke v.(); if v <= 0 goto label; virtualinvoke v.(v); label: v = specialinvoke v.(v); v = interfaceinvoke v.(v); v = new java.util.HashMap; v = interfaceinvoke v.(); specialinvoke v.(java.util.Map)>(v); v = specialinvoke v.(v); v = interfaceinvoke v.(); interfaceinvoke v.(v); v = virtualinvoke v.(); v = newarray (java.lang.Object)[1]; v = interfaceinvoke v.(); v = staticinvoke (v); v[0] = v; interfaceinvoke v.("Removed {} references to nonexistent files from session\'s state map", v); interfaceinvoke v.(v, v); label: goto label; label: v := @caughtexception; v = virtualinvoke v.(); interfaceinvoke v.("Exception raised while attempting to cleanup session\'s state map", v); interfaceinvoke v.(); return; label: return; catch java.io.IOException from label to label with label; catch java.io.IOException from label to label with label; catch org.apache.nifi.processors.standard.TailFile$NulCharacterEncounteredException from label to label with label; catch java.io.IOException from label to label with label; } private java.util.List collectKeysToBeRemoved(java.util.Map) { java.util.function.Function v; java.util.ArrayList v; java.util.Map v; java.lang.String v, v, v, v, v, v, v; java.util.stream.Collector v; boolean v; org.apache.nifi.processors.standard.TailFile v; java.util.Iterator v; java.util.function.Predicate v; java.util.Set v; java.util.stream.Stream v, v, v; java.lang.Object v, v; v := @this: org.apache.nifi.processors.standard.TailFile; v := @parameter: java.util.Map; v = new java.util.ArrayList; specialinvoke v.()>(); v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = staticinvoke (v); v = interfaceinvoke v.(v); v = staticinvoke (); v = interfaceinvoke v.(v); v = staticinvoke (); v = interfaceinvoke v.(v); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = staticinvoke (v, "filename"); v = dynamicinvoke "makeConcatWithConstants" (v) ("\u0001filename"); interfaceinvoke v.(v); v = dynamicinvoke "makeConcatWithConstants" (v) ("\u0001length"); interfaceinvoke v.(v); v = dynamicinvoke "makeConcatWithConstants" (v) ("\u0001position"); interfaceinvoke v.(v); v = dynamicinvoke "makeConcatWithConstants" (v) ("\u0001checksum"); interfaceinvoke v.(v); v = dynamicinvoke "makeConcatWithConstants" (v) ("\u0001timestamp"); interfaceinvoke v.(v); v = dynamicinvoke "makeConcatWithConstants" (v) ("\u0001tailingPostRollover"); interfaceinvoke v.(v); goto label; label: return v; } private void processTailFile(org.apache.nifi.processor.ProcessContext, org.apache.nifi.processor.ProcessSession, java.lang.String) { byte v, v, v, v, v, v, v; java.lang.Long v, v, v, v, v, v, v, v, v; java.util.Map v; java.nio.file.Path v; org.apache.nifi.components.AllowableValue v, v; java.lang.Object[] v, v, v, v, v, v, v, v, v; java.io.ByteArrayOutputStream v; long 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.processors.standard.TailFile$TailFileState v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.processor.Relationship v; java.io.IOException v, v, v, v; org.apache.nifi.processor.ProcessSession v; java.util.concurrent.atomic.AtomicLong v; java.util.zip.CRC32 v, v; org.apache.nifi.flowfile.attributes.CoreAttributes v, v; java.util.zip.CheckedInputStream v; org.apache.nifi.components.PropertyValue v, v, v; int v, v, v; java.lang.Boolean v; java.io.FileInputStream v; java.lang.Object v, v, v; java.nio.channels.FileChannel v, v; org.apache.nifi.components.PropertyDescriptor v, v, v; org.apache.nifi.stream.io.NullOutputStream v; java.lang.Throwable v, v; org.apache.nifi.provenance.ProvenanceReporter v; java.nio.file.OpenOption[] v; java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.processors.standard.TailFile v; org.apache.nifi.processors.standard.TailFile$1 v; java.io.File v, v, v; java.nio.ByteBuffer v, v, v, v; java.net.URI v; boolean v, v, v, v, v, v, v, v; org.apache.nifi.flowfile.FlowFile v, v; java.nio.file.StandardOpenOption v; java.util.HashMap v; org.apache.nifi.logging.ComponentLog v, v, v, v, v, v, v, v, v, v, v, v; java.util.concurrent.atomic.AtomicReference v; java.util.zip.Checksum v, v, v; org.apache.nifi.processor.ProcessContext v; java.util.concurrent.TimeUnit v, v; v := @this: org.apache.nifi.processors.standard.TailFile; v := @parameter: org.apache.nifi.processor.ProcessContext; v := @parameter: org.apache.nifi.processor.ProcessSession; v := @parameter: java.lang.String; v = v.; v = interfaceinvoke v.(v); v = virtualinvoke v.(); if v == 0 goto label; v = 0; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = ; v = virtualinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); specialinvoke v.(v, v, v, v, v, v); goto label; label: v = ; v = virtualinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; virtualinvoke v.(v); v = new org.apache.nifi.processors.standard.TailFile$TailFileState; v = virtualinvoke v.(); v = virtualinvoke v.(); specialinvoke v.(java.lang.String,java.io.File,java.nio.channels.FileChannel,long,long,long,java.util.zip.Checksum,java.nio.ByteBuffer)>(v, null, null, 0L, 0L, 0L, null, v); virtualinvoke v.(v); goto label; label: v = new java.io.File; specialinvoke v.(java.lang.String)>(v); label: v = virtualinvoke v.(); v = newarray (java.nio.file.OpenOption)[1]; v = ; v[0] = v; v = staticinvoke (v, v); v = virtualinvoke v.(); v = newarray (java.lang.Object)[2]; v[0] = v; v[1] = v; interfaceinvoke v.("Created FileChannel {} for {}", v); v = new java.util.zip.CRC32; specialinvoke v.()>(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = v + 1L; v = new java.io.FileInputStream; specialinvoke v.(java.io.File)>(v); label: v = new java.util.zip.CheckedInputStream; specialinvoke v.(java.io.InputStream,java.util.zip.Checksum)>(v, v); label: v = new org.apache.nifi.stream.io.NullOutputStream; specialinvoke v.()>(); staticinvoke (v, v, v); label: virtualinvoke v.(); goto label; label: v := @caughtexception; throw v; label: virtualinvoke v.(); goto label; label: v := @caughtexception; throw v; label: virtualinvoke v.(v); virtualinvoke v.(v); v = new org.apache.nifi.processors.standard.TailFile$TailFileState; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); specialinvoke v.(java.lang.String,java.io.File,java.nio.channels.FileChannel,long,long,long,java.util.zip.Checksum,java.nio.ByteBuffer)>(v, v, v, v, v, v, v, v); virtualinvoke v.(v); label: goto label; label: v := @caughtexception; v = virtualinvoke v.(); v = newarray (java.lang.Object)[3]; v[0] = v; v = virtualinvoke v.(); v[1] = v; v[2] = v; interfaceinvoke v.("Attempted to position Reader at current position in file {} but failed to do so due to {}", v); interfaceinvoke v.(); return; label: virtualinvoke v.(0); goto label; label: v = virtualinvoke v.(); if v != null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); if v != null goto label; v = null; goto label; label: v = virtualinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(); v = staticinvoke (v); label: v = v; label: v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = specialinvoke v.(v, v, v, v, v, v); if v == 0 goto label; v = ; v = interfaceinvoke v.(v); v = ; v = interfaceinvoke v.(v); v = virtualinvoke v.(); v = v cmp 0L; if v <= 0 goto label; v = 1; goto label; label: v = 0; label: if v == 0 goto label; v = virtualinvoke v.(); v = newarray (java.lang.Object)[1]; v[0] = v; interfaceinvoke v.("File {} was rolled over and the Rollover Tail Period is set, so will not consume from new file during this iteration.", v); return; label: virtualinvoke v.(null); label: v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); if v != null goto label; v = new java.util.zip.CRC32; specialinvoke v.()>(); v = v; label: v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); if v == null goto label; if v != null goto label; label: v = new java.io.File; specialinvoke v.(java.lang.String)>(v); v = v; v = specialinvoke v.(v, v); if v != null goto label; interfaceinvoke v.(); return; label: v = staticinvoke (); v = v; if v != 0 goto label; v = virtualinvoke v.(); v = v cmp v; if v <= 0 goto label; v = virtualinvoke v.(); v = newarray (java.lang.Object)[2]; v = staticinvoke (v); v[0] = v; v = staticinvoke (v); v[1] = v; interfaceinvoke v.("Rotated = true because TailFileState Length = {}, File Length = {}", v); v = 1; goto label; label: v = virtualinvoke v.(); v = virtualinvoke v.(); v = v cmp v; if v != 0 goto label; v = v cmp v; if v == 0 goto label; v = virtualinvoke v.(); v = newarray (java.lang.Object)[3]; v = staticinvoke (v); v[0] = v; v = staticinvoke (v); v[1] = v; v = staticinvoke (v); v[2] = v; interfaceinvoke v.("Rotated = true because readerSize={}, readerPosition={}, fileLength={}", v); v = 1; label: goto label; label: v := @caughtexception; v = virtualinvoke v.(); interfaceinvoke v.("Failed to determined the size or position of the File Channel when determining if the file has rolled over. Will assume that the file being tailed has not rolled over", v); label: if v == 0 goto label; label: virtualinvoke v.(); v = virtualinvoke v.(); v = newarray (java.lang.Object)[1]; v[0] = v; interfaceinvoke v.("Closed FileChannel {}", v); label: goto label; label: v := @caughtexception; v = virtualinvoke v.(); v = newarray (java.lang.Object)[2]; v[0] = v; v[1] = v; interfaceinvoke v.("Failed to close reader for {}", v); label: v = specialinvoke v.(v, 0L); v = 0L; interfaceinvoke v.(); label: v = virtualinvoke v.(); v = v cmp v; if v == 0 goto label; v = virtualinvoke v.(); if v != 0 goto label; label: v = virtualinvoke v.(); interfaceinvoke v.("No data to consume; created no FlowFiles"); v = new org.apache.nifi.processors.standard.TailFile$TailFileState; v = virtualinvoke v.(); specialinvoke v.(java.lang.String,java.io.File,java.nio.channels.FileChannel,long,long,long,java.util.zip.Checksum,java.nio.ByteBuffer)>(v, v, v, v, v, v, v, v); virtualinvoke v.(v); specialinvoke v.(v, v, v); interfaceinvoke v.(); return; label: v = interfaceinvoke v.(); v = new java.util.concurrent.atomic.AtomicLong; specialinvoke v.(long)>(v); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = virtualinvoke v.(); v = new java.util.concurrent.atomic.AtomicReference; specialinvoke v.()>(); v = new org.apache.nifi.processors.standard.TailFile$1; specialinvoke v.(org.apache.nifi.processors.standard.TailFile,java.util.concurrent.atomic.AtomicLong,java.nio.channels.FileChannel,org.apache.nifi.processors.standard.TailFile$TailFileState,java.util.zip.Checksum,boolean,java.util.concurrent.atomic.AtomicReference)>(v, v, v, v, v, v, v); v = interfaceinvoke v.(v, v); v = interfaceinvoke v.(); v = v cmp 0L; if v != 0 goto label; interfaceinvoke v.(v); v = virtualinvoke v.(); interfaceinvoke v.("No data to consume; removed created FlowFile"); goto label; label: v = virtualinvoke v.(); v = staticinvoke (v, "."); v = virtualinvoke v.(); v = virtualinvoke v.(); if v >= v goto label; v = virtualinvoke v.(); v = staticinvoke (v, "."); v = dynamicinvoke "makeConcatWithConstants" (v, v, v, v) ("\u.\u0001-\u.\u0001"); goto label; label: v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v, v) ("\u.\u0001-\u0001"); label: v = new java.util.HashMap; specialinvoke v.(int)>(3); v = ; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = ; v = virtualinvoke v.(); interfaceinvoke v.(v, "text/plain"); interfaceinvoke v.("tailfile.original.path", v); v = interfaceinvoke v.(v, v); v = interfaceinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("FlowFile contains bytes \u through \u of source file"); v = ; v = staticinvoke (); v = v - v; v = virtualinvoke v.(v); interfaceinvoke v.(v, v, v, v); v = ; interfaceinvoke v.(v, v); v = virtualinvoke v.(); v = newarray (java.lang.Object)[1]; v[0] = v; interfaceinvoke v.("Created {} and routed to success", v); label: v = interfaceinvoke v.(); v = v cmp 0L; if v > 0 goto label; v = v.; v = virtualinvoke v.(); if v <= 0 goto label; label: v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v, v); v = virtualinvoke v.(); label: v = new org.apache.nifi.processors.standard.TailFile$TailFileState; v = virtualinvoke v.(); specialinvoke v.(java.lang.String,java.io.File,java.nio.channels.FileChannel,long,long,long,java.util.zip.Checksum,java.nio.ByteBuffer)>(v, v, v, v, v, v, v, v); virtualinvoke v.(v); specialinvoke v.(v, v, v); v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); label: virtualinvoke v.(v); label: goto label; label: v := @caughtexception; v = virtualinvoke v.(); v = newarray (java.lang.Object)[3]; v[0] = v; v[1] = v; v[2] = v; interfaceinvoke v.("Couldn\'t reposition the reader for {} due to {}", v); label: v = virtualinvoke v.(); 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.io.IOException from label to label with label; catch java.io.IOException from label to label with label; catch java.io.IOException from label to label with label; catch java.io.IOException from label to label with label; } private long readLines(java.nio.channels.FileChannel, java.nio.ByteBuffer, java.io.OutputStream, java.util.zip.Checksum, java.lang.Boolean) throws java.io.IOException { java.io.OutputStream v; org.apache.nifi.processors.standard.TailFile v; java.util.zip.Checksum v; java.lang.Boolean v; long v; java.nio.channels.FileChannel v; java.nio.ByteBuffer v; v := @this: org.apache.nifi.processors.standard.TailFile; v := @parameter: java.nio.channels.FileChannel; v := @parameter: java.nio.ByteBuffer; v := @parameter: java.io.OutputStream; v := @parameter: java.util.zip.Checksum; v := @parameter: java.lang.Boolean; v = specialinvoke v.(v, v, v, v, v, 0); return v; } private long readLines(java.nio.channels.FileChannel, java.nio.ByteBuffer, java.io.OutputStream, java.util.zip.Checksum, java.lang.Boolean, boolean) throws java.io.IOException { java.lang.Integer v; java.nio.ByteBuffer v; byte v, v; java.lang.Long v, v, v; boolean v, v, v; org.apache.nifi.processors.standard.TailFile$NulCharacterEncounteredException v; java.lang.Throwable v; java.lang.Object[] v, v; java.io.ByteArrayOutputStream v; long v, v, v, v, v, v; org.apache.nifi.logging.ComponentLog v, v; java.util.zip.Checksum v; int v, v, v, v; java.lang.Boolean v; java.io.OutputStream v; org.apache.nifi.processors.standard.TailFile v; java.nio.channels.FileChannel v; v := @this: org.apache.nifi.processors.standard.TailFile; v := @parameter: java.nio.channels.FileChannel; v := @parameter: java.nio.ByteBuffer; v := @parameter: java.io.OutputStream; v := @parameter: java.util.zip.Checksum; v := @parameter: java.lang.Boolean; v := @parameter: boolean; v = virtualinvoke v.(); v = newarray (java.lang.Object)[1]; v = virtualinvoke v.(); v = staticinvoke (v); v[0] = v; interfaceinvoke v.("Reading lines starting at position {}", v); v = new java.io.ByteArrayOutputStream; specialinvoke v.()>(); label: v = virtualinvoke v.(); v = v; v = 0; v = 0; virtualinvoke v.(); label: v = virtualinvoke v.(v); v = (int) -1; if v == v goto label; virtualinvoke v.(); v = 0; label: if v >= v goto label; v = virtualinvoke v.(v); lookupswitch(v) { case 0: goto label; case 10: goto label; case 13: goto label; default: goto label; }; label: virtualinvoke v.(v); v = 0; specialinvoke v.(v, v, v, 0); v = v + v; v = v + 1L; v = v + 1; goto label; label: virtualinvoke v.(v); v = 1; goto label; label: v = virtualinvoke v.(); if v == 0 goto label; v = new org.apache.nifi.processors.standard.TailFile$NulCharacterEncounteredException; specialinvoke v.(long)>(v); throw v; label: if v == 0 goto label; v = 0; specialinvoke v.(v, v, v, 0); v = v + 1; virtualinvoke v.(v); v = v + v; goto label; label: virtualinvoke v.(v); label: v = v + 1; goto label; label: v = virtualinvoke v.(); goto label; label: if v == 0 goto label; specialinvoke v.(v, v, v, 1); v = virtualinvoke v.(); label: v = virtualinvoke v.(); v = v cmp v; if v >= 0 goto label; v = virtualinvoke v.(); v = newarray (java.lang.Object)[3]; v = staticinvoke (v); v[0] = v; v = staticinvoke (v); v[1] = v; v = staticinvoke (v); v[2] = v; interfaceinvoke v.("Read {} lines; repositioning reader from {} to {}", v); virtualinvoke v.(v); label: v = v; label: virtualinvoke v.(); return v; label: v := @caughtexception; throw v; catch java.lang.Throwable from label to label with label; } private void flushByteArrayOutputStream(java.io.ByteArrayOutputStream, java.io.OutputStream, java.util.zip.Checksum, boolean) throws java.io.IOException { byte[] v, v, v; java.util.regex.Matcher v; byte v; java.lang.Long v; boolean v, v, v; java.util.regex.Pattern v, v; java.lang.Object[] v; java.io.ByteArrayOutputStream v, v, v, v; java.lang.String[] v; long v, v; org.apache.nifi.logging.ComponentLog v, v; java.util.zip.Checksum v; java.nio.charset.Charset v, v; int v, v, v, v; java.lang.String v, v; java.io.OutputStream v; org.apache.nifi.processors.standard.TailFile v; v := @this: org.apache.nifi.processors.standard.TailFile; v := @parameter: java.io.ByteArrayOutputStream; v := @parameter: java.io.OutputStream; v := @parameter: java.util.zip.Checksum; v := @parameter: boolean; v = virtualinvoke v.(); virtualinvoke v.(); if v == 0 goto label; specialinvoke v.(v, v); label: v = v.; if v != null goto label; virtualinvoke v.(v); v = lengthof v; interfaceinvoke v.(v, 0, v); v = virtualinvoke v.(); v = interfaceinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); v = newarray (java.lang.Object)[1]; v = interfaceinvoke v.(); v = staticinvoke (v); v[0] = v; interfaceinvoke v.("Checksum updated to {}", v); label: return; label: v = new java.lang.String; v = ; specialinvoke v.(byte[],java.nio.charset.Charset)>(v, v); v = virtualinvoke v.("\n"); v = lengthof v; v = 0; label: if v >= v goto label; v = v[v]; v = v.; v = virtualinvoke v.(v); v = virtualinvoke v.(); if v != 0 goto label; v = v.; v = virtualinvoke v.(); v = v.; v = v cmp v; if v < 0 goto label; label: specialinvoke v.(v, v); label: v = v.; v = ; v = virtualinvoke v.(v); virtualinvoke v.(v); v = v.; v = ; virtualinvoke v.(v); v = v + 1; goto label; label: return; } private void flushLinesBuffer(java.io.OutputStream, java.util.zip.Checksum) throws java.io.IOException { java.io.OutputStream v; org.apache.nifi.processors.standard.TailFile v; byte[] v; java.lang.Object[] v; java.io.ByteArrayOutputStream v, v, v, v; long v; org.apache.nifi.logging.ComponentLog v, v; java.util.zip.Checksum v; java.lang.Long v; int v; boolean v; v := @this: org.apache.nifi.processors.standard.TailFile; v := @parameter: java.io.OutputStream; v := @parameter: java.util.zip.Checksum; v = v.; virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); interfaceinvoke v.(v, 0, v); v = virtualinvoke v.(); v = interfaceinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); v = newarray (java.lang.Object)[1]; v = interfaceinvoke v.(); v = staticinvoke (v); v[0] = v; interfaceinvoke v.("Checksum updated to {}", v); label: v = v.; virtualinvoke v.(); return; } private java.util.List getRolledOffFiles(org.apache.nifi.processor.ProcessContext, long, java.lang.String) throws java.io.IOException { java.lang.Throwable v; java.lang.Object[] v; long v, v, v; org.apache.nifi.logging.ComponentLog v; org.apache.nifi.components.PropertyDescriptor v; java.util.ArrayList v; org.apache.nifi.components.PropertyValue v; java.nio.file.DirectoryStream v; byte v; java.lang.Long v, v; java.lang.String v, v, v, v, v; java.nio.file.Path v; boolean v, v; org.apache.nifi.processors.standard.TailFile v; java.util.Iterator v; org.apache.nifi.processors.standard.TailFile$2 v; org.apache.nifi.processor.ProcessContext v; java.io.File v, v, v, v; java.util.List v; java.lang.Object v; v := @this: org.apache.nifi.processors.standard.TailFile; v := @parameter: org.apache.nifi.processor.ProcessContext; v := @parameter: long; v := @parameter: java.lang.String; v = new java.io.File; specialinvoke v.(java.lang.String)>(v); v = virtualinvoke v.(); if v != null goto label; v = new java.io.File; specialinvoke v.(java.lang.String)>("."); v = v; label: v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); if v != null goto label; v = staticinvoke (); return v; label: v = virtualinvoke v.(); v = staticinvoke (v, "."); v = virtualinvoke v.("${filename}", v); v = new java.util.ArrayList; specialinvoke v.()>(); v = virtualinvoke v.(); v = staticinvoke (v, v); label: v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = v cmp v; if v >= 0 goto label; v = virtualinvoke v.(); v = newarray (java.lang.Object)[3]; v[0] = v; v = staticinvoke (v); v[1] = v; v = staticinvoke (v); v[2] = v; interfaceinvoke v.("Found rolled off file {} but its last modified timestamp is before the cutoff (Last Mod = {}, Cutoff = {}) so will not consume it", v); goto label; label: v = virtualinvoke v.(v); if v != 0 goto label; interfaceinvoke v.(v); goto label; label: interfaceinvoke v.(); goto label; label: v := @caughtexception; throw v; label: v = new org.apache.nifi.processors.standard.TailFile$2; specialinvoke v.(org.apache.nifi.processors.standard.TailFile)>(v); interfaceinvoke v.(v); return v; catch java.lang.Throwable from label to label with label; } private org.apache.nifi.components.state.Scope getStateScope(org.apache.nifi.processor.ProcessContext) { org.apache.nifi.processors.standard.TailFile v; org.apache.nifi.processor.ProcessContext v; org.apache.nifi.components.AllowableValue v; org.apache.nifi.components.PropertyDescriptor v; org.apache.nifi.components.PropertyValue v; org.apache.nifi.components.state.Scope v, v; java.lang.String v, v; boolean v; v := @this: org.apache.nifi.processors.standard.TailFile; v := @parameter: org.apache.nifi.processor.ProcessContext; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = ; v = virtualinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; v = ; return v; label: v = ; return v; } private void persistState(org.apache.nifi.processors.standard.TailFile$TailFileObject, org.apache.nifi.processor.ProcessSession, org.apache.nifi.processor.ProcessContext) { org.apache.nifi.processors.standard.TailFile v; org.apache.nifi.processors.standard.TailFile$TailFileState v; java.util.Map v; int v; org.apache.nifi.processor.ProcessContext v; org.apache.nifi.processor.ProcessSession v; org.apache.nifi.processors.standard.TailFile$TailFileObject v; v := @this: org.apache.nifi.processors.standard.TailFile; v := @parameter: org.apache.nifi.processors.standard.TailFile$TailFileObject; v := @parameter: org.apache.nifi.processor.ProcessSession; v := @parameter: org.apache.nifi.processor.ProcessContext; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v); specialinvoke v.(v, v, v); return; } private void persistState(java.util.Map, org.apache.nifi.processor.ProcessSession, org.apache.nifi.processor.ProcessContext) { java.lang.Object[] v; java.util.HashMap v; org.apache.nifi.logging.ComponentLog v, v; org.apache.nifi.components.state.Scope v; java.util.Map v, v; java.lang.String v, v, v, v, v, v; boolean v, v, v, v, v; org.apache.nifi.processors.standard.TailFile v; java.util.Iterator v; org.apache.nifi.components.state.StateManager v, v; org.apache.nifi.processor.ProcessContext v; java.util.Set v; java.io.IOException v; org.apache.nifi.processor.ProcessSession v; org.apache.nifi.components.state.StateMap v, v; java.lang.Object v; v := @this: org.apache.nifi.processors.standard.TailFile; v := @parameter: java.util.Map; v := @parameter: org.apache.nifi.processor.ProcessSession; v := @parameter: org.apache.nifi.processor.ProcessContext; label: v = specialinvoke v.(v); if v != null goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(v); goto label; label: v = interfaceinvoke v.(v); label: v = v; v = new java.util.HashMap; specialinvoke v.()>(); v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = "checksum"; v = virtualinvoke v.(v); if v != 0 goto label; v = "filename"; v = virtualinvoke v.(v); if v != 0 goto label; v = "position"; v = virtualinvoke v.(v); if v != 0 goto label; v = "timestamp"; v = virtualinvoke v.(v); if v == 0 goto label; label: v = virtualinvoke v.(); v = newarray (java.lang.Object)[2]; v[0] = v; v = interfaceinvoke v.(v); v[1] = v; interfaceinvoke v.("Removed state {}={} stored by older version of NiFi.", v); goto label; label: v = interfaceinvoke v.(v); interfaceinvoke v.(v, v); goto label; label: interfaceinvoke v.(v); if v != null goto label; v = interfaceinvoke v.(); interfaceinvoke v.(v, v); goto label; label: interfaceinvoke v.(v, v); label: goto label; label: v := @caughtexception; v = virtualinvoke v.(); interfaceinvoke v.("Failed to store state; some data may be duplicated on restart of NiFi", v); label: return; catch java.io.IOException from label to label with label; } private java.nio.channels.FileChannel createReader(java.io.File, long) { java.lang.Object[] v, v, v, v; long v; org.apache.nifi.logging.ComponentLog v, v, v, v; java.nio.file.OpenOption[] v; java.nio.file.Path v; org.apache.nifi.processors.standard.TailFile v; java.nio.file.StandardOpenOption v; java.io.IOException v, v, v; java.io.File v; java.nio.channels.FileChannel v; v := @this: org.apache.nifi.processors.standard.TailFile; v := @parameter: java.io.File; v := @parameter: long; label: v = virtualinvoke v.(); v = newarray (java.nio.file.OpenOption)[1]; v = ; v[0] = v; v = staticinvoke (v, v); label: goto label; label: v := @caughtexception; v = virtualinvoke v.(); v = newarray (java.lang.Object)[2]; v[0] = v; v[1] = v; interfaceinvoke v.("Unable to open file {}; will attempt to access file again after the configured Yield Duration has elapsed", v); return null; label: v = virtualinvoke v.(); v = newarray (java.lang.Object)[2]; v[0] = v; v[1] = v; interfaceinvoke v.("Created FileChannel {} for {}", v); label: virtualinvoke v.(v); label: goto label; label: v := @caughtexception; v = virtualinvoke v.(); v = newarray (java.lang.Object)[2]; v[0] = v; v[1] = v; interfaceinvoke v.("Failed to read from {}", v); label: virtualinvoke v.(); v = virtualinvoke v.(); v = newarray (java.lang.Object)[1]; v[0] = v; interfaceinvoke v.("Closed FileChannel {}", v); label: goto label; label: v := @caughtexception; label: return null; label: return v; catch java.io.IOException from label to label with label; catch java.io.IOException from label to label with label; catch java.io.IOException from label to label with label; } java.util.Map getState() { org.apache.nifi.processors.standard.TailFile v; java.util.Map v; v := @this: org.apache.nifi.processors.standard.TailFile; v = v.; return v; } private boolean recoverRolledFiles(org.apache.nifi.processor.ProcessContext, org.apache.nifi.processor.ProcessSession, java.lang.String, java.lang.Long, long, long) { org.apache.nifi.processors.standard.TailFile v; org.apache.nifi.processor.ProcessContext v; java.io.IOException v; long v, v; org.apache.nifi.processor.ProcessSession v; org.apache.nifi.logging.ComponentLog v; java.util.List v; java.lang.Long v; java.lang.String v; boolean v; v := @this: org.apache.nifi.processors.standard.TailFile; v := @parameter: org.apache.nifi.processor.ProcessContext; v := @parameter: org.apache.nifi.processor.ProcessSession; v := @parameter: java.lang.String; v := @parameter: java.lang.Long; v := @parameter: long; v := @parameter: long; label: v = specialinvoke v.(v, v, v); v = specialinvoke v.(v, v, v, v, v, v); label: return v; label: v := @caughtexception; v = virtualinvoke v.(); interfaceinvoke v.("Failed to recover files that have rolled over", v); return 0; catch java.io.IOException from label to label with label; } private boolean recoverRolledFiles(org.apache.nifi.processor.ProcessContext, org.apache.nifi.processor.ProcessSession, java.lang.String, java.util.List, java.lang.Long, long) { java.lang.Integer v; org.apache.nifi.components.PropertyDescriptor v; byte v, v, v, v, v; java.lang.Long v, v, v, v, v, v, v; java.util.Map v; java.lang.Object[] v, v, v, v; long v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.processors.standard.TailFile$TailFileState v, v; java.lang.String v; org.apache.nifi.processors.standard.TailFile v; java.io.IOException v; org.apache.nifi.processor.ProcessSession v; org.apache.nifi.components.PropertyValue v; boolean v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.util.List v, v; org.apache.nifi.logging.ComponentLog v, v, v, v, v; java.util.function.Function v; int v; java.util.Iterator v; org.apache.nifi.processor.ProcessContext v; java.util.concurrent.TimeUnit v; java.lang.Object v, v, v, v, v; java.util.Comparator v, v; v := @this: org.apache.nifi.processors.standard.TailFile; v := @parameter: org.apache.nifi.processor.ProcessContext; v := @parameter: org.apache.nifi.processor.ProcessSession; v := @parameter: java.lang.String; v := @parameter: java.util.List; v := @parameter: java.lang.Long; v := @parameter: long; label: v = virtualinvoke v.(); v = newarray (java.lang.Object)[1]; v = interfaceinvoke v.(); v = staticinvoke (v); v[0] = v; interfaceinvoke v.("Recovering Rolled Off Files; total number of files rolled off = {}", v); v = v.; v = interfaceinvoke v.(v); v = ; v = interfaceinvoke v.(v); v = ; v = interfaceinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = v cmp 0L; if v <= 0 goto label; v = 1; goto label; label: v = 0; label: v = v; v = interfaceinvoke v.(); if v != 0 goto label; v = 1; goto label; label: v = 0; label: v = v; if v == 0 goto label; v = interfaceinvoke v.(0); v = virtualinvoke v.(); v = virtualinvoke v.(); v = v - v; v = virtualinvoke v.(); v = v cmp v; if v < 0 goto label; v = 1; goto label; label: v = 0; label: v = v; v = v cmp 0L; if v == 0 goto label; v = v cmp v; if v >= 0 goto label; label: v = 1; goto label; label: v = 0; label: if v == 0 goto label; if v == 0 goto label; if v == null goto label; v = 1; goto label; label: v = 0; label: v = v; goto label; label: v = 0; label: if v == 0 goto label; v = interfaceinvoke v.(0); if v == 0 goto label; v = specialinvoke v.(v, v, v, v, v, v, v, 0, 1); goto label; label: v = specialinvoke v.(v, v, v, v, v, v, v, 1, 0); label: if v == 0 goto label; interfaceinvoke v.(0); goto label; label: if v == 0 goto label; if v == 0 goto label; v = specialinvoke v.(v, 0L, v); v = staticinvoke (); v = staticinvoke (v); v = interfaceinvoke v.(); interfaceinvoke v.(v); v = interfaceinvoke v.(0); v = virtualinvoke v.(); v = virtualinvoke v.(); v = v - v; v = v cmp v; if v >= 0 goto label; v = virtualinvoke v.(); v = newarray (java.lang.Object)[4]; v[0] = v; v = virtualinvoke v.(); v = staticinvoke (v); v[1] = v; v = virtualinvoke v.(); v = staticinvoke (v); v[2] = v; v = staticinvoke (v); v[3] = v; interfaceinvoke v.("Rolled over file {} (size={}, lastModified={}) was modified {} millis ago, which isn\'t long enough to consume file fully without taking line endings into account. Will do nothing will file for now.", v); label: return 1; label: v = specialinvoke v.(v, v, v, v, v, v, v, 1, 0); if v == 0 goto label; v = virtualinvoke v.(); v = newarray (java.lang.Object)[1]; v[0] = v; interfaceinvoke v.("Consumed the final data from {}", v); interfaceinvoke v.(v); goto label; label: v = virtualinvoke v.(); v = newarray (java.lang.Object)[3]; v[0] = v; v = virtualinvoke v.(); v = staticinvoke (v); v[1] = v; v = virtualinvoke v.(); v = staticinvoke (v); v[2] = v; interfaceinvoke v.("No more data to consume from {} (size={}, lastModified={})", v); label: v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = specialinvoke v.(v, v, v, v); virtualinvoke v.(v); goto label; label: return v; label: v := @caughtexception; v = virtualinvoke v.(); interfaceinvoke v.("Failed to recover files that have rolled over", v); return 0; catch java.io.IOException from label to label with label; catch java.io.IOException from label to label with label; } private boolean tailRolledFile(org.apache.nifi.processor.ProcessContext, org.apache.nifi.processor.ProcessSession, java.lang.String, java.lang.Long, long, org.apache.nifi.processors.standard.TailFile$TailFileObject, java.io.File, boolean, boolean) throws java.io.IOException { org.apache.nifi.processor.io.OutputStreamCallback v; org.apache.nifi.components.PropertyDescriptor v, v, v; byte v, v, v; java.lang.Long v, v, v, v, v, v; org.apache.nifi.processors.standard.TailFile$TailFileObject v; org.apache.nifi.stream.io.NullOutputStream v; java.lang.Throwable v, v; java.lang.Object[] v, v, v, v, v; long v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.processors.standard.TailFile$TailFileState v, v, v, v; org.apache.nifi.provenance.ProvenanceReporter v; org.apache.nifi.processor.Relationship v; java.lang.String v, v, v, v, v, v, v, v; org.apache.nifi.processors.standard.TailFile v; org.apache.nifi.processor.ProcessSession v; java.io.File v, v; java.util.zip.CRC32 v, v; org.apache.nifi.flowfile.attributes.CoreAttributes v, v; java.util.zip.CheckedInputStream v; java.nio.ByteBuffer v, v, v, v; org.apache.nifi.components.PropertyValue v, v; java.net.URI v; boolean v, v; org.apache.nifi.flowfile.FlowFile v, v; java.util.HashMap v; org.apache.nifi.logging.ComponentLog v, v, v, v, v; java.util.concurrent.atomic.AtomicReference v; java.util.zip.Checksum v, v, v, v; int v; java.lang.Boolean v; org.apache.nifi.processor.ProcessContext v; java.io.FileInputStream v; java.util.concurrent.TimeUnit v, v; java.lang.Object v; java.nio.channels.FileChannel v; v := @this: org.apache.nifi.processors.standard.TailFile; v := @parameter: org.apache.nifi.processor.ProcessContext; v := @parameter: org.apache.nifi.processor.ProcessSession; v := @parameter: java.lang.String; v := @parameter: java.lang.Long; v := @parameter: long; v := @parameter: org.apache.nifi.processors.standard.TailFile$TailFileObject; v := @parameter: java.io.File; v := @parameter: boolean; v := @parameter: boolean; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = staticinvoke (); v = new java.io.FileInputStream; specialinvoke v.(java.io.File)>(v); label: v = new java.util.zip.CheckedInputStream; v = new java.util.zip.CRC32; specialinvoke v.()>(); specialinvoke v.(java.io.InputStream,java.util.zip.Checksum)>(v, v); label: v = new org.apache.nifi.stream.io.NullOutputStream; specialinvoke v.()>(); staticinvoke (v, v, v); v = virtualinvoke v.(); v = interfaceinvoke v.(); v = virtualinvoke v.(); v = v cmp v; if v == 0 goto label; v = virtualinvoke v.(); v = newarray (java.lang.Object)[3]; v[0] = v; v = staticinvoke (v); v[1] = v; v[2] = v; interfaceinvoke v.("Checksum for {} did not match expected checksum. Checksum for file was {} but expected {}. Will consume entire file", v); label: virtualinvoke v.(); label: virtualinvoke v.(); return 0; label: v = virtualinvoke v.(); v = newarray (java.lang.Object)[2]; v[0] = v; v = staticinvoke (v); v[1] = v; interfaceinvoke v.("Checksum for {} matched expected checksum. Will skip first {} bytes", v); v = interfaceinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); if v != null goto label; v = new java.util.zip.CRC32; v = v; specialinvoke v.()>(); goto label; label: v = virtualinvoke v.(); label: v = v; v = virtualinvoke v.(); if v != null goto label; v = v.; v = staticinvoke (v); goto label; label: v = virtualinvoke v.(); label: v = v; v = virtualinvoke v.(); v = virtualinvoke v.(); v = new java.util.concurrent.atomic.AtomicReference; specialinvoke v.()>(); v = staticinvoke (v, v, v, v, v, v, v, v, v); v = interfaceinvoke v.(v, v); v = interfaceinvoke v.(); v = v cmp 0L; if v != 0 goto label; interfaceinvoke v.(v); goto label; label: v = new java.util.HashMap; specialinvoke v.(int)>(3); v = ; v = virtualinvoke v.(); v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = ; v = virtualinvoke v.(); interfaceinvoke v.(v, "text/plain"); interfaceinvoke v.("tailfile.original.path", v); v = interfaceinvoke v.(v, v); v = interfaceinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("FlowFile contains bytes 0 through \u of source file"); v = ; v = staticinvoke (); v = v - v; v = virtualinvoke v.(v); interfaceinvoke v.(v, v, v, v); v = ; interfaceinvoke v.(v, v); v = virtualinvoke v.(); v = newarray (java.lang.Object)[2]; v[0] = v; v[1] = v; interfaceinvoke v.("Created {} from rolled over file {} and routed to success", v); label: v = ; v = interfaceinvoke v.(v); v = ; v = interfaceinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(); v = v - v; if v == 0 goto label; v = v cmp 0L; if v <= 0 goto label; v = virtualinvoke v.(); v = newarray (java.lang.Object)[4]; v[0] = v; v = staticinvoke (v); v[1] = v; v = ; v = virtualinvoke v.(); v[2] = v; v = staticinvoke (v); v[3] = v; interfaceinvoke v.("File {} has been rolled over, but it was updated {} millis ago, which is less than the configured {} ({} ms), so will continue tailing", v); v = virtualinvoke v.(); v = interfaceinvoke v.(); v = v + v; v = interfaceinvoke v.(); v = v + v; v = new org.apache.nifi.processors.standard.TailFile$TailFileState; v = virtualinvoke v.(); v = virtualinvoke v.(); specialinvoke v.(java.lang.String,java.io.File,java.nio.channels.FileChannel,long,long,long,java.util.zip.Checksum,java.nio.ByteBuffer,boolean)>(v, v, v, v, v, v, v, v, v); virtualinvoke v.(v); goto label; label: v = virtualinvoke v.(); if v == null goto label; throw v; label: v = virtualinvoke v.(); v = newarray (java.lang.Object)[1]; v[0] = v; interfaceinvoke v.("Completed tailing of file {}; will cleanup state", v); virtualinvoke v.(v); v = new org.apache.nifi.processors.standard.TailFile$TailFileState; v = virtualinvoke v.(); v = v + 1L; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); specialinvoke v.(java.lang.String,java.io.File,java.nio.channels.FileChannel,long,long,long,java.util.zip.Checksum,java.nio.ByteBuffer,boolean)>(v, null, null, 0L, v, v, null, v, v); virtualinvoke v.(v); label: specialinvoke v.(v, v, v); label: virtualinvoke v.(); label: virtualinvoke v.(); return 1; label: v := @caughtexception; throw v; label: v := @caughtexception; throw v; 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; } private org.apache.nifi.processors.standard.TailFile$TailFileState consumeFileFully(java.io.File, org.apache.nifi.processor.ProcessContext, org.apache.nifi.processor.ProcessSession, org.apache.nifi.processors.standard.TailFile$TailFileObject) throws java.io.IOException { org.apache.nifi.processor.io.OutputStreamCallback v; java.nio.ByteBuffer v; org.apache.nifi.components.PropertyDescriptor v; org.apache.nifi.components.PropertyValue v, v; byte v; java.net.URI v; org.apache.nifi.processors.standard.TailFile$TailFileObject v; org.apache.nifi.flowfile.FlowFile v, v, v; java.lang.Throwable v; java.lang.Object[] v; java.util.HashMap v; long v, v, v, v; org.apache.nifi.logging.ComponentLog v; org.apache.nifi.processors.standard.TailFile$TailFileState v, v, v, v; org.apache.nifi.provenance.ProvenanceReporter v; org.apache.nifi.processor.Relationship v; java.lang.String v, v, v, v, v, v; org.apache.nifi.processors.standard.TailFile v; org.apache.nifi.processor.ProcessContext v; org.apache.nifi.processor.ProcessSession v; java.io.FileInputStream v; java.io.File v; org.apache.nifi.flowfile.attributes.CoreAttributes v, v; v := @this: org.apache.nifi.processors.standard.TailFile; v := @parameter: java.io.File; v := @parameter: org.apache.nifi.processor.ProcessContext; v := @parameter: org.apache.nifi.processor.ProcessSession; v := @parameter: org.apache.nifi.processors.standard.TailFile$TailFileObject; v = interfaceinvoke v.(); v = new java.io.FileInputStream; specialinvoke v.(java.io.File)>(v); label: v = staticinvoke (v, v); v = interfaceinvoke v.(v, v); label: virtualinvoke v.(); goto label; label: v := @caughtexception; throw v; label: v = interfaceinvoke v.(); v = v cmp 0L; if v != 0 goto label; interfaceinvoke v.(v); goto label; label: v = new java.util.HashMap; specialinvoke v.(int)>(3); v = ; v = virtualinvoke v.(); v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = ; v = virtualinvoke v.(); interfaceinvoke v.(v, "text/plain"); v = virtualinvoke v.(); v = virtualinvoke v.(); interfaceinvoke v.("tailfile.original.path", v); v = interfaceinvoke v.(v, v); v = interfaceinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = ; interfaceinvoke v.(v, v); v = virtualinvoke v.(); v = newarray (java.lang.Object)[2]; v[0] = v; v[1] = v; interfaceinvoke v.("Created {} from {} and routed to success", v); virtualinvoke v.(v); v = new org.apache.nifi.processors.standard.TailFile$TailFileState; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = virtualinvoke v.(); v = v + 1L; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); specialinvoke v.(java.lang.String,java.io.File,java.nio.channels.FileChannel,long,long,long,java.util.zip.Checksum,java.nio.ByteBuffer)>(v, null, null, 0L, v, v, null, v); virtualinvoke v.(v); specialinvoke v.(v, v, v); label: v = virtualinvoke v.(); return v; catch java.lang.Throwable from label to label with label; } public long getCurrentTimeMs() { org.apache.nifi.processors.standard.TailFile v; long v; v := @this: org.apache.nifi.processors.standard.TailFile; v = staticinvoke (); return v; } static void () { byte[] v; org.apache.nifi.components.AllowableValue v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.processor.Relationship v; org.apache.nifi.expression.ExpressionLanguageScope v, v, v, v, v, v, v, v; java.nio.charset.Charset v; org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.lang.String v, v, v, v; org.apache.nifi.components.PropertyDescriptor$Builder v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.components.AllowableValue[] v, v, v, v, v; java.lang.String[] 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; v = "\n"; v = ; v = virtualinvoke v.(v); = v; v = new org.apache.nifi.components.AllowableValue; specialinvoke v.(java.lang.String,java.lang.String,java.lang.String)>("Local", "Local", "State is stored locally. Each node in a cluster will tail a different file."); = v; v = new org.apache.nifi.components.AllowableValue; specialinvoke v.(java.lang.String,java.lang.String,java.lang.String)>("Remote", "Remote", "State is located on a remote resource. This Processor will store state across the cluster so that it can be run on Primary Node Only and a new Primary Node can pick up where the last one left off."); = v; v = new org.apache.nifi.components.AllowableValue; specialinvoke v.(java.lang.String,java.lang.String,java.lang.String)>("Single file", "Single file", "In this mode, only the one file indicated in the \'Files to tail\' property will be watched by the processor. In this mode, the file may not exist when starting the processor."); = v; v = new org.apache.nifi.components.AllowableValue; specialinvoke v.(java.lang.String,java.lang.String,java.lang.String)>("Multiple files", "Multiple files", "In this mode, the \'Files to tail\' property accepts a regular expression and the processor will look for files in \'Base directory\' to list the files to tail by the processor."); = v; v = new org.apache.nifi.components.AllowableValue; specialinvoke v.(java.lang.String,java.lang.String,java.lang.String)>("Beginning of Time", "Beginning of Time", "Start with the oldest data that matches the Rolling Filename Pattern and then begin reading from the File to Tail"); = v; v = new org.apache.nifi.components.AllowableValue; specialinvoke v.(java.lang.String,java.lang.String,java.lang.String)>("Beginning of File", "Beginning of File", "Start with the beginning of the File to Tail. Do not ingest any data that has already been rolled over"); = v; v = new org.apache.nifi.components.AllowableValue; specialinvoke v.(java.lang.String,java.lang.String,java.lang.String)>("Current Time", "Current Time", "Start with the data at the end of the File to Tail. Do not ingest any data thas has already been rolled over or any data in the File to Tail that has already been written."); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("tail-base-directory"); v = virtualinvoke v.("Base directory"); v = virtualinvoke v.("Base directory used to look for files to tail. This property is required when using Multifile mode."); v = ; v = virtualinvoke v.(v); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(0); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("tail-mode"); v = virtualinvoke v.("Tailing mode"); v = virtualinvoke v.("Mode to use: single file will tail only one file, multiple file will look for a list of file. In Multiple mode the Base directory is required."); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(1); v = newarray (org.apache.nifi.components.AllowableValue)[2]; v = ; v[0] = v; v = ; v[1] = v; v = virtualinvoke v.(v); v = ; v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("File(s) to Tail"); v = virtualinvoke v.("File to Tail"); v = virtualinvoke v.("Path of the file to tail in case of single file mode. If using multifile mode, regular expression to find files to tail in the base directory. In case recursivity is set to true, the regular expression will be used to match the path starting from the base directory (see additional details for examples)."); v = ; v = virtualinvoke v.(v); v = staticinvoke (0, 2147483647, 1); v = virtualinvoke v.(v); v = virtualinvoke v.(1); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("Rolling Filename Pattern"); v = virtualinvoke v.("If the file to tail \"rolls over\" as would be the case with log files, this filename pattern will be used to identify files that have rolled over so that if NiFi is restarted, and the file has rolled over, it will be able to pick up where it left off. This pattern supports wildcard characters * and ?, it also supports the notation ${filename} to specify a pattern based on the name of the file (without extension), and will assume that the files that have rolled over live in the same directory as the file being tailed. The same glob pattern will be used for all files."); v = ; v = virtualinvoke v.(v); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(0); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("Post-Rollover Tail Period"); v = virtualinvoke v.("When a file is rolled over, the processor will continue tailing the rolled over file until it has not been modified for this amount of time. This allows for another process to rollover a file, and then flush out any buffered data. Note that when this value is set, and the tailed file rolls over, the new file will not be tailed until the old file has not been modified for the configured amount of time. Additionally, when using this capability, in order to avoid data duplication, this period must be set longer than the Processor\'s Run Schedule, and the Processor must not be stopped after the file being tailed has been rolled over and before the data has been fully consumed. Otherwise, the data may be duplicated, as the entire file may be written out as the contents of a single FlowFile."); v = virtualinvoke v.(0); v = ; v = virtualinvoke v.(v); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.("0 sec"); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("State Location"); v = virtualinvoke v.("File Location"); v = virtualinvoke v.("Specifies where the state is located either local or cluster so that state can be stored appropriately in order to ensure that all data is consumed without duplicating data upon restart of NiFi"); v = virtualinvoke v.(1); v = newarray (org.apache.nifi.components.AllowableValue)[2]; v = ; v[0] = v; v = ; v[1] = v; v = virtualinvoke v.(v); v = ; v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("Initial Start Position"); v = virtualinvoke v.("When the Processor first begins to tail data, this property specifies where the Processor should begin reading data. Once data has been ingested from a file, the Processor will continue from the last point from which it has received data."); v = newarray (org.apache.nifi.components.AllowableValue)[3]; v = ; v[0] = v; v = ; v[1] = v; v = ; v[2] = v; v = virtualinvoke v.(v); v = ; v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(1); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("tailfile-recursive-lookup"); v = virtualinvoke v.("Recursive lookup"); v = virtualinvoke v.("When using Multiple files mode, this property defines if files must be listed recursively or not in the base directory."); v = newarray (java.lang.String)[2]; v[0] = "true"; v[1] = "false"; v = virtualinvoke v.(v); v = virtualinvoke v.("false"); v = virtualinvoke v.(1); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("tailfile-lookup-frequency"); v = virtualinvoke v.("Lookup frequency"); v = virtualinvoke v.("Only used in Multiple files mode. It specifies the minimum duration the processor will wait before listing again the files to tail."); v = virtualinvoke v.(0); v = virtualinvoke v.("10 minutes"); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("tailfile-maximum-age"); v = virtualinvoke v.("Maximum age"); v = virtualinvoke v.("Only used in Multiple files mode. It specifies the necessary minimum duration to consider that no new messages will be appended in a file regarding its last modification date. This should not be set too low to avoid duplication of data in case new messages are appended at a lower frequency."); v = virtualinvoke v.(0); v = virtualinvoke v.("24 hours"); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("reread-on-nul"); v = virtualinvoke v.("Reread when NUL encountered"); v = virtualinvoke v.("If this option is set to \'true\', when a NUL character is read, the processor will yield and try to read the same part again later. (Note: Yielding may delay the processing of other files tailed by this processor, not just the one with the NUL character.) The purpose of this flag is to allow users to handle cases where reading a file may return temporary NUL values. NFS for example may send file contents out of order. In this case the missing parts are temporarily replaced by NUL values. CAUTION! If the file contains legitimate NUL values, setting this flag causes this processor to get stuck indefinitely. For this reason users should refrain from using this feature if they can help it and try to avoid having the target file on a file system where reads are unreliable."); v = virtualinvoke v.(0); v = newarray (java.lang.String)[2]; v[0] = "true"; v[1] = "false"; v = virtualinvoke v.(v); v = virtualinvoke v.("false"); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("Line Start Pattern"); v = virtualinvoke v.("Line Start Pattern"); v = virtualinvoke v.("A Regular Expression to match against the start of a log line. If specified, any line that matches the expression, and any following lines, will be buffered until another line matches the Expression. In doing this, we can avoid splitting apart multi-line messages in the file. This assumes that the data is in UTF-8 format."); v = virtualinvoke v.(0); v = ; v = virtualinvoke v.(v); v = ; v = virtualinvoke v.(v); v = ; v = newarray (org.apache.nifi.components.AllowableValue)[1]; v = ; v[0] = v; v = virtualinvoke v.(v, v); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("Max Buffer Size"); v = virtualinvoke v.("Max Buffer Size"); v = virtualinvoke v.("When using the Line Start Pattern, there may be situations in which the data in the file being tailed never matches the Regular Expression. This would result in the processor buffering all data from the tailed file, which can quickly exhaust the heap. To avoid this, the Processor will buffer only up to this amount of data before flushing the buffer, even if it means ingesting partial data from the file."); v = virtualinvoke v.(1); v = ; v = virtualinvoke v.(v); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.("64 KB"); v = ; v = newarray (org.apache.nifi.components.AllowableValue)[0]; v = virtualinvoke v.(v, v); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("pre-allocated-buffer-size"); v = virtualinvoke v.("Pre-Allocated Buffer Size"); v = virtualinvoke v.("Sets the amount of memory that is pre-allocated for each tailed file."); v = virtualinvoke v.(1); v = ; v = virtualinvoke v.(v); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.("65536 B"); v = virtualinvoke v.(); = v; v = new org.apache.nifi.processor.Relationship$Builder; specialinvoke v.()>(); v = virtualinvoke v.("success"); v = virtualinvoke v.("All FlowFiles are routed to this Relationship."); v = virtualinvoke v.(); = v; return; } }