public class org.apache.nifi.processors.standard.TestMergeContent extends java.lang.Object { public void () { org.apache.nifi.processors.standard.TestMergeContent v; v := @this: org.apache.nifi.processors.standard.TestMergeContent; specialinvoke v.()>(); return; } public void testFlowFileLargerThanBin() { byte[] v, v; org.apache.nifi.processors.standard.TestMergeContent v; long v; org.apache.nifi.components.PropertyDescriptor v, v, v, v, v; org.apache.nifi.processor.Relationship v, v, v, v, v, v; org.apache.nifi.util.TestRunner v; org.apache.nifi.processors.standard.MergeContent v; java.lang.String v, v, v; org.apache.nifi.components.AllowableValue v; java.util.List v, v, v; java.lang.Object v, v, v; org.apache.nifi.flowfile.attributes.CoreAttributes v; v := @this: org.apache.nifi.processors.standard.TestMergeContent; v = new org.apache.nifi.processors.standard.MergeContent; specialinvoke v.()>(); v = staticinvoke (v); v = ; v = ; interfaceinvoke v.(v, v); v = ; interfaceinvoke v.(v, "2"); v = ; interfaceinvoke v.(v, "2"); v = ; interfaceinvoke v.(v, "1 KB"); v = ; interfaceinvoke v.(v, "5 KB"); v = newarray (byte)[1026]; interfaceinvoke v.(v); v = newarray (byte)[6144]; interfaceinvoke v.(v); interfaceinvoke v.(2); v = ; interfaceinvoke v.(v, 1); v = ; interfaceinvoke v.(v, 1); v = ; interfaceinvoke v.(v, 0); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); v = ; v = virtualinvoke v.(); v = virtualinvoke v.(v); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); v = virtualinvoke v.("merge.uuid"); staticinvoke (v, v); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); v = virtualinvoke v.(); staticinvoke (6144L, v); interfaceinvoke v.(); return; } public void testSimpleAvroConcat() throws java.io.IOException { byte[] v, v, v, v; java.lang.Integer v, v, v; org.apache.nifi.components.PropertyDescriptor v, v, v; org.apache.nifi.util.TestRunner v; java.util.Map v; org.apache.avro.generic.GenericData$Record v, v, v; boolean v, v, v; org.apache.avro.generic.GenericDatumWriter v; org.apache.avro.Schema v; org.apache.avro.Schema$Parser v; org.apache.nifi.components.AllowableValue v; java.util.List v; org.apache.nifi.processors.standard.TestMergeContent v; java.io.ByteArrayOutputStream v, v, v; org.apache.nifi.processor.Relationship v, v, v, v; org.apache.nifi.processors.standard.MergeContent v; int v; java.lang.String v; java.io.File v; java.lang.Object v; org.apache.nifi.flowfile.attributes.CoreAttributes v; v := @this: org.apache.nifi.processors.standard.TestMergeContent; v = new org.apache.nifi.processors.standard.MergeContent; specialinvoke v.()>(); v = staticinvoke (v); v = ; interfaceinvoke v.(v, "3"); v = ; interfaceinvoke v.(v, "3"); v = ; v = ; interfaceinvoke v.(v, v); v = new org.apache.avro.Schema$Parser; specialinvoke v.()>(); v = new java.io.File; specialinvoke v.(java.lang.String)>("src/test/resources/TestMergeContent/user.avsc"); v = virtualinvoke v.(v); v = new org.apache.avro.generic.GenericData$Record; specialinvoke v.(org.apache.avro.Schema)>(v); interfaceinvoke v.("name", "Alyssa"); v = staticinvoke (256); interfaceinvoke v.("favorite_number", v); v = new org.apache.avro.generic.GenericData$Record; specialinvoke v.(org.apache.avro.Schema)>(v); interfaceinvoke v.("name", "Ben"); v = staticinvoke (7); interfaceinvoke v.("favorite_number", v); interfaceinvoke v.("favorite_color", "red"); v = new org.apache.avro.generic.GenericData$Record; specialinvoke v.(org.apache.avro.Schema)>(v); interfaceinvoke v.("name", "John"); v = staticinvoke (5); interfaceinvoke v.("favorite_number", v); interfaceinvoke v.("favorite_color", "blue"); v = new org.apache.avro.generic.GenericDatumWriter; specialinvoke v.(org.apache.avro.Schema)>(v); v = specialinvoke v.(v, v, v); v = specialinvoke v.(v, v, v); v = specialinvoke v.(v, v, v); v = virtualinvoke v.(); interfaceinvoke v.(v); v = virtualinvoke v.(); interfaceinvoke v.(v); v = virtualinvoke v.(); interfaceinvoke v.(v); interfaceinvoke v.(); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, 1); v = ; interfaceinvoke v.(v, 0); v = ; interfaceinvoke v.(v, 3); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); v = ; v = virtualinvoke v.(); virtualinvoke v.(v, "application/avro-binary"); v = interfaceinvoke v.(v); v = specialinvoke v.(v, v, "name"); v = interfaceinvoke v.(); staticinvoke (3, v); v = interfaceinvoke v.("Alyssa"); staticinvoke (v); v = interfaceinvoke v.("Ben"); staticinvoke (v); v = interfaceinvoke v.("John"); staticinvoke (v); return; } public void testAvroConcatWithDifferentSchemas() throws java.io.IOException { byte[] v, v, v, v, v; java.lang.Integer v, v; org.apache.nifi.components.PropertyDescriptor v, v, v; org.apache.nifi.util.TestRunner v; java.util.Map v, v; org.apache.avro.generic.GenericData$Record v, v, v; boolean v, v, v; org.apache.avro.generic.GenericDatumWriter v; org.apache.avro.Schema v, v; org.apache.avro.Schema$Parser v, v; org.apache.nifi.components.AllowableValue v; java.util.List v, v; org.apache.nifi.processors.standard.TestMergeContent v; java.io.ByteArrayOutputStream v, v, v; org.apache.nifi.processor.Relationship v, v, v, v, v; org.apache.nifi.processors.standard.MergeContent v; int v, v; java.lang.String v; java.io.File v, v; java.lang.Object v, v; org.apache.nifi.flowfile.attributes.CoreAttributes v; v := @this: org.apache.nifi.processors.standard.TestMergeContent; v = new org.apache.nifi.processors.standard.MergeContent; specialinvoke v.()>(); v = staticinvoke (v); v = ; interfaceinvoke v.(v, "3"); v = ; interfaceinvoke v.(v, "3"); v = ; v = ; interfaceinvoke v.(v, v); v = new org.apache.avro.Schema$Parser; specialinvoke v.()>(); v = new java.io.File; specialinvoke v.(java.lang.String)>("src/test/resources/TestMergeContent/user.avsc"); v = virtualinvoke v.(v); v = new org.apache.avro.Schema$Parser; specialinvoke v.()>(); v = new java.io.File; specialinvoke v.(java.lang.String)>("src/test/resources/TestMergeContent/place.avsc"); v = virtualinvoke v.(v); v = new org.apache.avro.generic.GenericData$Record; specialinvoke v.(org.apache.avro.Schema)>(v); interfaceinvoke v.("name", "Alyssa"); v = staticinvoke (256); interfaceinvoke v.("favorite_number", v); v = new org.apache.avro.generic.GenericData$Record; specialinvoke v.(org.apache.avro.Schema)>(v); interfaceinvoke v.("name", "Some Place"); v = new org.apache.avro.generic.GenericData$Record; specialinvoke v.(org.apache.avro.Schema)>(v); interfaceinvoke v.("name", "John"); v = staticinvoke (5); interfaceinvoke v.("favorite_number", v); interfaceinvoke v.("favorite_color", "blue"); v = new org.apache.avro.generic.GenericDatumWriter; specialinvoke v.(org.apache.avro.Schema)>(v); v = specialinvoke v.(v, v, v); v = specialinvoke v.(v, v, v); v = specialinvoke v.(v, v, v); v = virtualinvoke v.(); interfaceinvoke v.(v); v = virtualinvoke v.(); interfaceinvoke v.(v); v = virtualinvoke v.(); interfaceinvoke v.(v); interfaceinvoke v.(); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, 1); v = ; interfaceinvoke v.(v, 1); v = ; interfaceinvoke v.(v, 3); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); v = ; v = virtualinvoke v.(); virtualinvoke v.(v, "application/avro-binary"); v = interfaceinvoke v.(v); v = specialinvoke v.(v, v, "name"); v = interfaceinvoke v.(); staticinvoke (2, v); v = interfaceinvoke v.("Alyssa"); staticinvoke (v); v = interfaceinvoke v.("John"); staticinvoke (v); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); v = interfaceinvoke v.(v); v = specialinvoke v.(v, v, "name"); v = interfaceinvoke v.(); staticinvoke (1, v); v = interfaceinvoke v.("Some Place"); staticinvoke (v); return; } public void testAvroConcatWithDifferentMetadataDoNotMerge() throws java.io.IOException { byte[] v, v, v, v; java.lang.Integer v, v, v; org.apache.nifi.components.PropertyDescriptor v, v, v, v; org.apache.nifi.util.TestRunner v; java.util.Map v; org.apache.avro.generic.GenericData$Record v, v, v; boolean v; org.apache.avro.generic.GenericDatumWriter v; org.apache.avro.Schema v; org.apache.avro.Schema$Parser v; org.apache.nifi.components.AllowableValue v, v; java.util.List v; org.apache.nifi.processors.standard.TestMergeContent v; java.io.ByteArrayOutputStream v, v, v; org.apache.nifi.processors.standard.TestMergeContent$3 v; org.apache.nifi.processor.Relationship v, v, v, v; org.apache.nifi.processors.standard.MergeContent v; int v; java.lang.String v; org.apache.nifi.processors.standard.TestMergeContent$1 v; org.apache.nifi.processors.standard.TestMergeContent$2 v; java.io.File v; java.lang.Object v; org.apache.nifi.flowfile.attributes.CoreAttributes v; v := @this: org.apache.nifi.processors.standard.TestMergeContent; v = new org.apache.nifi.processors.standard.MergeContent; specialinvoke v.()>(); v = staticinvoke (v); v = ; interfaceinvoke v.(v, "3"); v = ; interfaceinvoke v.(v, "3"); v = ; v = ; interfaceinvoke v.(v, v); v = ; v = ; interfaceinvoke v.(v, v); v = new org.apache.avro.Schema$Parser; specialinvoke v.()>(); v = new java.io.File; specialinvoke v.(java.lang.String)>("src/test/resources/TestMergeContent/user.avsc"); v = virtualinvoke v.(v); v = new org.apache.avro.generic.GenericData$Record; specialinvoke v.(org.apache.avro.Schema)>(v); interfaceinvoke v.("name", "Alyssa"); v = staticinvoke (256); interfaceinvoke v.("favorite_number", v); v = new org.apache.nifi.processors.standard.TestMergeContent$1; specialinvoke v.(org.apache.nifi.processors.standard.TestMergeContent)>(v); v = new org.apache.avro.generic.GenericData$Record; specialinvoke v.(org.apache.avro.Schema)>(v); interfaceinvoke v.("name", "Ben"); v = staticinvoke (7); interfaceinvoke v.("favorite_number", v); interfaceinvoke v.("favorite_color", "red"); v = new org.apache.nifi.processors.standard.TestMergeContent$2; specialinvoke v.(org.apache.nifi.processors.standard.TestMergeContent)>(v); v = new org.apache.avro.generic.GenericData$Record; specialinvoke v.(org.apache.avro.Schema)>(v); interfaceinvoke v.("name", "John"); v = staticinvoke (5); interfaceinvoke v.("favorite_number", v); interfaceinvoke v.("favorite_color", "blue"); v = new org.apache.nifi.processors.standard.TestMergeContent$3; specialinvoke v.(org.apache.nifi.processors.standard.TestMergeContent)>(v); v = new org.apache.avro.generic.GenericDatumWriter; specialinvoke v.(org.apache.avro.Schema)>(v); v = specialinvoke v.(v, v, v, v); v = specialinvoke v.(v, v, v, v); v = specialinvoke v.(v, v, v, v); v = virtualinvoke v.(); interfaceinvoke v.(v); v = virtualinvoke v.(); interfaceinvoke v.(v); v = virtualinvoke v.(); interfaceinvoke v.(v); interfaceinvoke v.(); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, 1); v = ; interfaceinvoke v.(v, 2); v = ; interfaceinvoke v.(v, 3); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); v = ; v = virtualinvoke v.(); virtualinvoke v.(v, "application/avro-binary"); v = interfaceinvoke v.(v); v = specialinvoke v.(v, v, "name"); v = interfaceinvoke v.(); staticinvoke (1, v); v = interfaceinvoke v.("Alyssa"); staticinvoke (v); return; } public void testAvroConcatWithDifferentMetadataIgnore() throws java.io.IOException { byte[] v, v, v, v; java.lang.Integer v, v, v; org.apache.nifi.components.PropertyDescriptor v, v, v, v; org.apache.nifi.util.TestRunner v; java.util.Map v; org.apache.avro.generic.GenericData$Record v, v, v; boolean v, v, v; org.apache.avro.generic.GenericDatumWriter v; org.apache.avro.Schema v; org.apache.avro.Schema$Parser v; org.apache.nifi.components.AllowableValue v, v; java.util.List v; org.apache.nifi.processors.standard.TestMergeContent v; java.io.ByteArrayOutputStream v, v, v; org.apache.nifi.processors.standard.TestMergeContent$5 v; org.apache.nifi.processors.standard.TestMergeContent$6 v; org.apache.nifi.processors.standard.TestMergeContent$4 v; org.apache.nifi.processor.Relationship v, v, v, v; org.apache.nifi.processors.standard.MergeContent v; int v; java.lang.String v; java.io.File v; java.lang.Object v; org.apache.nifi.flowfile.attributes.CoreAttributes v; v := @this: org.apache.nifi.processors.standard.TestMergeContent; v = new org.apache.nifi.processors.standard.MergeContent; specialinvoke v.()>(); v = staticinvoke (v); v = ; interfaceinvoke v.(v, "3"); v = ; interfaceinvoke v.(v, "3"); v = ; v = ; interfaceinvoke v.(v, v); v = ; v = ; interfaceinvoke v.(v, v); v = new org.apache.avro.Schema$Parser; specialinvoke v.()>(); v = new java.io.File; specialinvoke v.(java.lang.String)>("src/test/resources/TestMergeContent/user.avsc"); v = virtualinvoke v.(v); v = new org.apache.avro.generic.GenericData$Record; specialinvoke v.(org.apache.avro.Schema)>(v); interfaceinvoke v.("name", "Alyssa"); v = staticinvoke (256); interfaceinvoke v.("favorite_number", v); v = new org.apache.nifi.processors.standard.TestMergeContent$4; specialinvoke v.(org.apache.nifi.processors.standard.TestMergeContent)>(v); v = new org.apache.avro.generic.GenericData$Record; specialinvoke v.(org.apache.avro.Schema)>(v); interfaceinvoke v.("name", "Ben"); v = staticinvoke (7); interfaceinvoke v.("favorite_number", v); interfaceinvoke v.("favorite_color", "red"); v = new org.apache.nifi.processors.standard.TestMergeContent$5; specialinvoke v.(org.apache.nifi.processors.standard.TestMergeContent)>(v); v = new org.apache.avro.generic.GenericData$Record; specialinvoke v.(org.apache.avro.Schema)>(v); interfaceinvoke v.("name", "John"); v = staticinvoke (5); interfaceinvoke v.("favorite_number", v); interfaceinvoke v.("favorite_color", "blue"); v = new org.apache.nifi.processors.standard.TestMergeContent$6; specialinvoke v.(org.apache.nifi.processors.standard.TestMergeContent)>(v); v = new org.apache.avro.generic.GenericDatumWriter; specialinvoke v.(org.apache.avro.Schema)>(v); v = specialinvoke v.(v, v, v, v); v = specialinvoke v.(v, v, v, v); v = specialinvoke v.(v, v, v, v); v = virtualinvoke v.(); interfaceinvoke v.(v); v = virtualinvoke v.(); interfaceinvoke v.(v); v = virtualinvoke v.(); interfaceinvoke v.(v); interfaceinvoke v.(); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, 1); v = ; interfaceinvoke v.(v, 0); v = ; interfaceinvoke v.(v, 3); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); v = ; v = virtualinvoke v.(); virtualinvoke v.(v, "application/avro-binary"); v = interfaceinvoke v.(v); v = specialinvoke v.(v, v, "name"); v = interfaceinvoke v.(); staticinvoke (3, v); v = interfaceinvoke v.("Alyssa"); staticinvoke (v); v = interfaceinvoke v.("Ben"); staticinvoke (v); v = interfaceinvoke v.("John"); staticinvoke (v); return; } public void testAvroConcatWithDifferentMetadataUseFirst() throws java.io.IOException { byte[] v, v, v, v; java.lang.Integer v, v, v; org.apache.nifi.components.PropertyDescriptor v, v, v, v; org.apache.nifi.util.TestRunner v; java.util.Map v; org.apache.avro.generic.GenericData$Record v, v, v; boolean v, v, v; org.apache.avro.generic.GenericDatumWriter v; org.apache.avro.Schema v; org.apache.avro.Schema$Parser v; org.apache.nifi.components.AllowableValue v, v; java.util.List v; org.apache.nifi.processors.standard.TestMergeContent v; java.io.ByteArrayOutputStream v, v, v; org.apache.nifi.processors.standard.TestMergeContent$9 v; org.apache.nifi.processor.Relationship v, v, v, v; org.apache.nifi.processors.standard.MergeContent v; org.apache.nifi.processors.standard.TestMergeContent$7 v; org.apache.nifi.processors.standard.TestMergeContent$8 v; int v; java.lang.String v; java.io.File v; java.lang.Object v; org.apache.nifi.flowfile.attributes.CoreAttributes v; v := @this: org.apache.nifi.processors.standard.TestMergeContent; v = new org.apache.nifi.processors.standard.MergeContent; specialinvoke v.()>(); v = staticinvoke (v); v = ; interfaceinvoke v.(v, "3"); v = ; interfaceinvoke v.(v, "3"); v = ; v = ; interfaceinvoke v.(v, v); v = ; v = ; interfaceinvoke v.(v, v); v = new org.apache.avro.Schema$Parser; specialinvoke v.()>(); v = new java.io.File; specialinvoke v.(java.lang.String)>("src/test/resources/TestMergeContent/user.avsc"); v = virtualinvoke v.(v); v = new org.apache.avro.generic.GenericData$Record; specialinvoke v.(org.apache.avro.Schema)>(v); interfaceinvoke v.("name", "Alyssa"); v = staticinvoke (256); interfaceinvoke v.("favorite_number", v); v = new org.apache.nifi.processors.standard.TestMergeContent$7; specialinvoke v.(org.apache.nifi.processors.standard.TestMergeContent)>(v); v = new org.apache.avro.generic.GenericData$Record; specialinvoke v.(org.apache.avro.Schema)>(v); interfaceinvoke v.("name", "Ben"); v = staticinvoke (7); interfaceinvoke v.("favorite_number", v); interfaceinvoke v.("favorite_color", "red"); v = new org.apache.nifi.processors.standard.TestMergeContent$8; specialinvoke v.(org.apache.nifi.processors.standard.TestMergeContent)>(v); v = new org.apache.avro.generic.GenericData$Record; specialinvoke v.(org.apache.avro.Schema)>(v); interfaceinvoke v.("name", "John"); v = staticinvoke (5); interfaceinvoke v.("favorite_number", v); interfaceinvoke v.("favorite_color", "blue"); v = new org.apache.nifi.processors.standard.TestMergeContent$9; specialinvoke v.(org.apache.nifi.processors.standard.TestMergeContent)>(v); v = new org.apache.avro.generic.GenericDatumWriter; specialinvoke v.(org.apache.avro.Schema)>(v); v = specialinvoke v.(v, v, v, v); v = specialinvoke v.(v, v, v, v); v = specialinvoke v.(v, v, v, v); v = virtualinvoke v.(); interfaceinvoke v.(v); v = virtualinvoke v.(); interfaceinvoke v.(v); v = virtualinvoke v.(); interfaceinvoke v.(v); interfaceinvoke v.(); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, 1); v = ; interfaceinvoke v.(v, 0); v = ; interfaceinvoke v.(v, 3); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); v = ; v = virtualinvoke v.(); virtualinvoke v.(v, "application/avro-binary"); v = interfaceinvoke v.(v); v = specialinvoke v.(v, v, "name"); v = interfaceinvoke v.(); staticinvoke (3, v); v = interfaceinvoke v.("Alyssa"); staticinvoke (v); v = interfaceinvoke v.("Ben"); staticinvoke (v); v = interfaceinvoke v.("John"); staticinvoke (v); return; } public void testAvroConcatWithDifferentMetadataKeepCommon() throws java.io.IOException { byte[] v, v, v, v; java.lang.Integer v, v, v; org.apache.nifi.components.PropertyDescriptor v, v, v, v; org.apache.nifi.util.TestRunner v; java.util.Map v; org.apache.avro.generic.GenericData$Record v, v, v; boolean v, v; org.apache.avro.generic.GenericDatumWriter v; org.apache.avro.Schema v; org.apache.avro.Schema$Parser v; org.apache.nifi.components.AllowableValue v, v; java.util.List v; org.apache.nifi.processors.standard.TestMergeContent$10 v; org.apache.nifi.processors.standard.TestMergeContent$11 v; org.apache.nifi.processors.standard.TestMergeContent$12 v; org.apache.nifi.processors.standard.TestMergeContent v; java.io.ByteArrayOutputStream v, v, v; org.apache.nifi.processor.Relationship v, v, v, v; org.apache.nifi.processors.standard.MergeContent v; int v; java.lang.String v; java.io.File v; java.lang.Object v; org.apache.nifi.flowfile.attributes.CoreAttributes v; v := @this: org.apache.nifi.processors.standard.TestMergeContent; v = new org.apache.nifi.processors.standard.MergeContent; specialinvoke v.()>(); v = staticinvoke (v); v = ; interfaceinvoke v.(v, "3"); v = ; interfaceinvoke v.(v, "3"); v = ; v = ; interfaceinvoke v.(v, v); v = ; v = ; interfaceinvoke v.(v, v); v = new org.apache.avro.Schema$Parser; specialinvoke v.()>(); v = new java.io.File; specialinvoke v.(java.lang.String)>("src/test/resources/TestMergeContent/user.avsc"); v = virtualinvoke v.(v); v = new org.apache.avro.generic.GenericData$Record; specialinvoke v.(org.apache.avro.Schema)>(v); interfaceinvoke v.("name", "Alyssa"); v = staticinvoke (256); interfaceinvoke v.("favorite_number", v); v = new org.apache.nifi.processors.standard.TestMergeContent$10; specialinvoke v.(org.apache.nifi.processors.standard.TestMergeContent)>(v); v = new org.apache.avro.generic.GenericData$Record; specialinvoke v.(org.apache.avro.Schema)>(v); interfaceinvoke v.("name", "Ben"); v = staticinvoke (7); interfaceinvoke v.("favorite_number", v); interfaceinvoke v.("favorite_color", "red"); v = new org.apache.nifi.processors.standard.TestMergeContent$11; specialinvoke v.(org.apache.nifi.processors.standard.TestMergeContent)>(v); v = new org.apache.avro.generic.GenericData$Record; specialinvoke v.(org.apache.avro.Schema)>(v); interfaceinvoke v.("name", "John"); v = staticinvoke (5); interfaceinvoke v.("favorite_number", v); interfaceinvoke v.("favorite_color", "blue"); v = new org.apache.nifi.processors.standard.TestMergeContent$12; specialinvoke v.(org.apache.nifi.processors.standard.TestMergeContent)>(v); v = new org.apache.avro.generic.GenericDatumWriter; specialinvoke v.(org.apache.avro.Schema)>(v); v = specialinvoke v.(v, v, v, v); v = specialinvoke v.(v, v, v, v); v = specialinvoke v.(v, v, v, v); v = virtualinvoke v.(); interfaceinvoke v.(v); v = virtualinvoke v.(); interfaceinvoke v.(v); v = virtualinvoke v.(); interfaceinvoke v.(v); interfaceinvoke v.(); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, 1); v = ; interfaceinvoke v.(v, 1); v = ; interfaceinvoke v.(v, 3); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); v = ; v = virtualinvoke v.(); virtualinvoke v.(v, "application/avro-binary"); v = interfaceinvoke v.(v); v = specialinvoke v.(v, v, "name"); v = interfaceinvoke v.(); staticinvoke (2, v); v = interfaceinvoke v.("Alyssa"); staticinvoke (v); v = interfaceinvoke v.("John"); staticinvoke (v); return; } private java.util.Map getGenericRecordMap(byte[], org.apache.avro.Schema, java.lang.String) throws java.io.IOException { byte[] v; org.apache.avro.Schema v; org.apache.nifi.processors.standard.TestMergeContent v; java.util.HashMap v; org.apache.avro.file.SeekableByteArrayInput v; java.lang.Object v, v; java.lang.String v, v; org.apache.avro.file.DataFileReader v; org.apache.avro.generic.GenericDatumReader v; boolean v; v := @this: org.apache.nifi.processors.standard.TestMergeContent; v := @parameter: byte[]; v := @parameter: org.apache.avro.Schema; v := @parameter: java.lang.String; v = new org.apache.avro.generic.GenericDatumReader; specialinvoke v.(org.apache.avro.Schema)>(v); v = new org.apache.avro.file.SeekableByteArrayInput; specialinvoke v.(byte[])>(v); v = new org.apache.avro.file.DataFileReader; specialinvoke v.(org.apache.avro.file.SeekableInput,org.apache.avro.io.DatumReader)>(v, v); v = new java.util.HashMap; specialinvoke v.()>(); label: v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); v = interfaceinvoke v.(v); v = virtualinvoke v.(); interfaceinvoke v.(v, v); goto label; label: return v; } private java.io.ByteArrayOutputStream serializeAvroRecord(org.apache.avro.Schema, org.apache.avro.generic.GenericRecord, org.apache.avro.io.DatumWriter) throws java.io.IOException { org.apache.avro.generic.GenericRecord v; org.apache.avro.Schema v; org.apache.avro.io.DatumWriter v; org.apache.nifi.processors.standard.TestMergeContent v; java.io.ByteArrayOutputStream v; v := @this: org.apache.nifi.processors.standard.TestMergeContent; v := @parameter: org.apache.avro.Schema; v := @parameter: org.apache.avro.generic.GenericRecord; v := @parameter: org.apache.avro.io.DatumWriter; v = specialinvoke v.(v, v, v, null); return v; } private java.io.ByteArrayOutputStream serializeAvroRecord(org.apache.avro.Schema, org.apache.avro.generic.GenericRecord, org.apache.avro.io.DatumWriter, java.util.Map) throws java.io.IOException { org.apache.avro.generic.GenericRecord v; org.apache.avro.Schema v; org.apache.avro.io.DatumWriter v; org.apache.nifi.processors.standard.TestMergeContent v; java.io.ByteArrayOutputStream v; org.apache.avro.file.DataFileWriter v; java.util.Map v; java.util.function.BiConsumer v; v := @this: org.apache.nifi.processors.standard.TestMergeContent; v := @parameter: org.apache.avro.Schema; v := @parameter: org.apache.avro.generic.GenericRecord; v := @parameter: org.apache.avro.io.DatumWriter; v := @parameter: java.util.Map; v = new java.io.ByteArrayOutputStream; specialinvoke v.()>(); v = new org.apache.avro.file.DataFileWriter; specialinvoke v.(org.apache.avro.io.DatumWriter)>(v); if v == null goto label; virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.(v); label: virtualinvoke v.(v, v); virtualinvoke v.(v); virtualinvoke v.(); return v; } public void testSimpleBinaryConcat() throws java.io.IOException { byte[] v; org.apache.nifi.processors.standard.TestMergeContent v; org.apache.nifi.components.PropertyDescriptor v, v; org.apache.nifi.processor.Relationship v, v, v, v, v; org.apache.nifi.util.TestRunner v; org.apache.nifi.processors.standard.MergeContent v; java.lang.String v, v; org.apache.nifi.components.AllowableValue v; java.util.function.Consumer v; java.util.List v, v; java.util.stream.Stream v; java.lang.Object v; org.apache.nifi.flowfile.attributes.CoreAttributes v; v := @this: org.apache.nifi.processors.standard.TestMergeContent; v = new org.apache.nifi.processors.standard.MergeContent; specialinvoke v.()>(); v = staticinvoke (v); v = ; interfaceinvoke v.(v, "1 sec"); v = ; v = ; interfaceinvoke v.(v, v); specialinvoke v.(v); interfaceinvoke v.(2); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, 1); v = ; interfaceinvoke v.(v, 0); v = ; interfaceinvoke v.(v, 3); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); v = "Hello, World!"; v = virtualinvoke v.("UTF-8"); virtualinvoke v.(v); v = ; v = virtualinvoke v.(); virtualinvoke v.(v, "application/plain-text"); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = staticinvoke (v); interfaceinvoke v.(v); return; } public void testSimpleBinaryConcatSingleBin() { org.apache.nifi.processors.standard.TestMergeContent v; org.apache.nifi.components.AllowableValue v; org.apache.nifi.components.PropertyDescriptor v, v, v; java.util.List v; org.apache.nifi.processor.Relationship v, v, v, v; org.apache.nifi.util.TestRunner v; org.apache.nifi.processors.standard.MergeContent v; java.lang.Object v; java.lang.String v; org.apache.nifi.flowfile.attributes.CoreAttributes v; v := @this: org.apache.nifi.processors.standard.TestMergeContent; v = new org.apache.nifi.processors.standard.MergeContent; specialinvoke v.()>(); v = staticinvoke (v); v = ; interfaceinvoke v.(v, "1 sec"); v = ; v = ; interfaceinvoke v.(v, v); v = ; interfaceinvoke v.(v, "1"); specialinvoke v.(v); interfaceinvoke v.(2); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, 1); v = ; interfaceinvoke v.(v, 0); v = ; interfaceinvoke v.(v, 3); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); virtualinvoke v.("Hello, World!"); v = ; v = virtualinvoke v.(); virtualinvoke v.(v, "application/plain-text"); return; } public void testSimpleBinaryConcatWithTextDelimiters() throws java.io.IOException { byte[] v; org.apache.nifi.processors.standard.TestMergeContent v; org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v; org.apache.nifi.processor.Relationship v, v, v, v; org.apache.nifi.util.TestRunner v; org.apache.nifi.processors.standard.MergeContent v; java.lang.String v, v; org.apache.nifi.components.AllowableValue v, v; java.util.List v; java.lang.Object v; org.apache.nifi.flowfile.attributes.CoreAttributes v; v := @this: org.apache.nifi.processors.standard.TestMergeContent; v = new org.apache.nifi.processors.standard.MergeContent; specialinvoke v.()>(); v = staticinvoke (v); v = ; interfaceinvoke v.(v, "1 sec"); v = ; v = ; interfaceinvoke v.(v, v); v = ; v = ; interfaceinvoke v.(v, v); v = ; interfaceinvoke v.(v, "@"); v = ; interfaceinvoke v.(v, "#"); v = ; interfaceinvoke v.(v, "$"); specialinvoke v.(v); interfaceinvoke v.(2); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, 1); v = ; interfaceinvoke v.(v, 0); v = ; interfaceinvoke v.(v, 3); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); v = "@Hello#, #World!$"; v = virtualinvoke v.("UTF-8"); virtualinvoke v.(v); v = ; v = virtualinvoke v.(); virtualinvoke v.(v, "application/plain-text"); return; } public void testSimpleBinaryConcatWithTextDelimitersHeaderOnly() throws java.io.IOException { byte[] v; org.apache.nifi.processors.standard.TestMergeContent v; org.apache.nifi.components.PropertyDescriptor v, v, v, v; org.apache.nifi.processor.Relationship v, v, v, v; org.apache.nifi.util.TestRunner v; org.apache.nifi.processors.standard.MergeContent v; java.lang.String v, v; org.apache.nifi.components.AllowableValue v, v; java.util.List v; java.lang.Object v; org.apache.nifi.flowfile.attributes.CoreAttributes v; v := @this: org.apache.nifi.processors.standard.TestMergeContent; v = new org.apache.nifi.processors.standard.MergeContent; specialinvoke v.()>(); v = staticinvoke (v); v = ; interfaceinvoke v.(v, "1 sec"); v = ; v = ; interfaceinvoke v.(v, v); v = ; v = ; interfaceinvoke v.(v, v); v = ; interfaceinvoke v.(v, "@"); specialinvoke v.(v); interfaceinvoke v.(2); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, 1); v = ; interfaceinvoke v.(v, 0); v = ; interfaceinvoke v.(v, 3); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); v = "@Hello, World!"; v = virtualinvoke v.("UTF-8"); virtualinvoke v.(v); v = ; v = virtualinvoke v.(); virtualinvoke v.(v, "application/plain-text"); return; } public void testSimpleBinaryConcatWithFileDelimiters() throws java.io.IOException, java.lang.InterruptedException { byte[] v, v, v, v; org.apache.nifi.processors.standard.TestMergeContent v; java.util.HashMap v; org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v; org.apache.nifi.processor.Relationship v, v, v, v; org.apache.nifi.util.TestRunner v; org.apache.nifi.processors.standard.MergeContent v; java.lang.String v, v, v, v, v, v; org.apache.nifi.components.AllowableValue v, v; java.util.List v; java.lang.Object v; org.apache.nifi.flowfile.attributes.CoreAttributes v, v; v := @this: org.apache.nifi.processors.standard.TestMergeContent; v = new org.apache.nifi.processors.standard.MergeContent; specialinvoke v.()>(); v = staticinvoke (v); v = ; interfaceinvoke v.(v, "1 sec"); v = ; v = ; interfaceinvoke v.(v, v); v = ; v = ; interfaceinvoke v.(v, v); v = ; interfaceinvoke v.(v, "${header}"); v = ; interfaceinvoke v.(v, "${demarcator}"); v = ; interfaceinvoke v.(v, "${footer}"); v = new java.util.HashMap; specialinvoke v.()>(); v = ; v = virtualinvoke v.(); interfaceinvoke v.(v, "application/plain-text"); interfaceinvoke v.("header", "src/test/resources/TestMergeContent/head"); interfaceinvoke v.("demarcator", "src/test/resources/TestMergeContent/demarcate"); interfaceinvoke v.("footer", "src/test/resources/TestMergeContent/foot"); v = "Hello"; v = virtualinvoke v.("UTF-8"); interfaceinvoke v.(v, v); v = ", "; v = virtualinvoke v.("UTF-8"); interfaceinvoke v.(v, v); v = "World!"; v = virtualinvoke v.("UTF-8"); interfaceinvoke v.(v, v); interfaceinvoke v.(2); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, 1); v = ; interfaceinvoke v.(v, 0); v = ; interfaceinvoke v.(v, 3); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); v = "(|)Hello***, ***World!___"; v = virtualinvoke v.("UTF-8"); virtualinvoke v.(v); v = ; v = virtualinvoke v.(); virtualinvoke v.(v, "application/plain-text"); return; } public void testTextDelimitersValidation() { org.apache.nifi.processors.standard.TestMergeContent v; org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v; java.util.HashSet v; org.apache.nifi.util.TestRunner v; org.apache.nifi.processors.standard.MergeContent v; int v; java.lang.String v; boolean v, v, v; java.util.Iterator v; java.util.Collection v; org.apache.nifi.processor.ProcessContext v; org.apache.nifi.components.AllowableValue v, v; java.lang.Object v; v := @this: org.apache.nifi.processors.standard.TestMergeContent; v = new org.apache.nifi.processors.standard.MergeContent; specialinvoke v.()>(); v = staticinvoke (v); v = ; interfaceinvoke v.(v, "1 sec"); v = ; v = ; interfaceinvoke v.(v, v); v = ; v = ; interfaceinvoke v.(v, v); v = ; interfaceinvoke v.(v, ""); v = ; interfaceinvoke v.(v, ""); v = ; interfaceinvoke v.(v, ""); v = new java.util.HashSet; specialinvoke v.()>(); v = v; v = interfaceinvoke v.(); v = v instanceof org.apache.nifi.util.MockProcessContext; if v == 0 goto label; v = virtualinvoke v.(); label: v = interfaceinvoke v.(); staticinvoke (3, v); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.("cannot be empty"); staticinvoke (v); goto label; label: return; } public void testFileDelimitersValidation() { org.apache.nifi.processors.standard.TestMergeContent v; org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v; java.util.HashSet v; org.apache.nifi.util.TestRunner v; org.apache.nifi.processors.standard.MergeContent v; int v; java.lang.String v, v, v; boolean v, v, v; java.util.Iterator v; java.util.Collection v; org.apache.nifi.processor.ProcessContext v; org.apache.nifi.components.AllowableValue v, v; java.io.File v; java.lang.Object v; v := @this: org.apache.nifi.processors.standard.TestMergeContent; v = new org.apache.nifi.processors.standard.MergeContent; specialinvoke v.()>(); v = staticinvoke (v); v = ; interfaceinvoke v.(v, "1 sec"); v = ; v = ; interfaceinvoke v.(v, v); v = ; v = ; interfaceinvoke v.(v, v); v = ; interfaceinvoke v.(v, "src/test/resources/TestMergeContent/does_not_exist"); v = ; interfaceinvoke v.(v, "src/test/resources/TestMergeContent/does_not_exist"); v = ; interfaceinvoke v.(v, "src/test/resources/TestMergeContent/does_not_exist"); v = new java.util.HashSet; specialinvoke v.()>(); v = v; v = interfaceinvoke v.(); v = v instanceof org.apache.nifi.util.MockProcessContext; if v == 0 goto label; v = virtualinvoke v.(); label: v = interfaceinvoke v.(); staticinvoke (3, v); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = new java.io.File; specialinvoke v.(java.lang.String)>("src/test/resources/TestMergeContent/does_not_exist"); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("is invalid because File \u does not exist"); v = virtualinvoke v.(v); staticinvoke (v); goto label; label: return; } public void testMimeTypeIsOctetStreamIfConflictingWithBinaryConcat() throws java.io.IOException { byte[] v, v; org.apache.nifi.processors.standard.TestMergeContent v; java.util.HashMap v; org.apache.nifi.components.PropertyDescriptor v, v; org.apache.nifi.processor.Relationship v, v, v, v; org.apache.nifi.util.TestRunner v; org.apache.nifi.processors.standard.MergeContent v; java.lang.String v, v, v; org.apache.nifi.components.AllowableValue v; java.util.List v; java.lang.Object v; org.apache.nifi.flowfile.attributes.CoreAttributes v, v; v := @this: org.apache.nifi.processors.standard.TestMergeContent; v = new org.apache.nifi.processors.standard.MergeContent; specialinvoke v.()>(); v = staticinvoke (v); v = ; interfaceinvoke v.(v, "1 sec"); v = ; v = ; interfaceinvoke v.(v, v); specialinvoke v.(v); v = new java.util.HashMap; specialinvoke v.()>(); v = ; v = virtualinvoke v.(); interfaceinvoke v.(v, "application/zip"); v = newarray (byte)[0]; interfaceinvoke v.(v, v); interfaceinvoke v.(2); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, 1); v = ; interfaceinvoke v.(v, 0); v = ; interfaceinvoke v.(v, 4); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); v = "Hello, World!"; v = virtualinvoke v.("UTF-8"); virtualinvoke v.(v); v = ; v = virtualinvoke v.(); virtualinvoke v.(v, "application/octet-stream"); return; } public void testOldestBinIsExpired() { byte[] v, v, v; org.apache.nifi.processors.standard.TestMergeContent v; java.util.HashMap v; org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v; org.apache.nifi.processor.Relationship v, v, v, v, v, v; org.apache.nifi.util.TestRunner v; org.apache.nifi.processors.standard.MergeContent v; int v, v; java.lang.String v; org.apache.nifi.components.AllowableValue v; v := @this: org.apache.nifi.processors.standard.TestMergeContent; v = new org.apache.nifi.processors.standard.MergeContent; specialinvoke v.()>(); v = staticinvoke (v); v = ; interfaceinvoke v.(v, "1 day"); v = ; interfaceinvoke v.(v, "50"); v = ; interfaceinvoke v.(v, "10"); v = ; interfaceinvoke v.(v, "10"); v = ; v = ; interfaceinvoke v.(v, v); v = ; interfaceinvoke v.(v, "correlationId"); v = new java.util.HashMap; specialinvoke v.()>(); v = 0; label: if v >= 49 goto label; v = staticinvoke (v); interfaceinvoke v.("correlationId", v); v = 0; label: if v >= 5 goto label; v = newarray (byte)[0]; interfaceinvoke v.(v, v); v = v + 1; goto label; label: v = v + 1; goto label; label: interfaceinvoke v.(); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, 0); v = ; interfaceinvoke v.(v, 0); v = ; interfaceinvoke v.(v, 0); interfaceinvoke v.("correlationId"); interfaceinvoke v.(); interfaceinvoke v.(1, 0, 1); v = newarray (byte)[0]; interfaceinvoke v.(v, v); interfaceinvoke v.("correlationId", "abc"); v = newarray (byte)[0]; interfaceinvoke v.(v, v); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, 1); v = ; interfaceinvoke v.(v, 0); v = ; interfaceinvoke v.(v, 5); return; } public void testSimpleBinaryConcatWaitsForMin() { org.apache.nifi.processors.standard.TestMergeContent v; org.apache.nifi.components.AllowableValue v; org.apache.nifi.components.PropertyDescriptor v, v; org.apache.nifi.processor.Relationship v, v, v; org.apache.nifi.util.TestRunner v; org.apache.nifi.processors.standard.MergeContent v; v := @this: org.apache.nifi.processors.standard.TestMergeContent; v = new org.apache.nifi.processors.standard.MergeContent; specialinvoke v.()>(); v = staticinvoke (v); v = ; v = ; interfaceinvoke v.(v, v); v = ; interfaceinvoke v.(v, "20 KB"); specialinvoke v.(v); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, 0); v = ; interfaceinvoke v.(v, 0); v = ; interfaceinvoke v.(v, 0); return; } public void testZip() throws java.io.IOException { java.lang.Throwable v, v; byte[] v, v, v, v, v, v, v; java.util.zip.ZipInputStream v; org.apache.nifi.processors.standard.TestMergeContent v; org.apache.nifi.components.PropertyDescriptor v, v; java.io.ByteArrayInputStream v; org.apache.nifi.processor.Relationship v, v, v, v; org.apache.nifi.util.TestRunner v; org.apache.nifi.processors.standard.MergeContent v; java.lang.String v, v, v, v; java.util.zip.ZipEntry v; org.apache.nifi.components.AllowableValue v; java.util.List v; java.lang.Object v; org.apache.nifi.flowfile.attributes.CoreAttributes v; v := @this: org.apache.nifi.processors.standard.TestMergeContent; v = new org.apache.nifi.processors.standard.MergeContent; specialinvoke v.()>(); v = staticinvoke (v); v = ; interfaceinvoke v.(v, "1 sec"); v = ; v = ; interfaceinvoke v.(v, v); specialinvoke v.(v); interfaceinvoke v.(2); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, 1); v = ; interfaceinvoke v.(v, 0); v = ; interfaceinvoke v.(v, 3); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); v = new java.io.ByteArrayInputStream; v = interfaceinvoke v.(v); specialinvoke v.(byte[])>(v); label: v = new java.util.zip.ZipInputStream; specialinvoke v.(java.io.InputStream)>(v); label: v = virtualinvoke v.(); staticinvoke (v); v = staticinvoke (v); v = "Hello"; v = virtualinvoke v.("UTF-8"); staticinvoke (v, v); virtualinvoke v.(); v = staticinvoke (v); v = ", "; v = virtualinvoke v.("UTF-8"); staticinvoke (v, v); virtualinvoke v.(); v = staticinvoke (v); v = "World!"; v = virtualinvoke v.("UTF-8"); staticinvoke (v, v); label: virtualinvoke v.(); goto label; label: v := @caughtexception; throw v; label: virtualinvoke v.(); goto label; label: v := @caughtexception; throw v; label: v = ; v = virtualinvoke v.(); virtualinvoke v.(v, "application/zip"); return; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; } public void testZipException() throws java.io.IOException { byte[] v, v, v; org.apache.nifi.processors.standard.TestMergeContent v; java.util.HashMap v; org.apache.nifi.components.PropertyDescriptor v, v; org.apache.nifi.processor.Relationship v, v, v; org.apache.nifi.util.TestRunner v; org.apache.nifi.processors.standard.MergeContent v; java.lang.String v, v, v, v; org.apache.nifi.components.AllowableValue v; org.apache.nifi.flowfile.attributes.CoreAttributes v; v := @this: org.apache.nifi.processors.standard.TestMergeContent; v = new org.apache.nifi.processors.standard.MergeContent; specialinvoke v.()>(); v = staticinvoke (v); v = ; interfaceinvoke v.(v, "1 sec"); v = ; v = ; interfaceinvoke v.(v, v); v = new java.util.HashMap; specialinvoke v.()>(); v = ; v = virtualinvoke v.(); interfaceinvoke v.(v, "application/plain-text"); interfaceinvoke v.("filename", "duplicate-filename.txt"); v = "Hello"; v = virtualinvoke v.("UTF-8"); interfaceinvoke v.(v, v); v = ", "; v = virtualinvoke v.("UTF-8"); interfaceinvoke v.(v, v); v = "World!"; v = virtualinvoke v.("UTF-8"); interfaceinvoke v.(v, v); interfaceinvoke v.(2); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, 1); v = ; interfaceinvoke v.(v, 2); v = ; interfaceinvoke v.(v, 3); return; } public void testTar() throws java.io.IOException { byte[] v, v, v, v, v, v, v, v, v, v; org.apache.nifi.components.PropertyDescriptor v, v; java.io.ByteArrayInputStream v; org.apache.nifi.util.TestRunner v; org.apache.nifi.components.AllowableValue v; java.util.List v; java.lang.Throwable v, v; org.apache.nifi.processors.standard.TestMergeContent v; org.apache.commons.compress.archivers.ArchiveEntry v, v, v; org.apache.commons.compress.archivers.tar.TarArchiveInputStream v; java.util.HashMap v; org.apache.nifi.processor.Relationship v, v, v, v; org.apache.nifi.processors.standard.MergeContent v; java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.lang.Object v; org.apache.nifi.flowfile.attributes.CoreAttributes v, v, v, v, v; v := @this: org.apache.nifi.processors.standard.TestMergeContent; v = new org.apache.nifi.processors.standard.MergeContent; specialinvoke v.()>(); v = staticinvoke (v); v = ; interfaceinvoke v.(v, "1 sec"); v = ; v = ; interfaceinvoke v.(v, v); v = new java.util.HashMap; specialinvoke v.()>(); v = ; v = virtualinvoke v.(); interfaceinvoke v.(v, "application/plain-text"); v = ; v = virtualinvoke v.(); interfaceinvoke v.(v, "AShortFileName"); v = "Hello"; v = virtualinvoke v.("UTF-8"); interfaceinvoke v.(v, v); v = ; v = virtualinvoke v.(); interfaceinvoke v.(v, "ALongerrrFileName"); v = ", "; v = virtualinvoke v.("UTF-8"); interfaceinvoke v.(v, v); v = ; v = virtualinvoke v.(); interfaceinvoke v.(v, "AReallyLongggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggFileName"); v = "World!"; v = virtualinvoke v.("UTF-8"); interfaceinvoke v.(v, v); interfaceinvoke v.(2); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, 1); v = ; interfaceinvoke v.(v, 0); v = ; interfaceinvoke v.(v, 3); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); v = new java.io.ByteArrayInputStream; v = interfaceinvoke v.(v); specialinvoke v.(byte[])>(v); label: v = new org.apache.commons.compress.archivers.tar.TarArchiveInputStream; specialinvoke v.(java.io.InputStream)>(v); label: v = virtualinvoke v.(); staticinvoke (v); v = interfaceinvoke v.(); staticinvoke ("AShortFileName", v); v = staticinvoke (v); v = "Hello"; v = virtualinvoke v.("UTF-8"); staticinvoke (v, v); v = virtualinvoke v.(); v = interfaceinvoke v.(); staticinvoke ("ALongerrrFileName", v); v = staticinvoke (v); v = ", "; v = virtualinvoke v.("UTF-8"); staticinvoke (v, v); v = virtualinvoke v.(); v = interfaceinvoke v.(); staticinvoke ("AReallyLongggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggFileName", v); v = staticinvoke (v); v = "World!"; v = virtualinvoke v.("UTF-8"); staticinvoke (v, v); label: virtualinvoke v.(); goto label; label: v := @caughtexception; throw v; label: virtualinvoke v.(); goto label; label: v := @caughtexception; throw v; label: v = ; v = virtualinvoke v.(); virtualinvoke v.(v, "application/tar"); return; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; } public void testFlowFileStream() throws java.io.IOException { org.apache.nifi.processors.standard.TestMergeContent v; java.lang.String[] v, v; java.util.HashMap v; org.apache.nifi.components.PropertyDescriptor v, v, v, v; org.apache.nifi.processor.Relationship v, v, v, v; org.apache.nifi.util.TestRunner v; org.apache.nifi.processors.standard.MergeContent v; org.apache.nifi.flowfile.attributes.StandardFlowFileMediaType v; java.lang.String v, v; java.nio.file.Path v, v; org.apache.nifi.components.AllowableValue v; java.util.List v; java.lang.Object v; org.apache.nifi.flowfile.attributes.CoreAttributes v; v := @this: org.apache.nifi.processors.standard.TestMergeContent; v = new org.apache.nifi.processors.standard.MergeContent; specialinvoke v.()>(); v = staticinvoke (v); v = ; interfaceinvoke v.(v, "1 sec"); v = ; interfaceinvoke v.(v, "2"); v = ; interfaceinvoke v.(v, "2"); v = ; v = ; interfaceinvoke v.(v, v); v = new java.util.HashMap; specialinvoke v.()>(); interfaceinvoke v.("path", "folder"); v = newarray (java.lang.String)[0]; v = staticinvoke ("src/test/resources/TestUnpackContent/folder/cal.txt", v); interfaceinvoke v.(v, v); v = newarray (java.lang.String)[0]; v = staticinvoke ("src/test/resources/TestUnpackContent/folder/date.txt", v); interfaceinvoke v.(v, v); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, 1); v = ; interfaceinvoke v.(v, 0); v = ; interfaceinvoke v.(v, 2); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); v = ; v = virtualinvoke v.(); v = ; v = virtualinvoke v.(); virtualinvoke v.(v, v); return; } public void testDefragment() throws java.io.IOException { byte[] v, v, v, v, v; org.apache.nifi.processors.standard.TestMergeContent v; java.util.HashMap v; org.apache.nifi.components.PropertyDescriptor v, v; org.apache.nifi.processor.Relationship v, v; org.apache.nifi.util.TestRunner v; org.apache.nifi.processors.standard.MergeContent v; java.lang.String v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.components.AllowableValue v; java.util.List v; java.lang.Object v; v := @this: org.apache.nifi.processors.standard.TestMergeContent; v = new org.apache.nifi.processors.standard.MergeContent; specialinvoke v.()>(); v = staticinvoke (v); v = ; v = ; interfaceinvoke v.(v, v); v = ; interfaceinvoke v.(v, "1 min"); v = new java.util.HashMap; specialinvoke v.()>(); v = ; interfaceinvoke v.(v, "1"); v = ; interfaceinvoke v.(v, "4"); v = ; interfaceinvoke v.(v, "1"); v = "A Man "; v = virtualinvoke v.("UTF-8"); interfaceinvoke v.(v, v); v = ; interfaceinvoke v.(v, "2"); v = "A Plan "; v = virtualinvoke v.("UTF-8"); interfaceinvoke v.(v, v); v = ; interfaceinvoke v.(v, "3"); v = "A Canal "; v = virtualinvoke v.("UTF-8"); interfaceinvoke v.(v, v); v = ; interfaceinvoke v.(v, "4"); v = "Panama"; v = virtualinvoke v.("UTF-8"); interfaceinvoke v.(v, v); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, 1); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); v = "A Man A Plan A Canal Panama"; v = virtualinvoke v.("UTF-8"); virtualinvoke v.(v); return; } public void testDefragmentWithFragmentCountOnLastFragmentOnly() throws java.io.IOException { byte[] v, v, v, v, v; org.apache.nifi.processors.standard.TestMergeContent v; java.util.HashMap v; org.apache.nifi.components.PropertyDescriptor v, v; org.apache.nifi.processor.Relationship v, v; org.apache.nifi.util.TestRunner v; org.apache.nifi.processors.standard.MergeContent v; java.lang.String v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.components.AllowableValue v; java.util.List v; java.lang.Object v; v := @this: org.apache.nifi.processors.standard.TestMergeContent; v = new org.apache.nifi.processors.standard.MergeContent; specialinvoke v.()>(); v = staticinvoke (v); v = ; v = ; interfaceinvoke v.(v, v); v = ; interfaceinvoke v.(v, "1 min"); v = new java.util.HashMap; specialinvoke v.()>(); v = ; interfaceinvoke v.(v, "1"); v = ; interfaceinvoke v.(v, "1"); v = "A Man "; v = virtualinvoke v.("UTF-8"); interfaceinvoke v.(v, v); v = ; interfaceinvoke v.(v, "2"); v = "A Plan "; v = virtualinvoke v.("UTF-8"); interfaceinvoke v.(v, v); v = ; interfaceinvoke v.(v, "3"); v = "A Canal "; v = virtualinvoke v.("UTF-8"); interfaceinvoke v.(v, v); v = ; interfaceinvoke v.(v, "4"); v = ; interfaceinvoke v.(v, "4"); v = "Panama"; v = virtualinvoke v.("UTF-8"); interfaceinvoke v.(v, v); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, 1); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); v = "A Man A Plan A Canal Panama"; v = virtualinvoke v.("UTF-8"); virtualinvoke v.(v); return; } public void testDefragmentWithFragmentCountOnMiddleFragment() throws java.io.IOException { byte[] v, v, v, v; org.apache.nifi.processors.standard.TestMergeContent v; org.apache.nifi.components.PropertyDescriptor v, v; org.apache.nifi.processor.Relationship v, v; org.apache.nifi.util.TestRunner v; org.apache.nifi.processors.standard.MergeContent v; java.lang.String v, v, v, v; org.apache.nifi.components.AllowableValue v; java.util.List v; java.lang.Object v; org.apache.nifi.processors.standard.TestMergeContent$14 v; org.apache.nifi.processors.standard.TestMergeContent$15 v; org.apache.nifi.processors.standard.TestMergeContent$13 v; v := @this: org.apache.nifi.processors.standard.TestMergeContent; v = new org.apache.nifi.processors.standard.MergeContent; specialinvoke v.()>(); v = staticinvoke (v); v = ; v = ; interfaceinvoke v.(v, v); v = ; interfaceinvoke v.(v, "1 min"); v = "Fragment 1 without count "; v = virtualinvoke v.("UTF-8"); v = new org.apache.nifi.processors.standard.TestMergeContent$13; specialinvoke v.(org.apache.nifi.processors.standard.TestMergeContent)>(v); interfaceinvoke v.(v, v); v = "Fragment 2 with count "; v = virtualinvoke v.("UTF-8"); v = new org.apache.nifi.processors.standard.TestMergeContent$14; specialinvoke v.(org.apache.nifi.processors.standard.TestMergeContent)>(v); interfaceinvoke v.(v, v); v = "Fragment 3 without count"; v = virtualinvoke v.("UTF-8"); v = new org.apache.nifi.processors.standard.TestMergeContent$15; specialinvoke v.(org.apache.nifi.processors.standard.TestMergeContent)>(v); interfaceinvoke v.(v, v); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, 1); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); v = "Fragment 1 without count Fragment 2 with count Fragment 3 without count"; v = virtualinvoke v.("UTF-8"); virtualinvoke v.(v); return; } public void testDefragmentWithDifferentFragmentCounts() throws java.io.IOException { byte[] v, v, v; org.apache.nifi.processors.standard.TestMergeContent v; org.apache.nifi.components.PropertyDescriptor v, v; org.apache.nifi.processor.Relationship v, v, v; org.apache.nifi.util.TestRunner v; org.apache.nifi.processors.standard.MergeContent v; java.lang.String v, v, v; org.apache.nifi.components.AllowableValue v; org.apache.nifi.processors.standard.TestMergeContent$18 v; org.apache.nifi.processors.standard.TestMergeContent$16 v; org.apache.nifi.processors.standard.TestMergeContent$17 v; v := @this: org.apache.nifi.processors.standard.TestMergeContent; v = new org.apache.nifi.processors.standard.MergeContent; specialinvoke v.()>(); v = staticinvoke (v); v = ; v = ; interfaceinvoke v.(v, v); v = ; interfaceinvoke v.(v, "1 min"); v = "Fragment 1 with count "; v = virtualinvoke v.("UTF-8"); v = new org.apache.nifi.processors.standard.TestMergeContent$16; specialinvoke v.(org.apache.nifi.processors.standard.TestMergeContent)>(v); interfaceinvoke v.(v, v); v = "Fragment 2 with count "; v = virtualinvoke v.("UTF-8"); v = new org.apache.nifi.processors.standard.TestMergeContent$17; specialinvoke v.(org.apache.nifi.processors.standard.TestMergeContent)>(v); interfaceinvoke v.(v, v); v = "Fragment 3 without count"; v = virtualinvoke v.("UTF-8"); v = new org.apache.nifi.processors.standard.TestMergeContent$18; specialinvoke v.(org.apache.nifi.processors.standard.TestMergeContent)>(v); interfaceinvoke v.(v, v); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, 0); v = ; interfaceinvoke v.(v, 3); v = ; interfaceinvoke v.(v, 0); return; } public void testDefragmentDuplicateFragment() throws java.io.IOException, java.lang.InterruptedException { byte[] v, v, v, v, v, v; org.apache.nifi.components.PropertyDescriptor v, v; org.apache.nifi.util.TestRunner v; org.apache.nifi.components.AllowableValue v; java.util.List v; org.apache.nifi.processors.standard.TestMergeContent v; java.util.HashMap v; org.apache.nifi.processor.Relationship v, v, v, v, v; org.apache.nifi.processors.standard.MergeContent v; java.lang.String v, v, v, v, v, v, v, v, v, v, v, v; java.lang.Object v; v := @this: org.apache.nifi.processors.standard.TestMergeContent; v = new org.apache.nifi.processors.standard.MergeContent; specialinvoke v.()>(); v = staticinvoke (v); v = ; v = ; interfaceinvoke v.(v, v); v = ; interfaceinvoke v.(v, "1 sec"); v = new java.util.HashMap; specialinvoke v.()>(); v = ; interfaceinvoke v.(v, "1"); v = ; interfaceinvoke v.(v, "4"); v = ; interfaceinvoke v.(v, "1"); v = "A Man "; v = virtualinvoke v.("UTF-8"); interfaceinvoke v.(v, v); v = ; interfaceinvoke v.(v, "2"); v = "A Plan "; v = virtualinvoke v.("UTF-8"); interfaceinvoke v.(v, v); v = "A Plan "; v = virtualinvoke v.("UTF-8"); interfaceinvoke v.(v, v); v = ; interfaceinvoke v.(v, "3"); v = "A Canal "; v = virtualinvoke v.("UTF-8"); interfaceinvoke v.(v, v); v = ; interfaceinvoke v.(v, "4"); v = "Panama"; v = virtualinvoke v.("UTF-8"); interfaceinvoke v.(v, v); interfaceinvoke v.(1, 0); v = ; interfaceinvoke v.(v, 0); v = ; interfaceinvoke v.(v, 1); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); v = "A Man A Plan A Canal Panama"; v = virtualinvoke v.("UTF-8"); virtualinvoke v.(v); interfaceinvoke v.(); staticinvoke (1100L); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, 1); v = ; interfaceinvoke v.(v, 0); return; } public void testDefragmentWithTooManyFragments() throws java.io.IOException { byte[] v, v, v, v, v; org.apache.nifi.processors.standard.TestMergeContent v; java.util.HashMap v; org.apache.nifi.components.PropertyDescriptor v, v; org.apache.nifi.processor.Relationship v, v, v; org.apache.nifi.util.TestRunner v; org.apache.nifi.processors.standard.MergeContent v; java.lang.String v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.components.AllowableValue v; java.util.List v; java.lang.Object v; v := @this: org.apache.nifi.processors.standard.TestMergeContent; v = new org.apache.nifi.processors.standard.MergeContent; specialinvoke v.()>(); v = staticinvoke (v); v = ; v = ; interfaceinvoke v.(v, v); v = ; interfaceinvoke v.(v, "3"); v = new java.util.HashMap; specialinvoke v.()>(); v = ; interfaceinvoke v.(v, "1"); v = ; interfaceinvoke v.(v, "4"); v = ; interfaceinvoke v.(v, "1"); v = "A Man "; v = virtualinvoke v.("UTF-8"); interfaceinvoke v.(v, v); v = ; interfaceinvoke v.(v, "2"); v = "A Plan "; v = virtualinvoke v.("UTF-8"); interfaceinvoke v.(v, v); v = ; interfaceinvoke v.(v, "3"); v = "A Canal "; v = virtualinvoke v.("UTF-8"); interfaceinvoke v.(v, v); v = ; interfaceinvoke v.(v, "4"); v = "Panama"; v = virtualinvoke v.("UTF-8"); interfaceinvoke v.(v, v); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, 0); v = ; interfaceinvoke v.(v, 1); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); v = "A Man A Plan A Canal Panama"; v = virtualinvoke v.("UTF-8"); virtualinvoke v.(v); return; } public void testDefragmentWithTooFewFragments() throws java.io.IOException { byte[] v, v, v, v; org.apache.nifi.processors.standard.TestMergeContent v; java.util.HashMap v; org.apache.nifi.components.PropertyDescriptor v, v; org.apache.nifi.processor.Relationship v; org.apache.nifi.util.TestRunner 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.AllowableValue v; java.lang.InterruptedException v; v := @this: org.apache.nifi.processors.standard.TestMergeContent; v = new org.apache.nifi.processors.standard.MergeContent; specialinvoke v.()>(); v = staticinvoke (v); v = ; v = ; interfaceinvoke v.(v, v); v = ; interfaceinvoke v.(v, "2 secs"); v = new java.util.HashMap; specialinvoke v.()>(); v = ; interfaceinvoke v.(v, "1"); v = ; interfaceinvoke v.(v, "5"); v = ; interfaceinvoke v.(v, "1"); v = "A Man "; v = virtualinvoke v.("UTF-8"); interfaceinvoke v.(v, v); v = ; interfaceinvoke v.(v, "2"); v = "A Plan "; v = virtualinvoke v.("UTF-8"); interfaceinvoke v.(v, v); v = ; interfaceinvoke v.(v, "3"); v = "A Canal "; v = virtualinvoke v.("UTF-8"); interfaceinvoke v.(v, v); v = ; interfaceinvoke v.(v, "4"); v = "Panama"; v = virtualinvoke v.("UTF-8"); interfaceinvoke v.(v, v); interfaceinvoke v.(1, 0); label: staticinvoke (3000L); label: goto label; label: v := @caughtexception; goto label; label: interfaceinvoke v.(1); v = ; interfaceinvoke v.(v, 4); return; catch java.lang.InterruptedException from label to label with label; } public void testDefragmentOutOfOrder() throws java.io.IOException { byte[] v, v, v, v, v; org.apache.nifi.processors.standard.TestMergeContent v; java.util.HashMap v; org.apache.nifi.components.PropertyDescriptor v, v; org.apache.nifi.processor.Relationship v, v, v; org.apache.nifi.util.TestRunner v; org.apache.nifi.processors.standard.MergeContent v; java.lang.String v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.components.AllowableValue v; java.util.function.Consumer v; java.util.List v, v; java.util.stream.Stream v; java.lang.Object v; v := @this: org.apache.nifi.processors.standard.TestMergeContent; v = new org.apache.nifi.processors.standard.MergeContent; specialinvoke v.()>(); v = staticinvoke (v); v = ; v = ; interfaceinvoke v.(v, v); v = ; interfaceinvoke v.(v, "1 min"); v = new java.util.HashMap; specialinvoke v.()>(); v = ; interfaceinvoke v.(v, "1"); v = ; interfaceinvoke v.(v, "4"); v = ; interfaceinvoke v.(v, "1"); v = "A Man "; v = virtualinvoke v.("UTF-8"); interfaceinvoke v.(v, v); v = ; interfaceinvoke v.(v, "3"); v = "A Canal "; v = virtualinvoke v.("UTF-8"); interfaceinvoke v.(v, v); v = ; interfaceinvoke v.(v, "4"); v = "Panama"; v = virtualinvoke v.("UTF-8"); interfaceinvoke v.(v, v); v = ; interfaceinvoke v.(v, "2"); v = "A Plan "; v = virtualinvoke v.("UTF-8"); interfaceinvoke v.(v, v); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, 1); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); v = "A Man A Plan A Canal Panama"; v = virtualinvoke v.("UTF-8"); virtualinvoke v.(v); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = staticinvoke (v); interfaceinvoke v.(v); return; } public void testDefragmentMultipleMingledSegments() throws java.io.IOException { byte[] v, v, v, v, v, v, v, v, v; org.apache.nifi.components.PropertyDescriptor v, v; org.apache.nifi.util.TestRunner v; org.apache.nifi.components.AllowableValue v; java.util.List v, v; org.apache.nifi.processors.standard.TestMergeContent v; java.util.HashMap v, v; org.apache.nifi.processor.Relationship v, v, v; 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, v, v, v, v, v; java.lang.Object v, v; v := @this: org.apache.nifi.processors.standard.TestMergeContent; v = new org.apache.nifi.processors.standard.MergeContent; specialinvoke v.()>(); v = staticinvoke (v); v = ; v = ; interfaceinvoke v.(v, v); v = ; interfaceinvoke v.(v, "1 min"); v = new java.util.HashMap; specialinvoke v.()>(); v = ; interfaceinvoke v.(v, "1"); v = ; interfaceinvoke v.(v, "4"); v = new java.util.HashMap; specialinvoke v.()>(); v = ; interfaceinvoke v.(v, "TWO"); v = ; interfaceinvoke v.(v, "3"); v = ; interfaceinvoke v.(v, "1"); v = "A Man "; v = virtualinvoke v.("UTF-8"); interfaceinvoke v.(v, v); v = ; interfaceinvoke v.(v, "2"); v = "A Plan "; v = virtualinvoke v.("UTF-8"); interfaceinvoke v.(v, v); v = ; interfaceinvoke v.(v, "1"); v = "No x "; v = virtualinvoke v.("UTF-8"); interfaceinvoke v.(v, v); v = ; interfaceinvoke v.(v, "2"); v = "in "; v = virtualinvoke v.("UTF-8"); interfaceinvoke v.(v, v); v = ; interfaceinvoke v.(v, "3"); v = "Nixon"; v = virtualinvoke v.("UTF-8"); interfaceinvoke v.(v, v); v = ; interfaceinvoke v.(v, "3"); v = "A Canal "; v = virtualinvoke v.("UTF-8"); interfaceinvoke v.(v, v); v = ; interfaceinvoke v.(v, "4"); v = "Panama"; v = virtualinvoke v.("UTF-8"); interfaceinvoke v.(v, v); interfaceinvoke v.(1); v = ; interfaceinvoke v.(v, 2); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); v = "A Man A Plan A Canal Panama"; v = virtualinvoke v.("UTF-8"); virtualinvoke v.(v); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(1); v = "No x in Nixon"; v = virtualinvoke v.("UTF-8"); virtualinvoke v.(v); return; } public void testDefragmentOldStyleAttributes() throws java.io.IOException { byte[] v, v, v, v, v; org.apache.nifi.processors.standard.TestMergeContent v; java.util.HashMap v; org.apache.nifi.components.PropertyDescriptor v, v; org.apache.nifi.processor.Relationship v, v; org.apache.nifi.util.TestRunner v; org.apache.nifi.processors.standard.MergeContent v; java.lang.String v, v, v, v, v, v; org.apache.nifi.components.AllowableValue v; java.util.List v; java.lang.Object v; org.apache.nifi.flowfile.attributes.CoreAttributes v; v := @this: org.apache.nifi.processors.standard.TestMergeContent; v = new org.apache.nifi.processors.standard.MergeContent; specialinvoke v.()>(); v = staticinvoke (v); v = ; v = ; interfaceinvoke v.(v, v); v = ; interfaceinvoke v.(v, "1 min"); v = new java.util.HashMap; specialinvoke v.()>(); interfaceinvoke v.("segment.identifier", "1"); interfaceinvoke v.("segment.count", "4"); interfaceinvoke v.("segment.index", "1"); interfaceinvoke v.("segment.original.filename", "originalfilename"); v = "A Man "; v = virtualinvoke v.("UTF-8"); interfaceinvoke v.(v, v); interfaceinvoke v.("segment.index", "2"); v = "A Plan "; v = virtualinvoke v.("UTF-8"); interfaceinvoke v.(v, v); interfaceinvoke v.("segment.index", "3"); v = "A Canal "; v = virtualinvoke v.("UTF-8"); interfaceinvoke v.(v, v); interfaceinvoke v.("segment.index", "4"); v = "Panama"; v = virtualinvoke v.("UTF-8"); interfaceinvoke v.(v, v); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, 1); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); v = "A Man A Plan A Canal Panama"; v = virtualinvoke v.("UTF-8"); virtualinvoke v.(v); v = ; v = virtualinvoke v.(); virtualinvoke v.(v, "originalfilename"); return; } public void testDefragmentMultipleOnTriggers() throws java.io.IOException { byte[] v, v, v, v, v; org.apache.nifi.processors.standard.TestMergeContent v; java.util.HashMap v; org.apache.nifi.components.PropertyDescriptor v; org.apache.nifi.processor.Relationship v, v; org.apache.nifi.util.TestRunner v; org.apache.nifi.processors.standard.MergeContent v; java.lang.String v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.components.AllowableValue v; java.util.List v; java.lang.Object v; v := @this: org.apache.nifi.processors.standard.TestMergeContent; v = new org.apache.nifi.processors.standard.MergeContent; specialinvoke v.()>(); v = staticinvoke (v); v = ; v = ; interfaceinvoke v.(v, v); v = new java.util.HashMap; specialinvoke v.()>(); v = ; interfaceinvoke v.(v, "1"); v = ; interfaceinvoke v.(v, "4"); v = ; interfaceinvoke v.(v, "1"); v = "A Man "; v = virtualinvoke v.("UTF-8"); interfaceinvoke v.(v, v); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, "2"); v = "A Plan "; v = virtualinvoke v.("UTF-8"); interfaceinvoke v.(v, v); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, "3"); v = "A Canal "; v = virtualinvoke v.("UTF-8"); interfaceinvoke v.(v, v); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, "4"); v = "Panama"; v = virtualinvoke v.("UTF-8"); interfaceinvoke v.(v, v); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, 1); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); v = "A Man A Plan A Canal Panama"; v = virtualinvoke v.("UTF-8"); virtualinvoke v.(v); return; } public void testMergeBasedOnCorrelation() throws java.io.IOException, java.lang.InterruptedException { byte[] v, v, v, v; org.apache.nifi.processors.standard.TestMergeContent v; java.util.HashMap v; org.apache.nifi.components.PropertyDescriptor v, v, v, v, v; org.apache.nifi.processor.Relationship v, v; org.apache.nifi.util.TestRunner v; org.apache.nifi.processors.standard.MergeContent v; java.lang.String v, v, v, v, v, v, v; boolean v; org.apache.nifi.components.AllowableValue v; java.util.List v; java.lang.Object v, v; v := @this: org.apache.nifi.processors.standard.TestMergeContent; v = new org.apache.nifi.processors.standard.MergeContent; specialinvoke v.()>(); v = staticinvoke (v); v = ; v = ; interfaceinvoke v.(v, v); v = ; interfaceinvoke v.(v, "1 min"); v = ; interfaceinvoke v.(v, "attr"); v = ; interfaceinvoke v.(v, "3"); v = ; interfaceinvoke v.(v, "1"); v = new java.util.HashMap; specialinvoke v.()>(); interfaceinvoke v.("attr", "b"); v = "A Man "; v = virtualinvoke v.("UTF-8"); interfaceinvoke v.(v, v); v = "A Plan "; v = virtualinvoke v.("UTF-8"); interfaceinvoke v.(v, v); interfaceinvoke v.("attr", "c"); v = "A Canal "; v = virtualinvoke v.("UTF-8"); interfaceinvoke v.(v, v); interfaceinvoke v.("attr", "b"); v = "Panama"; v = virtualinvoke v.("UTF-8"); interfaceinvoke v.(v, v); interfaceinvoke v.(2); v = ; interfaceinvoke v.(v, 2); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); v = interfaceinvoke v.(1); v = virtualinvoke v.("attr"); v = virtualinvoke v.("attr"); v = "c"; v = virtualinvoke v.(v); if v == 0 goto label; staticinvoke ("b", v); virtualinvoke v.("A Canal ", "UTF-8"); virtualinvoke v.("A Man A Plan Panama", "UTF-8"); goto label; label: staticinvoke ("b", v); staticinvoke ("c", v); virtualinvoke v.("A Man A Plan Panama", "UTF-8"); virtualinvoke v.("A Canal ", "UTF-8"); label: return; } public void testMaxBinAge() throws java.lang.InterruptedException { byte[] v; org.apache.nifi.processors.standard.TestMergeContent v; org.apache.nifi.components.AllowableValue v; org.apache.nifi.components.PropertyDescriptor v, v, v, v, v; org.apache.nifi.processor.Relationship v, v; org.apache.nifi.util.TestRunner v; org.apache.nifi.processors.standard.MergeContent v; int v; v := @this: org.apache.nifi.processors.standard.TestMergeContent; v = new org.apache.nifi.processors.standard.MergeContent; specialinvoke v.()>(); v = staticinvoke (v); v = ; v = ; interfaceinvoke v.(v, v); v = ; interfaceinvoke v.(v, "2 sec"); v = ; interfaceinvoke v.(v, "attr"); v = ; interfaceinvoke v.(v, "500"); v = ; interfaceinvoke v.(v, "500"); v = 0; label: if v >= 50 goto label; v = newarray (byte)[0]; interfaceinvoke v.(v); v = v + 1; goto label; label: interfaceinvoke v.(5, 0); v = ; interfaceinvoke v.(v, 0); interfaceinvoke v.(); staticinvoke (3000L); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, 1); return; } public void testUniqueAttributes() { byte[] v, v; org.apache.nifi.processors.standard.TestMergeContent v; java.util.HashMap v, v; org.apache.nifi.components.AllowableValue v; org.apache.nifi.components.PropertyDescriptor v, v, v; java.util.List v; org.apache.nifi.processor.Relationship v, v; org.apache.nifi.util.TestRunner v; org.apache.nifi.processors.standard.MergeContent v; java.lang.Object v; v := @this: org.apache.nifi.processors.standard.TestMergeContent; v = new org.apache.nifi.processors.standard.MergeContent; specialinvoke v.()>(); v = staticinvoke (v); v = ; v = ; interfaceinvoke v.(v, v); v = ; interfaceinvoke v.(v, "2 B"); v = ; interfaceinvoke v.(v, "2 B"); v = new java.util.HashMap; specialinvoke v.()>(); interfaceinvoke v.("abc", "xyz"); interfaceinvoke v.("xyz", "123"); interfaceinvoke v.("hello", "good-bye"); v = new java.util.HashMap; specialinvoke v.()>(); interfaceinvoke v.("abc", "xyz"); interfaceinvoke v.("xyz", "321"); interfaceinvoke v.("world", "aaa"); v = newarray (byte)[1]; interfaceinvoke v.(v, v); v = newarray (byte)[1]; interfaceinvoke v.(v, v); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, 1); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); virtualinvoke v.("abc", "xyz"); virtualinvoke v.("hello", "good-bye"); virtualinvoke v.("world", "aaa"); virtualinvoke v.("xyz"); return; } public void testCommonAttributesOnly() { byte[] v, v; org.apache.nifi.processors.standard.TestMergeContent v; java.util.HashMap v, v; org.apache.nifi.components.PropertyDescriptor v, v, v; java.util.HashSet v; org.apache.nifi.processor.Relationship v, v, v; org.apache.nifi.util.TestRunner v; org.apache.nifi.processors.standard.MergeContent v; int v; java.lang.String v, v, v, v; boolean v; java.util.Iterator v; org.apache.nifi.components.AllowableValue v; java.util.List v, v; java.lang.Object v, v; org.apache.nifi.flowfile.attributes.CoreAttributes v, v; v := @this: org.apache.nifi.processors.standard.TestMergeContent; v = new org.apache.nifi.processors.standard.MergeContent; specialinvoke v.()>(); v = staticinvoke (v); v = ; v = ; interfaceinvoke v.(v, v); v = ; interfaceinvoke v.(v, "2 B"); v = ; interfaceinvoke v.(v, "2 B"); v = new java.util.HashMap; specialinvoke v.()>(); interfaceinvoke v.("abc", "xyz"); interfaceinvoke v.("xyz", "123"); interfaceinvoke v.("hello", "good-bye"); v = new java.util.HashMap; specialinvoke v.()>(); interfaceinvoke v.("abc", "xyz"); interfaceinvoke v.("xyz", "321"); interfaceinvoke v.("world", "aaa"); v = newarray (byte)[1]; interfaceinvoke v.(v, v); v = newarray (byte)[1]; interfaceinvoke v.(v, v); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, 1); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); virtualinvoke v.("abc", "xyz"); virtualinvoke v.("hello"); virtualinvoke v.("world"); virtualinvoke v.("xyz"); v = new java.util.HashSet; specialinvoke v.()>(); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = ; v = virtualinvoke v.(); v = virtualinvoke v.(v); interfaceinvoke v.(v); goto label; label: v = ; v = virtualinvoke v.(); v = virtualinvoke v.(v); interfaceinvoke v.(v); v = interfaceinvoke v.(); staticinvoke (3, v); return; } public void testCountAttribute() throws java.io.IOException { byte[] v; org.apache.nifi.processors.standard.TestMergeContent v; org.apache.nifi.components.AllowableValue v; org.apache.nifi.components.PropertyDescriptor v, v; java.util.List v; org.apache.nifi.processor.Relationship v, v, v, v; org.apache.nifi.util.TestRunner v; org.apache.nifi.processors.standard.MergeContent v; java.lang.Object v; java.lang.String v; v := @this: org.apache.nifi.processors.standard.TestMergeContent; v = new org.apache.nifi.processors.standard.MergeContent; specialinvoke v.()>(); v = staticinvoke (v); v = ; interfaceinvoke v.(v, "1 sec"); v = ; v = ; interfaceinvoke v.(v, v); specialinvoke v.(v); interfaceinvoke v.(2); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, 1); v = ; interfaceinvoke v.(v, 0); v = ; interfaceinvoke v.(v, 3); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); v = "Hello, World!"; v = virtualinvoke v.("UTF-8"); virtualinvoke v.(v); virtualinvoke v.("merge.count", "3"); virtualinvoke v.("merge.bin.age"); return; } public void testLeavesSmallBinUnmerged() { org.apache.nifi.processors.standard.TestMergeContent v; org.apache.nifi.components.PropertyDescriptor v, v, v; org.apache.nifi.controller.queue.QueueSize v; org.apache.nifi.processor.Relationship v, v; org.apache.nifi.util.TestRunner v; org.apache.nifi.processors.standard.MergeContent v; int v, v; java.lang.String v, v; v := @this: org.apache.nifi.processors.standard.TestMergeContent; v = new org.apache.nifi.processors.standard.MergeContent; specialinvoke v.()>(); v = staticinvoke (v); v = ; interfaceinvoke v.(v, "5"); v = ; interfaceinvoke v.(v, "5"); v = ; interfaceinvoke v.(v, "3"); v = 0; label: if v >= 17 goto label; v = staticinvoke (v); v = dynamicinvoke "makeConcatWithConstants" (v) ("\u0001\n"); interfaceinvoke v.(v); v = v + 1; goto label; label: interfaceinvoke v.(5); v = ; interfaceinvoke v.(v, 3); v = ; interfaceinvoke v.(v, 15); v = interfaceinvoke v.(); v = virtualinvoke v.(); staticinvoke (2, v); return; } private void createFlowFiles(org.apache.nifi.util.TestRunner) { org.apache.nifi.processors.standard.TestMergeContent v; org.apache.nifi.util.TestRunner v; java.util.HashMap v; java.lang.String v, v; org.apache.nifi.flowfile.attributes.CoreAttributes v; v := @this: org.apache.nifi.processors.standard.TestMergeContent; v := @parameter: org.apache.nifi.util.TestRunner; v = new java.util.HashMap; specialinvoke v.()>(); v = ; v = virtualinvoke v.(); interfaceinvoke v.(v, "application/plain-text"); v = ; interfaceinvoke v.(v, "1"); interfaceinvoke v.("Hello", v); interfaceinvoke v.(", ", v); interfaceinvoke v.("World!", v); return; } }