public class org.apache.nifi.processors.standard.UnpackContent extends org.apache.nifi.processor.AbstractProcessor
{
public static final java.lang.String FRAGMENT_ID;
public static final java.lang.String FRAGMENT_INDEX;
public static final java.lang.String FRAGMENT_COUNT;
public static final java.lang.String SEGMENT_ORIGINAL_FILENAME;
public static final java.lang.String AUTO_DETECT_FORMAT_NAME;
public static final java.lang.String TAR_FORMAT_NAME;
public static final java.lang.String ZIP_FORMAT_NAME;
public static final java.lang.String FLOWFILE_STREAM_FORMAT_V3_NAME;
public static final java.lang.String FLOWFILE_STREAM_FORMAT_V2_NAME;
public static final java.lang.String FLOWFILE_TAR_FORMAT_NAME;
public static final java.lang.String OCTET_STREAM;
public static final java.lang.String FILE_LAST_MODIFIED_TIME_ATTRIBUTE;
public static final java.lang.String FILE_CREATION_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_ENCRYPTION_METHOD_ATTRIBUTE;
public static final java.lang.String FILE_MODIFIED_DATE_ATTR_FORMAT;
public static final java.time.format.DateTimeFormatter DATE_TIME_FORMATTER;
public static final org.apache.nifi.components.PropertyDescriptor PACKAGING_FORMAT;
public static final org.apache.nifi.components.PropertyDescriptor FILE_FILTER;
public static final org.apache.nifi.components.PropertyDescriptor PASSWORD;
public static final org.apache.nifi.components.PropertyDescriptor ALLOW_STORED_ENTRIES_WITH_DATA_DESCRIPTOR;
public static final org.apache.nifi.processor.Relationship REL_SUCCESS;
public static final org.apache.nifi.processor.Relationship REL_ORIGINAL;
public static final org.apache.nifi.processor.Relationship REL_FAILURE;
private java.util.Set relationships;
private java.util.List properties;
private java.util.regex.Pattern fileFilter;
private org.apache.nifi.processors.standard.UnpackContent$Unpacker tarUnpacker;
private org.apache.nifi.processors.standard.UnpackContent$Unpacker zipUnpacker;
public void <init>()
{
org.apache.nifi.processors.standard.UnpackContent v;
v := @this: org.apache.nifi.processors.standard.UnpackContent;
specialinvoke v.<org.apache.nifi.processor.AbstractProcessor: void <init>()>();
return;
}
protected void init(org.apache.nifi.processor.ProcessorInitializationContext)
{
java.util.Set v;
org.apache.nifi.processors.standard.UnpackContent v;
org.apache.nifi.components.PropertyDescriptor v, v, v, v;
java.util.ArrayList v;
java.util.HashSet v;
java.util.List v;
org.apache.nifi.processor.Relationship v, v, v;
org.apache.nifi.processor.ProcessorInitializationContext v;
v := @this: org.apache.nifi.processors.standard.UnpackContent;
v := @parameter: org.apache.nifi.processor.ProcessorInitializationContext;
v = new java.util.HashSet;
specialinvoke v.<java.util.HashSet: void <init>()>();
v = <org.apache.nifi.processors.standard.UnpackContent: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.UnpackContent: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.UnpackContent: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
v = staticinvoke <java.util.Collections: java.util.Set unmodifiableSet(java.util.Set)>(v);
v.<org.apache.nifi.processors.standard.UnpackContent: java.util.Set relationships> = v;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = <org.apache.nifi.processors.standard.UnpackContent: org.apache.nifi.components.PropertyDescriptor PACKAGING_FORMAT>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.UnpackContent: org.apache.nifi.components.PropertyDescriptor FILE_FILTER>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.UnpackContent: org.apache.nifi.components.PropertyDescriptor PASSWORD>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.UnpackContent: org.apache.nifi.components.PropertyDescriptor ALLOW_STORED_ENTRIES_WITH_DATA_DESCRIPTOR>;
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.UnpackContent: java.util.List properties> = v;
return;
}
public java.util.Set getRelationships()
{
java.util.Set v;
org.apache.nifi.processors.standard.UnpackContent v;
v := @this: org.apache.nifi.processors.standard.UnpackContent;
v = v.<org.apache.nifi.processors.standard.UnpackContent: java.util.Set relationships>;
return v;
}
protected java.util.List getSupportedPropertyDescriptors()
{
java.util.List v;
org.apache.nifi.processors.standard.UnpackContent v;
v := @this: org.apache.nifi.processors.standard.UnpackContent;
v = v.<org.apache.nifi.processors.standard.UnpackContent: java.util.List properties>;
return v;
}
public void onStopped()
{
org.apache.nifi.processors.standard.UnpackContent v;
v := @this: org.apache.nifi.processors.standard.UnpackContent;
v.<org.apache.nifi.processors.standard.UnpackContent: java.util.regex.Pattern fileFilter> = null;
return;
}
public void onScheduled(org.apache.nifi.processor.ProcessContext) throws org.apache.nifi.processor.exception.ProcessException
{
org.apache.nifi.components.PropertyDescriptor v, v, v;
org.apache.nifi.components.PropertyValue v, v, v;
java.lang.Boolean v;
java.lang.String v, v;
boolean v, v, v;
org.apache.nifi.processors.standard.UnpackContent$ZipUnpacker v;
org.apache.nifi.processor.ProcessContext v;
org.apache.nifi.processors.standard.UnpackContent v;
org.apache.nifi.processors.standard.UnpackContent$TarUnpacker v;
char[] v;
java.util.regex.Pattern v, v, v, v;
v := @this: org.apache.nifi.processors.standard.UnpackContent;
v := @parameter: org.apache.nifi.processor.ProcessContext;
v = v.<org.apache.nifi.processors.standard.UnpackContent: java.util.regex.Pattern fileFilter>;
if v != null goto label;
v = <org.apache.nifi.processors.standard.UnpackContent: 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.UnpackContent: java.util.regex.Pattern fileFilter> = v;
v = new org.apache.nifi.processors.standard.UnpackContent$TarUnpacker;
v = v.<org.apache.nifi.processors.standard.UnpackContent: java.util.regex.Pattern fileFilter>;
specialinvoke v.<org.apache.nifi.processors.standard.UnpackContent$TarUnpacker: void <init>(java.util.regex.Pattern)>(v);
v.<org.apache.nifi.processors.standard.UnpackContent: org.apache.nifi.processors.standard.UnpackContent$Unpacker tarUnpacker> = v;
v = null;
v = <org.apache.nifi.processors.standard.UnpackContent: org.apache.nifi.components.PropertyDescriptor PASSWORD>;
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: boolean isSet()>();
if v == 0 goto label;
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.String getValue()>();
v = virtualinvoke v.<java.lang.String: char[] toCharArray()>();
label:
v = <org.apache.nifi.processors.standard.UnpackContent: org.apache.nifi.components.PropertyDescriptor ALLOW_STORED_ENTRIES_WITH_DATA_DESCRIPTOR>;
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: boolean isSet()>();
if v == 0 goto label;
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.Boolean asBoolean()>();
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
goto label;
label:
v = 0;
label:
v = new org.apache.nifi.processors.standard.UnpackContent$ZipUnpacker;
v = v.<org.apache.nifi.processors.standard.UnpackContent: java.util.regex.Pattern fileFilter>;
specialinvoke v.<org.apache.nifi.processors.standard.UnpackContent$ZipUnpacker: void <init>(java.util.regex.Pattern,char[],boolean)>(v, v, v);
v.<org.apache.nifi.processors.standard.UnpackContent: org.apache.nifi.processors.standard.UnpackContent$Unpacker zipUnpacker> = v;
label:
return;
}
public void onTrigger(org.apache.nifi.processor.ProcessContext, org.apache.nifi.processor.ProcessSession) throws org.apache.nifi.processor.exception.ProcessException
{
org.apache.nifi.util.FlowFileUnpackagerV3 v;
org.apache.nifi.util.FlowFileUnpackagerV1 v;
org.apache.nifi.util.FlowFileUnpackagerV2 v;
org.apache.nifi.processors.standard.UnpackContent$Unpacker v;
org.apache.nifi.components.PropertyDescriptor v;
org.apache.nifi.components.PropertyValue v;
int[] v;
boolean v, v, v;
org.apache.nifi.processors.standard.UnpackContent$PackageFormat[] v;
org.apache.nifi.flowfile.FlowFile v;
java.lang.Exception v;
org.apache.nifi.processors.standard.UnpackContent$PackageFormat v, v, v;
org.apache.nifi.processors.standard.UnpackContent$FlowFileStreamUnpacker v, v, v;
java.lang.Object[] v, v, v, v, v;
org.apache.nifi.logging.ComponentLog v;
org.apache.nifi.processor.exception.ProcessException v;
java.util.ArrayList v;
org.apache.nifi.provenance.ProvenanceReporter v;
org.apache.nifi.processor.Relationship v, v, v, v, v, v;
int v, v, v, v, v, v;
java.lang.String v, v, v, v, v, v, v, v, v;
org.apache.nifi.processor.ProcessContext v;
org.apache.nifi.processor.ProcessSession v;
org.apache.nifi.processors.standard.UnpackContent v;
java.lang.Object v;
org.apache.nifi.flowfile.attributes.CoreAttributes v;
v := @this: org.apache.nifi.processors.standard.UnpackContent;
v := @parameter: org.apache.nifi.processor.ProcessContext;
v := @parameter: org.apache.nifi.processor.ProcessSession;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile get()>();
if v != null goto label;
return;
label:
v = virtualinvoke v.<org.apache.nifi.processors.standard.UnpackContent: org.apache.nifi.logging.ComponentLog getLogger()>();
v = <org.apache.nifi.processors.standard.UnpackContent: org.apache.nifi.components.PropertyDescriptor PACKAGING_FORMAT>;
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 = virtualinvoke v.<java.lang.String: java.lang.String toLowerCase()>();
v = staticinvoke <org.apache.nifi.processors.standard.UnpackContent$PackageFormat: org.apache.nifi.processors.standard.UnpackContent$PackageFormat getFormat(java.lang.String)>(v);
v = <org.apache.nifi.processors.standard.UnpackContent$PackageFormat: org.apache.nifi.processors.standard.UnpackContent$PackageFormat AUTO_DETECT_FORMAT>;
if v != v goto label;
v = null;
v = <org.apache.nifi.flowfile.attributes.CoreAttributes: org.apache.nifi.flowfile.attributes.CoreAttributes MIME_TYPE>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.CoreAttributes: java.lang.String key()>();
v = interfaceinvoke v.<org.apache.nifi.flowfile.FlowFile: java.lang.String getAttribute(java.lang.String)>(v);
if v != null goto label;
v = newarray (java.lang.Object)[1];
v[0] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void error(java.lang.String,java.lang.Object[])>("No mime.type attribute set for {}; routing to failure", v);
v = <org.apache.nifi.processors.standard.UnpackContent: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void transfer(org.apache.nifi.flowfile.FlowFile,org.apache.nifi.processor.Relationship)>(v, v);
return;
label:
v = staticinvoke <org.apache.nifi.processors.standard.UnpackContent$PackageFormat: org.apache.nifi.processors.standard.UnpackContent$PackageFormat[] values()>();
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = virtualinvoke v.<java.lang.String: java.lang.String toLowerCase()>();
v = virtualinvoke v.<org.apache.nifi.processors.standard.UnpackContent$PackageFormat: java.lang.String getMimeType()>();
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = v;
label:
v = v + 1;
goto label;
label:
if v != null goto label;
v = newarray (java.lang.Object)[2];
v[0] = v;
v[1] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void info(java.lang.String,java.lang.Object[])>("Cannot unpack {} because its mime.type attribute is set to \'{}\', which is not a format that can be unpacked; routing to \'success\'", v);
v = <org.apache.nifi.processors.standard.UnpackContent: 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);
return;
label:
v = <org.apache.nifi.processors.standard.UnpackContent$1: int[] $SwitchMap$org$apache$nifi$processors$standard$UnpackContent$PackageFormat>;
v = virtualinvoke v.<org.apache.nifi.processors.standard.UnpackContent$PackageFormat: int ordinal()>();
v = v[v];
tableswitch(v)
{
case 1: goto label;
case 2: goto label;
case 3: goto label;
case 4: goto label;
case 5: goto label;
case 6: goto label;
case 7: goto label;
default: goto label;
};
label:
v = v.<org.apache.nifi.processors.standard.UnpackContent: org.apache.nifi.processors.standard.UnpackContent$Unpacker tarUnpacker>;
v = 1;
goto label;
label:
v = v.<org.apache.nifi.processors.standard.UnpackContent: org.apache.nifi.processors.standard.UnpackContent$Unpacker zipUnpacker>;
v = 1;
goto label;
label:
v = new org.apache.nifi.processors.standard.UnpackContent$FlowFileStreamUnpacker;
v = new org.apache.nifi.util.FlowFileUnpackagerV2;
specialinvoke v.<org.apache.nifi.util.FlowFileUnpackagerV2: void <init>()>();
specialinvoke v.<org.apache.nifi.processors.standard.UnpackContent$FlowFileStreamUnpacker: void <init>(org.apache.nifi.util.FlowFileUnpackager)>(v);
v = v;
v = 0;
goto label;
label:
v = new org.apache.nifi.processors.standard.UnpackContent$FlowFileStreamUnpacker;
v = new org.apache.nifi.util.FlowFileUnpackagerV3;
specialinvoke v.<org.apache.nifi.util.FlowFileUnpackagerV3: void <init>()>();
specialinvoke v.<org.apache.nifi.processors.standard.UnpackContent$FlowFileStreamUnpacker: void <init>(org.apache.nifi.util.FlowFileUnpackager)>(v);
v = v;
v = 0;
goto label;
label:
v = new org.apache.nifi.processors.standard.UnpackContent$FlowFileStreamUnpacker;
v = new org.apache.nifi.util.FlowFileUnpackagerV1;
specialinvoke v.<org.apache.nifi.util.FlowFileUnpackagerV1: void <init>()>();
specialinvoke v.<org.apache.nifi.processors.standard.UnpackContent$FlowFileStreamUnpacker: void <init>(org.apache.nifi.util.FlowFileUnpackager)>(v);
v = v;
v = 0;
goto label;
label:
v = new org.apache.nifi.processor.exception.ProcessException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.nifi.processors.standard.UnpackContent$PackageFormat)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u is not a valid packaging format");
specialinvoke v.<org.apache.nifi.processor.exception.ProcessException: void <init>(java.lang.String)>(v);
throw v;
label:
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
label:
virtualinvoke v.<org.apache.nifi.processors.standard.UnpackContent$Unpacker: void unpack(org.apache.nifi.processor.ProcessSession,org.apache.nifi.flowfile.FlowFile,java.util.List)>(v, v, v);
v = interfaceinvoke v.<java.util.List: boolean isEmpty()>();
if v == 0 goto label;
v = newarray (java.lang.Object)[1];
v[0] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void error(java.lang.String,java.lang.Object[])>("Unable to unpack {} because it does not appear to have any entries; routing to failure", v);
v = <org.apache.nifi.processors.standard.UnpackContent: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void transfer(org.apache.nifi.flowfile.FlowFile,org.apache.nifi.processor.Relationship)>(v, v);
label:
return;
label:
if v == 0 goto label;
specialinvoke v.<org.apache.nifi.processors.standard.UnpackContent: void finishFragmentAttributes(org.apache.nifi.processor.ProcessSession,org.apache.nifi.flowfile.FlowFile,java.util.List)>(v, v, v);
label:
v = <org.apache.nifi.processors.standard.UnpackContent: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void transfer(java.util.Collection,org.apache.nifi.processor.Relationship)>(v, v);
v = interfaceinvoke v.<java.util.List: int size()>();
if v <= 0 goto label;
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = <org.apache.nifi.processors.standard.UnpackContent: java.lang.String FRAGMENT_ID>;
v = interfaceinvoke v.<org.apache.nifi.flowfile.FlowFile: java.lang.String getAttribute(java.lang.String)>(v);
goto label;
label:
v = null;
label:
v = interfaceinvoke v.<java.util.List: int size()>();
v = staticinvoke <org.apache.nifi.flowfile.attributes.FragmentAttributes: org.apache.nifi.flowfile.FlowFile copyAttributesToOriginal(org.apache.nifi.processor.ProcessSession,org.apache.nifi.flowfile.FlowFile,java.lang.String,int)>(v, v, v, v);
v = <org.apache.nifi.processors.standard.UnpackContent: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void transfer(org.apache.nifi.flowfile.FlowFile,org.apache.nifi.processor.Relationship)>(v, v);
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.provenance.ProvenanceReporter getProvenanceReporter()>();
interfaceinvoke v.<org.apache.nifi.provenance.ProvenanceReporter: void fork(org.apache.nifi.flowfile.FlowFile,java.util.Collection)>(v, v);
v = newarray (java.lang.Object)[2];
v[0] = v;
v[1] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void info(java.lang.String,java.lang.Object[])>("Unpacked {} into {} and transferred to success", v);
label:
goto label;
label:
v := @caughtexception;
v = newarray (java.lang.Object)[2];
v[0] = v;
v[1] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void error(java.lang.String,java.lang.Object[])>("Unable to unpack {}; routing to failure", v);
v = <org.apache.nifi.processors.standard.UnpackContent: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void transfer(org.apache.nifi.flowfile.FlowFile,org.apache.nifi.processor.Relationship)>(v, v);
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void remove(java.util.Collection)>(v);
label:
return;
catch java.lang.Exception from label to label with label;
catch java.lang.Exception from label to label with label;
}
private static void mapAttributes(java.util.Map, java.lang.String, java.lang.String)
{
java.util.Map v;
java.lang.Object v;
java.lang.String v, v;
boolean v, v;
v := @parameter: java.util.Map;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = interfaceinvoke v.<java.util.Map: boolean containsKey(java.lang.Object)>(v);
if v != 0 goto label;
v = interfaceinvoke v.<java.util.Map: boolean containsKey(java.lang.Object)>(v);
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
label:
return;
}
private void finishFragmentAttributes(org.apache.nifi.processor.ProcessSession, org.apache.nifi.flowfile.FlowFile, java.util.List)
{
java.util.HashMap v;
java.util.ArrayList v;
int v, v, v;
java.lang.String v, v, v, v, v, v, v;
boolean v, v, v, v, v;
java.util.Iterator v, v;
org.apache.nifi.flowfile.FlowFile v, v;
org.apache.nifi.processor.ProcessSession v;
org.apache.nifi.processors.standard.UnpackContent v;
java.util.List v;
java.lang.Object v, v;
org.apache.nifi.flowfile.attributes.CoreAttributes v;
v := @this: org.apache.nifi.processors.standard.UnpackContent;
v := @parameter: org.apache.nifi.processor.ProcessSession;
v := @parameter: org.apache.nifi.flowfile.FlowFile;
v := @parameter: java.util.List;
v = 0;
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = <org.apache.nifi.processors.standard.UnpackContent: java.lang.String FRAGMENT_INDEX>;
v = interfaceinvoke v.<org.apache.nifi.flowfile.FlowFile: java.lang.String getAttribute(java.lang.String)>(v);
if v == null goto label;
v = v + 1;
goto label;
label:
return;
label:
v = <org.apache.nifi.flowfile.attributes.CoreAttributes: org.apache.nifi.flowfile.attributes.CoreAttributes FILENAME>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.CoreAttributes: java.lang.String key()>();
v = interfaceinvoke v.<org.apache.nifi.flowfile.FlowFile: java.lang.String getAttribute(java.lang.String)>(v);
v = virtualinvoke v.<java.lang.String: boolean endsWith(java.lang.String)>(".tar");
if v != 0 goto label;
v = virtualinvoke v.<java.lang.String: boolean endsWith(java.lang.String)>(".zip");
if v != 0 goto label;
v = virtualinvoke v.<java.lang.String: boolean endsWith(java.lang.String)>(".pkg");
if v == 0 goto label;
label:
v = virtualinvoke v.<java.lang.String: int length()>();
v = v - 4;
v = virtualinvoke v.<java.lang.String: java.lang.String substring(int,int)>(0, v);
label:
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>(java.util.Collection)>(v);
interfaceinvoke v.<java.util.List: void clear()>();
v = virtualinvoke v.<java.util.ArrayList: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v = <org.apache.nifi.processors.standard.UnpackContent: java.lang.String FRAGMENT_COUNT>;
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = <org.apache.nifi.processors.standard.UnpackContent: java.lang.String SEGMENT_ORIGINAL_FILENAME>;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile putAllAttributes(org.apache.nifi.flowfile.FlowFile,java.util.Map)>(v, v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
return;
}
static void <clinit>()
{
org.apache.nifi.components.PropertyDescriptor v, v, v, v, v;
org.apache.nifi.flowfile.attributes.FragmentAttributes v, v, v, v;
java.time.ZoneId v;
org.apache.nifi.processors.standard.UnpackContent$PackageFormat v, v, v, v, v, v, v, v;
org.apache.nifi.processor.Relationship v, v, v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.nifi.components.PropertyDescriptor$Builder v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.lang.String[] v, v, v;
org.apache.nifi.components.Validator v, v, v;
org.apache.nifi.processor.Relationship$Builder v, v, v, v, v, v, v, v, v;
java.time.format.DateTimeFormatter v, v;
v = <org.apache.nifi.flowfile.attributes.FragmentAttributes: org.apache.nifi.flowfile.attributes.FragmentAttributes FRAGMENT_ID>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.FragmentAttributes: java.lang.String key()>();
<org.apache.nifi.processors.standard.UnpackContent: java.lang.String FRAGMENT_ID> = v;
v = <org.apache.nifi.flowfile.attributes.FragmentAttributes: org.apache.nifi.flowfile.attributes.FragmentAttributes FRAGMENT_INDEX>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.FragmentAttributes: java.lang.String key()>();
<org.apache.nifi.processors.standard.UnpackContent: java.lang.String FRAGMENT_INDEX> = v;
v = <org.apache.nifi.flowfile.attributes.FragmentAttributes: org.apache.nifi.flowfile.attributes.FragmentAttributes FRAGMENT_COUNT>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.FragmentAttributes: java.lang.String key()>();
<org.apache.nifi.processors.standard.UnpackContent: java.lang.String FRAGMENT_COUNT> = v;
v = <org.apache.nifi.flowfile.attributes.FragmentAttributes: org.apache.nifi.flowfile.attributes.FragmentAttributes SEGMENT_ORIGINAL_FILENAME>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.FragmentAttributes: java.lang.String key()>();
<org.apache.nifi.processors.standard.UnpackContent: java.lang.String SEGMENT_ORIGINAL_FILENAME> = v;
v = staticinvoke <java.time.format.DateTimeFormatter: java.time.format.DateTimeFormatter ofPattern(java.lang.String)>("yyyy-MM-dd\'T\'HH:mm:ssZ");
v = staticinvoke <java.time.ZoneId: java.time.ZoneId systemDefault()>();
v = virtualinvoke v.<java.time.format.DateTimeFormatter: java.time.format.DateTimeFormatter withZone(java.time.ZoneId)>(v);
<org.apache.nifi.processors.standard.UnpackContent: java.time.format.DateTimeFormatter DATE_TIME_FORMATTER> = 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)>("Packaging Format");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("The Packaging Format used to create 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)[6];
v = <org.apache.nifi.processors.standard.UnpackContent$PackageFormat: org.apache.nifi.processors.standard.UnpackContent$PackageFormat AUTO_DETECT_FORMAT>;
v = virtualinvoke v.<org.apache.nifi.processors.standard.UnpackContent$PackageFormat: java.lang.String toString()>();
v[0] = v;
v = <org.apache.nifi.processors.standard.UnpackContent$PackageFormat: org.apache.nifi.processors.standard.UnpackContent$PackageFormat TAR_FORMAT>;
v = virtualinvoke v.<org.apache.nifi.processors.standard.UnpackContent$PackageFormat: java.lang.String toString()>();
v[1] = v;
v = <org.apache.nifi.processors.standard.UnpackContent$PackageFormat: org.apache.nifi.processors.standard.UnpackContent$PackageFormat ZIP_FORMAT>;
v = virtualinvoke v.<org.apache.nifi.processors.standard.UnpackContent$PackageFormat: java.lang.String toString()>();
v[2] = v;
v = <org.apache.nifi.processors.standard.UnpackContent$PackageFormat: org.apache.nifi.processors.standard.UnpackContent$PackageFormat FLOWFILE_STREAM_FORMAT_V3>;
v = virtualinvoke v.<org.apache.nifi.processors.standard.UnpackContent$PackageFormat: java.lang.String toString()>();
v[3] = v;
v = <org.apache.nifi.processors.standard.UnpackContent$PackageFormat: org.apache.nifi.processors.standard.UnpackContent$PackageFormat FLOWFILE_STREAM_FORMAT_V2>;
v = virtualinvoke v.<org.apache.nifi.processors.standard.UnpackContent$PackageFormat: java.lang.String toString()>();
v[4] = v;
v = <org.apache.nifi.processors.standard.UnpackContent$PackageFormat: org.apache.nifi.processors.standard.UnpackContent$PackageFormat FLOWFILE_TAR_FORMAT>;
v = virtualinvoke v.<org.apache.nifi.processors.standard.UnpackContent$PackageFormat: java.lang.String toString()>();
v[5] = v;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder allowableValues(java.lang.String[])>(v);
v = <org.apache.nifi.processors.standard.UnpackContent$PackageFormat: org.apache.nifi.processors.standard.UnpackContent$PackageFormat AUTO_DETECT_FORMAT>;
v = virtualinvoke v.<org.apache.nifi.processors.standard.UnpackContent$PackageFormat: java.lang.String toString()>();
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder defaultValue(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.UnpackContent: org.apache.nifi.components.PropertyDescriptor PACKAGING_FORMAT> = 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 contained in the archive whose names match the given regular expression will be extracted (tar/zip only)");
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.UnpackContent: 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)>("Password");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder displayName(java.lang.String)>("Password");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("Password used for decrypting Zip archives encrypted with ZipCrypto or AES. Configuring a password disables support for alternative Zip compression algorithms.");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder required(boolean)>(0);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder sensitive(boolean)>(1);
v = <org.apache.nifi.processor.util.StandardValidators: org.apache.nifi.components.Validator NON_BLANK_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.UnpackContent: org.apache.nifi.components.PropertyDescriptor PASSWORD> = 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)>("allow-stored-entries-wdd");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder displayName(java.lang.String)>("Allow Stored Entries With Data Descriptor");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("Some zip archives contain stored entries with data descriptors which by spec should not happen.  If this property is true they will be read anyway.  If false and such an entry is discovered the zip will fail to process.");
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)>("false");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder sensitive(boolean)>(0);
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 = <org.apache.nifi.processors.standard.UnpackContent: org.apache.nifi.components.PropertyDescriptor PACKAGING_FORMAT>;
v = <org.apache.nifi.processors.standard.UnpackContent$PackageFormat: org.apache.nifi.processors.standard.UnpackContent$PackageFormat ZIP_FORMAT>;
v = virtualinvoke v.<org.apache.nifi.processors.standard.UnpackContent$PackageFormat: java.lang.String toString()>();
v = newarray (java.lang.String)[0];
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder dependsOn(org.apache.nifi.components.PropertyDescriptor,java.lang.String,java.lang.String[])>(v, v, v);
v = <org.apache.nifi.processor.util.StandardValidators: org.apache.nifi.components.Validator BOOLEAN_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.UnpackContent: org.apache.nifi.components.PropertyDescriptor ALLOW_STORED_ENTRIES_WITH_DATA_DESCRIPTOR> = 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)>("Unpacked FlowFiles are sent to this relationship");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship build()>();
<org.apache.nifi.processors.standard.UnpackContent: org.apache.nifi.processor.Relationship REL_SUCCESS> = v;
v = new org.apache.nifi.processor.Relationship$Builder;
specialinvoke v.<org.apache.nifi.processor.Relationship$Builder: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship$Builder name(java.lang.String)>("original");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship$Builder description(java.lang.String)>("The original FlowFile is sent to this relationship after it has been successfully unpacked");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship build()>();
<org.apache.nifi.processors.standard.UnpackContent: org.apache.nifi.processor.Relationship REL_ORIGINAL> = v;
v = new org.apache.nifi.processor.Relationship$Builder;
specialinvoke v.<org.apache.nifi.processor.Relationship$Builder: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship$Builder name(java.lang.String)>("failure");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship$Builder description(java.lang.String)>("The original FlowFile is sent to this relationship when it cannot be unpacked for some reason");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship build()>();
<org.apache.nifi.processors.standard.UnpackContent: org.apache.nifi.processor.Relationship REL_FAILURE> = v;
return;
}
}