public class org.apache.nifi.processors.standard.MergeContent extends org.apache.nifi.processor.util.bin.BinFiles { public static final java.lang.String FRAGMENT_ID_ATTRIBUTE; public static final java.lang.String FRAGMENT_INDEX_ATTRIBUTE; public static final java.lang.String FRAGMENT_COUNT_ATTRIBUTE; public static final java.lang.String SEGMENT_ID_ATTRIBUTE; public static final java.lang.String SEGMENT_INDEX_ATTRIBUTE; public static final java.lang.String SEGMENT_COUNT_ATTRIBUTE; public static final java.lang.String SEGMENT_ORIGINAL_FILENAME; public static final org.apache.nifi.components.AllowableValue METADATA_STRATEGY_USE_FIRST; public static final org.apache.nifi.components.AllowableValue METADATA_STRATEGY_ALL_COMMON; public static final org.apache.nifi.components.AllowableValue METADATA_STRATEGY_IGNORE; public static final org.apache.nifi.components.AllowableValue METADATA_STRATEGY_DO_NOT_MERGE; public static final org.apache.nifi.components.AllowableValue MERGE_STRATEGY_BIN_PACK; public static final org.apache.nifi.components.AllowableValue MERGE_STRATEGY_DEFRAGMENT; public static final org.apache.nifi.components.AllowableValue DELIMITER_STRATEGY_FILENAME; public static final org.apache.nifi.components.AllowableValue DELIMITER_STRATEGY_TEXT; public static final org.apache.nifi.components.AllowableValue DELIMITER_STRATEGY_NONE; public static final java.lang.String MERGE_FORMAT_TAR_VALUE; public static final java.lang.String MERGE_FORMAT_ZIP_VALUE; public static final java.lang.String MERGE_FORMAT_FLOWFILE_STREAM_V3_VALUE; public static final java.lang.String MERGE_FORMAT_FLOWFILE_STREAM_V2_VALUE; public static final java.lang.String MERGE_FORMAT_FLOWFILE_TAR_V1_VALUE; public static final java.lang.String MERGE_FORMAT_CONCAT_VALUE; public static final java.lang.String MERGE_FORMAT_AVRO_VALUE; public static final org.apache.nifi.components.AllowableValue MERGE_FORMAT_TAR; public static final org.apache.nifi.components.AllowableValue MERGE_FORMAT_ZIP; public static final org.apache.nifi.components.AllowableValue MERGE_FORMAT_FLOWFILE_STREAM_V3; public static final org.apache.nifi.components.AllowableValue MERGE_FORMAT_FLOWFILE_STREAM_V2; public static final org.apache.nifi.components.AllowableValue MERGE_FORMAT_FLOWFILE_TAR_V1; public static final org.apache.nifi.components.AllowableValue MERGE_FORMAT_CONCAT; public static final org.apache.nifi.components.AllowableValue MERGE_FORMAT_AVRO; public static final java.lang.String TAR_PERMISSIONS_ATTRIBUTE; public static final java.lang.String MERGE_COUNT_ATTRIBUTE; public static final java.lang.String MERGE_BIN_AGE_ATTRIBUTE; public static final java.lang.String MERGE_UUID_ATTRIBUTE; public static final java.lang.String REASON_FOR_MERGING; public static final org.apache.nifi.components.PropertyDescriptor MERGE_STRATEGY; public static final org.apache.nifi.components.PropertyDescriptor MERGE_FORMAT; public static final org.apache.nifi.components.PropertyDescriptor METADATA_STRATEGY; public static final org.apache.nifi.components.PropertyDescriptor CORRELATION_ATTRIBUTE_NAME; public static final org.apache.nifi.components.PropertyDescriptor DELIMITER_STRATEGY; public static final org.apache.nifi.components.PropertyDescriptor HEADER; public static final org.apache.nifi.components.PropertyDescriptor FOOTER; public static final org.apache.nifi.components.PropertyDescriptor DEMARCATOR; public static final org.apache.nifi.components.PropertyDescriptor COMPRESSION_LEVEL; public static final org.apache.nifi.components.PropertyDescriptor KEEP_PATH; public static final org.apache.nifi.components.PropertyDescriptor TAR_MODIFIED_TIME; public static final org.apache.nifi.processor.Relationship REL_MERGED; public static final java.util.regex.Pattern NUMBER_PATTERN; public void () { org.apache.nifi.processors.standard.MergeContent v; v := @this: org.apache.nifi.processors.standard.MergeContent; specialinvoke v.()>(); return; } public java.util.Set getRelationships() { java.util.HashSet v; org.apache.nifi.processor.Relationship v, v, v; org.apache.nifi.processors.standard.MergeContent v; v := @this: org.apache.nifi.processors.standard.MergeContent; v = new java.util.HashSet; specialinvoke v.()>(); v = ; interfaceinvoke v.(v); v = ; interfaceinvoke v.(v); v = ; interfaceinvoke v.(v); return v; } protected java.util.List getSupportedPropertyDescriptors() { org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.util.ArrayList v; org.apache.nifi.processors.standard.MergeContent v; v := @this: org.apache.nifi.processors.standard.MergeContent; 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 = ; v = specialinvoke v.(v); interfaceinvoke v.(v); v = ; v = specialinvoke v.(v); interfaceinvoke v.(v); v = ; v = specialinvoke v.(v); interfaceinvoke v.(v); v = ; v = 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); return v; } private org.apache.nifi.components.PropertyDescriptor addBinPackingDependency(org.apache.nifi.components.PropertyDescriptor) { org.apache.nifi.components.AllowableValue[] v; org.apache.nifi.components.AllowableValue v; org.apache.nifi.components.PropertyDescriptor v, v, v; org.apache.nifi.components.PropertyDescriptor$Builder v, v, v; org.apache.nifi.processors.standard.MergeContent v; v := @this: org.apache.nifi.processors.standard.MergeContent; v := @parameter: org.apache.nifi.components.PropertyDescriptor; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke 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.(); return v; } protected java.util.Collection additionalCustomValidation(org.apache.nifi.components.ValidationContext) { org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v, v, v; org.apache.nifi.components.PropertyValue v, v, v, v, v; boolean v, v; org.apache.nifi.components.AllowableValue v, v; org.apache.nifi.components.ValidationContext v; java.util.ArrayList v; org.apache.nifi.processors.standard.MergeContent v; java.lang.String v, v, v, v, v, v, v, v, v, v; org.apache.nifi.components.ValidationResult v, v, v; org.apache.nifi.components.Validator v, v, v; v := @this: org.apache.nifi.processors.standard.MergeContent; v := @parameter: org.apache.nifi.components.ValidationContext; v = new java.util.ArrayList; specialinvoke v.()>(); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = ; v = virtualinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; v = ; v = virtualinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); if v == null goto label; v = ; v = ; v = virtualinvoke v.(); v = interfaceinvoke v.(v, v, v); interfaceinvoke v.(v); label: v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); if v == null goto label; v = ; v = ; v = virtualinvoke v.(); v = interfaceinvoke v.(v, v, v); interfaceinvoke v.(v); label: v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); if v == null goto label; v = ; v = ; v = virtualinvoke v.(); v = interfaceinvoke v.(v, v, v); interfaceinvoke v.(v); label: return v; } private byte[] readContent(java.lang.String) throws java.io.IOException { byte[] v; org.apache.nifi.processors.standard.MergeContent v; java.lang.String[] v; java.lang.String v; java.nio.file.Path v; v := @this: org.apache.nifi.processors.standard.MergeContent; v := @parameter: java.lang.String; v = newarray (java.lang.String)[0]; v = staticinvoke (v, v); v = staticinvoke (v); return v; } protected org.apache.nifi.flowfile.FlowFile preprocessFlowFile(org.apache.nifi.processor.ProcessContext, org.apache.nifi.processor.ProcessSession, org.apache.nifi.flowfile.FlowFile) { org.apache.nifi.processors.standard.MergeContent v; java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.flowfile.FlowFile v, v; org.apache.nifi.processor.ProcessContext v; org.apache.nifi.processor.ProcessSession v; v := @this: org.apache.nifi.processors.standard.MergeContent; v := @parameter: org.apache.nifi.processor.ProcessContext; v := @parameter: org.apache.nifi.processor.ProcessSession; v := @parameter: org.apache.nifi.flowfile.FlowFile; v = v; v = ; v = interfaceinvoke v.(v); if v != null goto label; v = interfaceinvoke v.("segment.count"); if v == null goto label; v = ; v = interfaceinvoke v.("segment.count"); v = interfaceinvoke v.(v, v, v); label: v = ; v = interfaceinvoke v.(v); if v != null goto label; v = interfaceinvoke v.("segment.index"); if v == null goto label; v = ; v = interfaceinvoke v.("segment.index"); v = interfaceinvoke v.(v, v, v); label: v = ; v = interfaceinvoke v.(v); if v != null goto label; v = interfaceinvoke v.("segment.identifier"); if v == null goto label; v = ; v = interfaceinvoke v.("segment.identifier"); v = interfaceinvoke v.(v, v, v); label: return v; } protected java.lang.String getGroupId(org.apache.nifi.processor.ProcessContext, org.apache.nifi.flowfile.FlowFile, org.apache.nifi.processor.ProcessSession) { org.apache.nifi.components.PropertyDescriptor v, v; org.apache.nifi.components.PropertyValue v, v, v; org.apache.nifi.processors.standard.MergeContent v; java.lang.String v, v, v, v, v, v; boolean v; org.apache.nifi.flowfile.FlowFile v; org.apache.nifi.processor.ProcessContext v; org.apache.nifi.processor.ProcessSession v; org.apache.nifi.components.AllowableValue v; v := @this: org.apache.nifi.processors.standard.MergeContent; v := @parameter: org.apache.nifi.processor.ProcessContext; v := @parameter: org.apache.nifi.flowfile.FlowFile; v := @parameter: org.apache.nifi.processor.ProcessSession; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(v); v = interfaceinvoke v.(); if v != null goto label; v = null; goto label; label: v = interfaceinvoke v.(v); label: v = v; if v != null goto label; v = ; v = virtualinvoke v.(); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; v = ; v = interfaceinvoke v.(v); label: return v; } protected void setUpBinManager(org.apache.nifi.processor.util.bin.BinManager, org.apache.nifi.processor.ProcessContext) { org.apache.nifi.processor.ProcessContext v; org.apache.nifi.processor.util.bin.BinManager v; org.apache.nifi.components.AllowableValue v; org.apache.nifi.components.PropertyDescriptor v; org.apache.nifi.components.PropertyValue v; org.apache.nifi.processors.standard.MergeContent v; java.lang.String v, v, v; boolean v; v := @this: org.apache.nifi.processors.standard.MergeContent; v := @parameter: org.apache.nifi.processor.util.bin.BinManager; v := @parameter: org.apache.nifi.processor.ProcessContext; v = ; v = virtualinvoke v.(); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; v = ; virtualinvoke v.(v); goto label; label: virtualinvoke v.(null); label: return; } protected org.apache.nifi.processor.util.bin.BinProcessingResult processBin(org.apache.nifi.processor.util.bin.Bin, org.apache.nifi.processor.ProcessContext) throws org.apache.nifi.processor.exception.ProcessException { org.apache.nifi.processors.standard.MergeContent$MergeBin v; java.lang.Integer v; org.apache.nifi.components.PropertyDescriptor v, v, v; byte v; java.util.Map v, v; org.apache.nifi.components.AllowableValue v; org.apache.nifi.processors.standard.MergeContent$FlowFileStreamMerger v, v, v; org.apache.nifi.processors.standard.MergeContent$TarMerge v; java.lang.Object[] v, v; long v; java.lang.AssertionError v; org.apache.nifi.processor.Relationship v, v, v; java.lang.String 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.MergeContent$BinaryConcatenationMerge v; org.apache.nifi.processor.ProcessSession v; org.apache.nifi.processor.util.bin.BinProcessingResult v; org.apache.nifi.processors.standard.MergeContent$ZipMerge v; org.apache.nifi.flowfile.attributes.CoreAttributes v, v, v, v; org.apache.nifi.components.PropertyValue v, v, v; org.apache.nifi.processors.standard.MergeContent$AvroMerge v; boolean v, v, v, v, v, v, v, v, v; org.apache.nifi.flowfile.FlowFile v, v, v; org.apache.nifi.processor.util.bin.Bin v; java.util.List v, v, v; org.apache.nifi.util.FlowFilePackagerV1 v; org.apache.nifi.util.FlowFilePackagerV2 v; org.apache.nifi.util.FlowFilePackagerV3 v; org.apache.nifi.logging.ComponentLog v, v; org.apache.nifi.processors.standard.MergeContent v; int v, v, v, v, v, v, v; org.apache.nifi.flowfile.attributes.StandardFlowFileMediaType v, v, v; org.apache.nifi.processor.util.bin.EvictionReason v, v; java.util.Iterator v; org.apache.nifi.processor.ProcessContext v; org.apache.nifi.processors.standard.MergeContent$FragmentComparator v; org.apache.nifi.processors.standard.merge.AttributeStrategy v; java.lang.Object v; v := @this: org.apache.nifi.processors.standard.MergeContent; v := @parameter: org.apache.nifi.processor.util.bin.Bin; v := @parameter: org.apache.nifi.processor.ProcessContext; v = new org.apache.nifi.processor.util.bin.BinProcessingResult; specialinvoke v.(boolean)>(1); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = -1; v = virtualinvoke v.(); lookupswitch(v) { case -1458991994: goto label; case -1458991993: goto label; case 82821: goto label; case 88833: goto label; case 2053458: goto label; case 578035134: goto label; case 1444276345: goto label; default: goto label; }; label: v = virtualinvoke v.("TAR"); if v == 0 goto label; v = 0; goto label; label: v = virtualinvoke v.("ZIP"); if v == 0 goto label; v = 1; goto label; label: v = virtualinvoke v.("FlowFile Stream, v3"); if v == 0 goto label; v = 2; goto label; label: v = virtualinvoke v.("FlowFile Stream, v2"); if v == 0 goto label; v = 3; goto label; label: v = virtualinvoke v.("FlowFile Tar, v1"); if v == 0 goto label; v = 4; goto label; label: v = virtualinvoke v.("Binary Concatenation"); if v == 0 goto label; v = 5; goto label; label: v = virtualinvoke v.("Avro"); if v == 0 goto label; v = 6; label: tableswitch(v) { case 0: goto label; case 1: goto label; case 2: goto label; case 3: goto label; case 4: goto label; case 5: goto label; case 6: goto label; default: goto label; }; label: v = new org.apache.nifi.processors.standard.MergeContent$TarMerge; specialinvoke v.(org.apache.nifi.processors.standard.MergeContent)>(v); v = v; goto label; label: v = new org.apache.nifi.processors.standard.MergeContent$ZipMerge; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = virtualinvoke v.(); specialinvoke v.(org.apache.nifi.processors.standard.MergeContent,int)>(v, v); v = v; goto label; label: v = new org.apache.nifi.processors.standard.MergeContent$FlowFileStreamMerger; v = new org.apache.nifi.util.FlowFilePackagerV3; specialinvoke v.()>(); v = ; v = virtualinvoke v.(); specialinvoke v.(org.apache.nifi.processors.standard.MergeContent,org.apache.nifi.util.FlowFilePackager,java.lang.String)>(v, v, v); v = v; goto label; label: v = new org.apache.nifi.processors.standard.MergeContent$FlowFileStreamMerger; v = new org.apache.nifi.util.FlowFilePackagerV2; specialinvoke v.()>(); v = ; v = virtualinvoke v.(); specialinvoke v.(org.apache.nifi.processors.standard.MergeContent,org.apache.nifi.util.FlowFilePackager,java.lang.String)>(v, v, v); v = v; goto label; label: v = new org.apache.nifi.processors.standard.MergeContent$FlowFileStreamMerger; v = new org.apache.nifi.util.FlowFilePackagerV1; specialinvoke v.()>(); v = ; v = virtualinvoke v.(); specialinvoke v.(org.apache.nifi.processors.standard.MergeContent,org.apache.nifi.util.FlowFilePackager,java.lang.String)>(v, v, v); v = v; goto label; label: v = new org.apache.nifi.processors.standard.MergeContent$BinaryConcatenationMerge; specialinvoke v.(org.apache.nifi.processors.standard.MergeContent)>(v); v = v; goto label; label: v = new org.apache.nifi.processors.standard.MergeContent$AvroMerge; specialinvoke v.(org.apache.nifi.processors.standard.MergeContent)>(v); v = v; goto label; label: v = new java.lang.AssertionError; specialinvoke v.()>(); throw v; label: v = staticinvoke (v); v = virtualinvoke v.(); v = virtualinvoke v.(); v = ; v = virtualinvoke v.(); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; v = virtualinvoke v.(); v = specialinvoke v.(v); if v == null goto label; v = interfaceinvoke v.(); if v > 10 goto label; v = virtualinvoke v.(); goto label; label: v = interfaceinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("\u FlowFiles"); label: v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("\u; routing {} to failure"); v = newarray (java.lang.Object)[1]; v[0] = v; interfaceinvoke v.(v, v); v = ; interfaceinvoke v.(v, v); interfaceinvoke v.(); return v; label: v = new org.apache.nifi.processors.standard.MergeContent$FragmentComparator; specialinvoke v.()>(); staticinvoke (v, v); label: v = interfaceinvoke v.(v, v); v = ; v = virtualinvoke v.(); v = interfaceinvoke v.(v); v = interfaceinvoke v.(v); v = ; v = virtualinvoke v.(); v = interfaceinvoke v.(); interfaceinvoke v.(v, v); v = ; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = interfaceinvoke v.(); v = staticinvoke (v); interfaceinvoke v.("merge.count", v); v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.("merge.bin.age", v); v = virtualinvoke v.(); v = virtualinvoke v.(); interfaceinvoke v.("merge.reason", v); v = interfaceinvoke v.(v, v); v = interfaceinvoke v.(); if v >= 10 goto label; v = virtualinvoke v.(); goto label; label: v = interfaceinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("\u FlowFiles"); label: v = virtualinvoke v.(); v = newarray (java.lang.Object)[3]; v[0] = v; v[1] = v; v = virtualinvoke v.(); v[2] = v; interfaceinvoke v.("Merged {} into {}. Reason for merging: {}", v); v = ; interfaceinvoke v.(v, v); v = virtualinvoke v.(); v = ; v = virtualinvoke v.(); v = interfaceinvoke v.(v); interfaceinvoke v.("merge.uuid", v); v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(v); v = ; interfaceinvoke v.(v, v); goto label; label: virtualinvoke v.(0); return v; } private java.lang.String getDefragmentValidationError(java.util.List) { boolean v, v, v, v, v; java.util.List v; org.apache.nifi.processors.standard.MergeContent v; int v, v, v, v, v; java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.util.Iterator v; java.lang.NumberFormatException v; java.lang.Object v; v := @this: org.apache.nifi.processors.standard.MergeContent; v := @parameter: java.util.List; v = interfaceinvoke v.(); if v == 0 goto label; return null; label: v = null; v = null; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = ; v = interfaceinvoke v.(v); v = specialinvoke v.(v); if v != 0 goto label; v = ; v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Cannot Defragment \u because it does not have an integer value for the \u attribute"); return v; label: v = ; v = interfaceinvoke v.(v); v = ; v = interfaceinvoke v.(v); if v == null goto label; v = specialinvoke v.(v); if v != 0 goto label; v = ; v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Cannot Defragment \u because it does not have an integer value for the \u attribute"); return v; label: if v != null goto label; v = v; goto label; label: v = virtualinvoke v.(v); if v != 0 goto label; v = ; v = dynamicinvoke "makeConcatWithConstants" (v, v, v, v) ("Cannot Defragment \u because it is grouped with another FlowFile, and the two have differing values for the \u attribute: \u and \u0001"); return v; label: if v != null goto label; v = ; v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Cannot Defragment FlowFiles with Fragment Identifier \u because no FlowFile arrived with the \u attribute and the expected number of fragments is unknown"); return v; label: v = staticinvoke (v); label: goto label; label: v := @caughtexception; v = ; v = dynamicinvoke "makeConcatWithConstants" (v, v, v) ("Cannot Defragment FlowFiles with Fragment Identifier \u because the \u has a non-integer value of \u0001"); return v; label: v = interfaceinvoke v.(); if v >= v goto label; v = interfaceinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v, v) ("Cannot Defragment FlowFiles with Fragment Identifier \u because the expected number of fragments is \u but found only \u fragments"); return v; label: v = interfaceinvoke v.(); if v <= v goto label; v = interfaceinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v, v) ("Cannot Defragment FlowFiles with Fragment Identifier \u because the expected number of fragments is \u but found \u fragments for this identifier"); return v; label: return null; catch java.lang.NumberFormatException from label to label with label; } private boolean isNumber(java.lang.String) { java.util.regex.Matcher v; org.apache.nifi.processors.standard.MergeContent v; java.lang.String v; java.util.regex.Pattern v; boolean v; v := @this: org.apache.nifi.processors.standard.MergeContent; v := @parameter: java.lang.String; if v != null goto label; return 0; label: v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); return v; } private void removeFlowFileFromSession(org.apache.nifi.processor.ProcessSession, org.apache.nifi.flowfile.FlowFile, org.apache.nifi.processor.ProcessContext) { org.apache.nifi.flowfile.FlowFile v; org.apache.nifi.processor.ProcessContext v; org.apache.nifi.processor.ProcessSession v; org.apache.nifi.logging.ComponentLog v; java.lang.Exception v; org.apache.nifi.components.PropertyDescriptor v; org.apache.nifi.components.PropertyValue v; org.apache.nifi.processors.standard.MergeContent v; java.lang.String v, v; v := @this: org.apache.nifi.processors.standard.MergeContent; v := @parameter: org.apache.nifi.processor.ProcessSession; v := @parameter: org.apache.nifi.flowfile.FlowFile; v := @parameter: org.apache.nifi.processor.ProcessContext; label: interfaceinvoke v.(v); label: goto label; label: v := @caughtexception; v = virtualinvoke v.(); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("Failed to remove merged FlowFile from the session after merge failure during \"\u0001\" merge."); interfaceinvoke v.(v, v); label: return; catch java.lang.Exception from label to label with label; } private java.lang.String getPath(org.apache.nifi.flowfile.FlowFile) { java.lang.String[] v; org.apache.nifi.processors.standard.MergeContent v; int v, v, v; java.lang.String v, v, v, v, v, v; java.nio.file.Path v, v, v; boolean v; org.apache.nifi.flowfile.FlowFile v; org.apache.nifi.flowfile.attributes.CoreAttributes v; v := @this: org.apache.nifi.processors.standard.MergeContent; v := @parameter: org.apache.nifi.flowfile.FlowFile; v = ; v = virtualinvoke v.(); v = interfaceinvoke v.(v); v = newarray (java.lang.String)[0]; v = staticinvoke (v, v); v = interfaceinvoke v.(); if v != 0 goto label; return ""; label: v = "."; v = interfaceinvoke v.(0); v = interfaceinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; v = interfaceinvoke v.(); if v != 1 goto label; v = null; goto label; label: v = interfaceinvoke v.(); v = interfaceinvoke v.(1, v); label: v = v; label: if v != null goto label; v = ""; goto label; label: v = interfaceinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("\u0001/"); label: return v; } private java.lang.String createFilename(java.util.List) { long v; java.util.List v; org.apache.nifi.processors.standard.MergeContent v; int v; java.lang.Object v, v; java.lang.String v, v, v, v, v; org.apache.nifi.flowfile.attributes.CoreAttributes v; v := @this: org.apache.nifi.processors.standard.MergeContent; v := @parameter: java.util.List; v = interfaceinvoke v.(); if v != 1 goto label; v = interfaceinvoke v.(0); v = ; v = virtualinvoke v.(); v = interfaceinvoke v.(v); return v; label: v = interfaceinvoke v.(0); v = ; v = interfaceinvoke v.(v); if v == null goto label; return v; label: v = staticinvoke (); v = staticinvoke (v); return v; } static void () { org.apache.nifi.flowfile.attributes.FragmentAttributes v, v, v, v; org.apache.nifi.components.AllowableValue v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, 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.processor.Relationship v; org.apache.nifi.components.resource.ResourceType v, v, v, v, v, v; org.apache.nifi.expression.ExpressionLanguageScope v, v, v, v, v; org.apache.nifi.components.PropertyDescriptor 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, v, v, v, v, v; org.apache.nifi.components.resource.ResourceType[] 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; org.apache.nifi.components.resource.ResourceCardinality v, v, v; java.util.regex.Pattern v; org.apache.nifi.components.AllowableValue[] 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, v, v; org.apache.nifi.processor.Relationship$Builder v, v, v; v = ; v = virtualinvoke v.(); = v; v = ; v = virtualinvoke v.(); = v; v = ; v = virtualinvoke v.(); = v; v = ; v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.AllowableValue; specialinvoke v.(java.lang.String,java.lang.String,java.lang.String)>("Use First Metadata", "Use First Metadata", "For any input format that supports metadata (Avro, e.g.), the metadata for the first FlowFile in the bin will be set on the output FlowFile."); = v; v = new org.apache.nifi.components.AllowableValue; specialinvoke v.(java.lang.String,java.lang.String,java.lang.String)>("Keep Only Common Metadata", "Keep Only Common Metadata", "For any input format that supports metadata (Avro, e.g.), any FlowFile whose metadata values match those of the first FlowFile, any additional metadata will be dropped but the FlowFile will be merged. Any FlowFile whose metadata values do not match those of the first FlowFile in the bin will not be merged."); = v; v = new org.apache.nifi.components.AllowableValue; specialinvoke v.(java.lang.String,java.lang.String,java.lang.String)>("Ignore Metadata", "Ignore Metadata", "Ignores (does not transfer, compare, etc.) any metadata from a FlowFile whose content supports embedded metadata."); = v; v = new org.apache.nifi.components.AllowableValue; specialinvoke v.(java.lang.String,java.lang.String,java.lang.String)>("Do Not Merge Uncommon Metadata", "Do Not Merge Uncommon Metadata", "For any input format that supports metadata (Avro, e.g.), any FlowFile whose metadata values do not match those of the first FlowFile in the bin will not be merged."); = v; v = new org.apache.nifi.components.AllowableValue; specialinvoke v.(java.lang.String,java.lang.String,java.lang.String)>("Bin-Packing Algorithm", "Bin-Packing Algorithm", "Generates \'bins\' of FlowFiles and fills each bin as full as possible. FlowFiles are placed into a bin based on their size and optionally their attributes (if the property is set)"); = v; v = new org.apache.nifi.components.AllowableValue; specialinvoke v.(java.lang.String,java.lang.String,java.lang.String)>("Defragment", "Defragment", "Combines fragments that are associated by attributes back into a single cohesive FlowFile. If using this strategy, all FlowFiles must have the attributes , , and or alternatively (for backward compatibility purposes) , , and . All FlowFiles with the same value for \"fragment.identifier\" will be grouped together. All FlowFiles in this group must have the same value for the \"fragment.count\" attribute. All FlowFiles in this group must have a unique value for the \"fragment.index\" attribute between 0 and the value of the \"fragment.count\" attribute."); = v; v = new org.apache.nifi.components.AllowableValue; specialinvoke v.(java.lang.String,java.lang.String,java.lang.String)>("Filename", "Filename", "The values of Header, Footer, and Demarcator will be retrieved from the contents of a file"); = v; v = new org.apache.nifi.components.AllowableValue; specialinvoke v.(java.lang.String,java.lang.String,java.lang.String)>("Text", "Text", "The values of Header, Footer, and Demarcator will be specified as property values"); = v; v = new org.apache.nifi.components.AllowableValue; specialinvoke v.(java.lang.String,java.lang.String,java.lang.String)>("Do Not Use Delimiters", "Do Not Use Delimiters", "No Header, Footer, or Demarcator will be used"); = v; v = new org.apache.nifi.components.AllowableValue; specialinvoke v.(java.lang.String,java.lang.String,java.lang.String)>("TAR", "TAR", "A bin of FlowFiles will be combined into a single TAR file. The FlowFiles\' attribute will be used to create a directory in the TAR file if the property is set to true; otherwise, all FlowFiles will be added at the root of the TAR file. If a FlowFile has an attribute named that is 3 characters, each between 0-7, that attribute will be used as the TAR entry\'s \'mode\'."); = v; v = new org.apache.nifi.components.AllowableValue; specialinvoke v.(java.lang.String,java.lang.String,java.lang.String)>("ZIP", "ZIP", "A bin of FlowFiles will be combined into a single ZIP file. The FlowFiles\' attribute will be used to create a directory in the ZIP file if the property is set to true; otherwise, all FlowFiles will be added at the root of the ZIP file. The property indicates the ZIP compression to use."); = v; v = new org.apache.nifi.components.AllowableValue; specialinvoke v.(java.lang.String,java.lang.String,java.lang.String)>("FlowFile Stream, v3", "FlowFile Stream, v3", "A bin of FlowFiles will be combined into a single Version 3 FlowFile Stream"); = v; v = new org.apache.nifi.components.AllowableValue; specialinvoke v.(java.lang.String,java.lang.String,java.lang.String)>("FlowFile Stream, v2", "FlowFile Stream, v2", "A bin of FlowFiles will be combined into a single Version 2 FlowFile Stream"); = v; v = new org.apache.nifi.components.AllowableValue; specialinvoke v.(java.lang.String,java.lang.String,java.lang.String)>("FlowFile Tar, v1", "FlowFile Tar, v1", "A bin of FlowFiles will be combined into a single Version 1 FlowFile Package"); = v; v = new org.apache.nifi.components.AllowableValue; specialinvoke v.(java.lang.String,java.lang.String,java.lang.String)>("Binary Concatenation", "Binary Concatenation", "The contents of all FlowFiles will be concatenated together into a single FlowFile"); = v; v = new org.apache.nifi.components.AllowableValue; specialinvoke v.(java.lang.String,java.lang.String,java.lang.String)>("Avro", "Avro", "The Avro contents of all FlowFiles will be concatenated together into a single FlowFile"); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("Merge Strategy"); v = virtualinvoke v.("Specifies the algorithm used to merge content. The \'Defragment\' algorithm combines fragments that are associated by attributes back into a single cohesive FlowFile. The \'Bin-Packing Algorithm\' generates a FlowFile populated by arbitrarily chosen FlowFiles"); 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.(1); v = virtualinvoke v.("Merge Format"); v = virtualinvoke v.("Determines the format that will be used to merge the content."); v = newarray (org.apache.nifi.components.AllowableValue)[7]; v = ; v[0] = v; v = ; v[1] = v; v = ; v[2] = v; v = ; v[3] = v; v = ; v[4] = v; v = ; v[5] = v; v = ; v[6] = 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.(1); v = virtualinvoke v.("mergecontent-metadata-strategy"); v = virtualinvoke v.