class org.apache.nifi.processors.standard.MergeContent$AvroMerge$1$1 extends java.lang.Object implements org.apache.nifi.processor.io.InputStreamCallback
{
final java.io.OutputStream val$out;
final org.apache.nifi.flowfile.FlowFile val$flowFile;
final org.apache.nifi.processors.standard.MergeContent$AvroMerge$1 this$2;
void <init>(org.apache.nifi.processors.standard.MergeContent$AvroMerge$1, java.io.OutputStream, org.apache.nifi.flowfile.FlowFile)
{
java.io.OutputStream v;
org.apache.nifi.flowfile.FlowFile v;
org.apache.nifi.processors.standard.MergeContent$AvroMerge$1 v;
org.apache.nifi.processors.standard.MergeContent$AvroMerge$1$1 v;
v := @this: org.apache.nifi.processors.standard.MergeContent$AvroMerge$1$1;
v := @parameter: org.apache.nifi.processors.standard.MergeContent$AvroMerge$1;
v := @parameter: java.io.OutputStream;
v := @parameter: org.apache.nifi.flowfile.FlowFile;
v.<org.apache.nifi.processors.standard.MergeContent$AvroMerge$1$1: org.apache.nifi.processors.standard.MergeContent$AvroMerge$1 this$2> = v;
v.<org.apache.nifi.processors.standard.MergeContent$AvroMerge$1$1: java.io.OutputStream val$out> = v;
v.<org.apache.nifi.processors.standard.MergeContent$AvroMerge$1$1: org.apache.nifi.flowfile.FlowFile val$flowFile> = v;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
public void process(java.io.InputStream) throws java.io.IOException
{
byte[] v, v;
java.lang.Long v, v, v;
java.util.Map v, v;
org.apache.avro.Schema v, v, v;
org.apache.avro.file.DataFileWriter v, v, v, v;
org.apache.nifi.components.AllowableValue v, v, v, v;
org.apache.nifi.processors.standard.MergeContent$AvroMerge$1$1 v;
java.lang.Throwable v;
java.lang.Object[] v, v, v;
long v, v, v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v;
org.apache.avro.file.DataFileStream v;
org.apache.nifi.processors.standard.MergeContent$AvroMerge$1 v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.nifi.processors.standard.MergeContent$AvroMerge v, v, v, v, v, v;
org.apache.avro.file.CodecFactory v;
boolean v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.nifi.flowfile.FlowFile v, v, v, v, v, v;
java.util.List v, v, v, v, v;
org.apache.avro.generic.GenericDatumReader v;
org.apache.nifi.logging.ComponentLog v, v, v;
java.util.concurrent.atomic.AtomicReference v, v, v, v, v, v, v, v, v;
org.apache.nifi.processors.standard.MergeContent v, v, v;
java.io.OutputStream v;
java.util.Iterator v, v;
java.lang.Object v, v, v, v, v, v, v, v, v;
java.io.InputStream v;
v := @this: org.apache.nifi.processors.standard.MergeContent$AvroMerge$1$1;
v := @parameter: java.io.InputStream;
v = 1;
v = new org.apache.avro.file.DataFileStream;
v = new org.apache.avro.generic.GenericDatumReader;
specialinvoke v.<org.apache.avro.generic.GenericDatumReader: void <init>()>();
specialinvoke v.<org.apache.avro.file.DataFileStream: void <init>(java.io.InputStream,org.apache.avro.io.DatumReader)>(v, v);
label:
v = v.<org.apache.nifi.processors.standard.MergeContent$AvroMerge$1$1: org.apache.nifi.processors.standard.MergeContent$AvroMerge$1 this$2>;
v = v.<org.apache.nifi.processors.standard.MergeContent$AvroMerge$1: java.util.concurrent.atomic.AtomicReference val$schema>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: java.lang.Object get()>();
if v != null goto label;
v = v.<org.apache.nifi.processors.standard.MergeContent$AvroMerge$1$1: org.apache.nifi.processors.standard.MergeContent$AvroMerge$1 this$2>;
v = v.<org.apache.nifi.processors.standard.MergeContent$AvroMerge$1: java.util.concurrent.atomic.AtomicReference val$schema>;
v = virtualinvoke v.<org.apache.avro.file.DataFileStream: org.apache.avro.Schema getSchema()>();
virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: void set(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.MergeContent: org.apache.nifi.components.AllowableValue METADATA_STRATEGY_IGNORE>;
v = virtualinvoke v.<org.apache.nifi.components.AllowableValue: java.lang.String getValue()>();
v = v.<org.apache.nifi.processors.standard.MergeContent$AvroMerge$1$1: org.apache.nifi.processors.standard.MergeContent$AvroMerge$1 this$2>;
v = v.<org.apache.nifi.processors.standard.MergeContent$AvroMerge$1: java.lang.String val$metadataStrategy>;
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
v = virtualinvoke v.<org.apache.avro.file.DataFileStream: java.util.List getMetaKeys()>();
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = staticinvoke <org.apache.avro.file.DataFileWriter: boolean isReservedMeta(java.lang.String)>(v);
if v != 0 goto label;
v = virtualinvoke v.<org.apache.avro.file.DataFileStream: byte[] getMeta(java.lang.String)>(v);
v = v.<org.apache.nifi.processors.standard.MergeContent$AvroMerge$1$1: org.apache.nifi.processors.standard.MergeContent$AvroMerge$1 this$2>;
v = v.<org.apache.nifi.processors.standard.MergeContent$AvroMerge$1: java.util.Map val$metadata>;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = v.<org.apache.nifi.processors.standard.MergeContent$AvroMerge$1$1: org.apache.nifi.processors.standard.MergeContent$AvroMerge$1 this$2>;
v = v.<org.apache.nifi.processors.standard.MergeContent$AvroMerge$1: org.apache.avro.file.DataFileWriter val$writer>;
virtualinvoke v.<org.apache.avro.file.DataFileWriter: org.apache.avro.file.DataFileWriter setMeta(java.lang.String,byte[])>(v, v);
goto label;
label:
v = v.<org.apache.nifi.processors.standard.MergeContent$AvroMerge$1$1: org.apache.nifi.processors.standard.MergeContent$AvroMerge$1 this$2>;
v = v.<org.apache.nifi.processors.standard.MergeContent$AvroMerge$1: java.util.concurrent.atomic.AtomicReference val$inputCodec>;
v = virtualinvoke v.<org.apache.avro.file.DataFileStream: java.lang.String getMetaString(java.lang.String)>("avro.codec");
virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: void set(java.lang.Object)>(v);
v = v.<org.apache.nifi.processors.standard.MergeContent$AvroMerge$1$1: org.apache.nifi.processors.standard.MergeContent$AvroMerge$1 this$2>;
v = v.<org.apache.nifi.processors.standard.MergeContent$AvroMerge$1: java.util.concurrent.atomic.AtomicReference val$inputCodec>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: java.lang.Object get()>();
if v != null goto label;
v = v.<org.apache.nifi.processors.standard.MergeContent$AvroMerge$1$1: org.apache.nifi.processors.standard.MergeContent$AvroMerge$1 this$2>;
v = v.<org.apache.nifi.processors.standard.MergeContent$AvroMerge$1: java.util.concurrent.atomic.AtomicReference val$inputCodec>;
virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: void set(java.lang.Object)>("null");
label:
v = v.<org.apache.nifi.processors.standard.MergeContent$AvroMerge$1$1: org.apache.nifi.processors.standard.MergeContent$AvroMerge$1 this$2>;
v = v.<org.apache.nifi.processors.standard.MergeContent$AvroMerge$1: org.apache.avro.file.DataFileWriter val$writer>;
v = v.<org.apache.nifi.processors.standard.MergeContent$AvroMerge$1$1: org.apache.nifi.processors.standard.MergeContent$AvroMerge$1 this$2>;
v = v.<org.apache.nifi.processors.standard.MergeContent$AvroMerge$1: java.util.concurrent.atomic.AtomicReference val$inputCodec>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: java.lang.Object get()>();
v = staticinvoke <org.apache.avro.file.CodecFactory: org.apache.avro.file.CodecFactory fromString(java.lang.String)>(v);
virtualinvoke v.<org.apache.avro.file.DataFileWriter: org.apache.avro.file.DataFileWriter setCodec(org.apache.avro.file.CodecFactory)>(v);
v = v.<org.apache.nifi.processors.standard.MergeContent$AvroMerge$1$1: org.apache.nifi.processors.standard.MergeContent$AvroMerge$1 this$2>;
v = v.<org.apache.nifi.processors.standard.MergeContent$AvroMerge$1: org.apache.avro.file.DataFileWriter val$writer>;
v = v.<org.apache.nifi.processors.standard.MergeContent$AvroMerge$1$1: org.apache.nifi.processors.standard.MergeContent$AvroMerge$1 this$2>;
v = v.<org.apache.nifi.processors.standard.MergeContent$AvroMerge$1: java.util.concurrent.atomic.AtomicReference val$schema>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: java.lang.Object get()>();
v = v.<org.apache.nifi.processors.standard.MergeContent$AvroMerge$1$1: java.io.OutputStream val$out>;
virtualinvoke v.<org.apache.avro.file.DataFileWriter: org.apache.avro.file.DataFileWriter create(org.apache.avro.Schema,java.io.OutputStream)>(v, v);
goto label;
label:
v = v.<org.apache.nifi.processors.standard.MergeContent$AvroMerge$1$1: org.apache.nifi.processors.standard.MergeContent$AvroMerge$1 this$2>;
v = v.<org.apache.nifi.processors.standard.MergeContent$AvroMerge$1: java.util.concurrent.atomic.AtomicReference val$schema>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: java.lang.Object get()>();
v = virtualinvoke v.<org.apache.avro.file.DataFileStream: org.apache.avro.Schema getSchema()>();
v = virtualinvoke v.<org.apache.avro.Schema: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
v = v.<org.apache.nifi.processors.standard.MergeContent$AvroMerge$1$1: org.apache.nifi.processors.standard.MergeContent$AvroMerge$1 this$2>;
v = v.<org.apache.nifi.processors.standard.MergeContent$AvroMerge$1: org.apache.nifi.processors.standard.MergeContent$AvroMerge this$1>;
v = v.<org.apache.nifi.processors.standard.MergeContent$AvroMerge: org.apache.nifi.processors.standard.MergeContent this$0>;
v = virtualinvoke v.<org.apache.nifi.processors.standard.MergeContent: org.apache.nifi.logging.ComponentLog getLogger()>();
v = newarray (java.lang.Object)[2];
v = v.<org.apache.nifi.processors.standard.MergeContent$AvroMerge$1$1: org.apache.nifi.flowfile.FlowFile val$flowFile>;
v = interfaceinvoke v.<org.apache.nifi.flowfile.FlowFile: long getId()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v[0] = v;
v = virtualinvoke v.<org.apache.avro.file.DataFileStream: org.apache.avro.Schema getSchema()>();
v = virtualinvoke v.<org.apache.avro.Schema: java.lang.String getName()>();
v[1] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void debug(java.lang.String,java.lang.Object[])>("Input file {} has different schema - {}, not merging", v);
v = 0;
v = v.<org.apache.nifi.processors.standard.MergeContent$AvroMerge$1$1: org.apache.nifi.processors.standard.MergeContent$AvroMerge$1 this$2>;
v = v.<org.apache.nifi.processors.standard.MergeContent$AvroMerge$1: org.apache.nifi.processors.standard.MergeContent$AvroMerge this$1>;
v = v.<org.apache.nifi.processors.standard.MergeContent$AvroMerge: java.util.List unmerged>;
v = v.<org.apache.nifi.processors.standard.MergeContent$AvroMerge$1$1: org.apache.nifi.flowfile.FlowFile val$flowFile>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
label:
v = <org.apache.nifi.processors.standard.MergeContent: org.apache.nifi.components.AllowableValue METADATA_STRATEGY_DO_NOT_MERGE>;
v = virtualinvoke v.<org.apache.nifi.components.AllowableValue: java.lang.String getValue()>();
v = v.<org.apache.nifi.processors.standard.MergeContent$AvroMerge$1$1: org.apache.nifi.processors.standard.MergeContent$AvroMerge$1 this$2>;
v = v.<org.apache.nifi.processors.standard.MergeContent$AvroMerge$1: java.lang.String val$metadataStrategy>;
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
v = <org.apache.nifi.processors.standard.MergeContent: org.apache.nifi.components.AllowableValue METADATA_STRATEGY_ALL_COMMON>;
v = virtualinvoke v.<org.apache.nifi.components.AllowableValue: java.lang.String getValue()>();
v = v.<org.apache.nifi.processors.standard.MergeContent$AvroMerge$1$1: org.apache.nifi.processors.standard.MergeContent$AvroMerge$1 this$2>;
v = v.<org.apache.nifi.processors.standard.MergeContent$AvroMerge$1: java.lang.String val$metadataStrategy>;
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
label:
v = virtualinvoke v.<org.apache.avro.file.DataFileStream: java.util.List getMetaKeys()>();
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = staticinvoke <org.apache.avro.file.DataFileWriter: boolean isReservedMeta(java.lang.String)>(v);
if v != 0 goto label;
v = virtualinvoke v.<org.apache.avro.file.DataFileStream: byte[] getMeta(java.lang.String)>(v);
v = v.<org.apache.nifi.processors.standard.MergeContent$AvroMerge$1$1: org.apache.nifi.processors.standard.MergeContent$AvroMerge$1 this$2>;
v = v.<org.apache.nifi.processors.standard.MergeContent$AvroMerge$1: java.util.Map val$metadata>;
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
v = staticinvoke <java.util.Arrays: boolean equals(byte[],byte[])>(v, v);
if v != 0 goto label;
v = <org.apache.nifi.processors.standard.MergeContent: org.apache.nifi.components.AllowableValue METADATA_STRATEGY_ALL_COMMON>;
v = virtualinvoke v.<org.apache.nifi.components.AllowableValue: java.lang.String getValue()>();
v = v.<org.apache.nifi.processors.standard.MergeContent$AvroMerge$1$1: org.apache.nifi.processors.standard.MergeContent$AvroMerge$1 this$2>;
v = v.<org.apache.nifi.processors.standard.MergeContent$AvroMerge$1: java.lang.String val$metadataStrategy>;
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
if v == null goto label;
label:
v = v.<org.apache.nifi.processors.standard.MergeContent$AvroMerge$1$1: org.apache.nifi.processors.standard.MergeContent$AvroMerge$1 this$2>;
v = v.<org.apache.nifi.processors.standard.MergeContent$AvroMerge$1: org.apache.nifi.processors.standard.MergeContent$AvroMerge this$1>;
v = v.<org.apache.nifi.processors.standard.MergeContent$AvroMerge: org.apache.nifi.processors.standard.MergeContent this$0>;
v = virtualinvoke v.<org.apache.nifi.processors.standard.MergeContent: org.apache.nifi.logging.ComponentLog getLogger()>();
v = newarray (java.lang.Object)[1];
v = v.<org.apache.nifi.processors.standard.MergeContent$AvroMerge$1$1: org.apache.nifi.flowfile.FlowFile val$flowFile>;
v = interfaceinvoke v.<org.apache.nifi.flowfile.FlowFile: long getId()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v[0] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void debug(java.lang.String,java.lang.Object[])>("Input file {} has different non-reserved metadata, not merging", v);
v = 0;
v = v.<org.apache.nifi.processors.standard.MergeContent$AvroMerge$1$1: org.apache.nifi.processors.standard.MergeContent$AvroMerge$1 this$2>;
v = v.<org.apache.nifi.processors.standard.MergeContent$AvroMerge$1: org.apache.nifi.processors.standard.MergeContent$AvroMerge this$1>;
v = v.<org.apache.nifi.processors.standard.MergeContent$AvroMerge: java.util.List unmerged>;
v = v.<org.apache.nifi.processors.standard.MergeContent$AvroMerge$1$1: org.apache.nifi.flowfile.FlowFile val$flowFile>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
v = virtualinvoke v.<org.apache.avro.file.DataFileStream: java.lang.String getMetaString(java.lang.String)>("avro.codec");
if v != null goto label;
v = "null";
label:
v = v.<org.apache.nifi.processors.standard.MergeContent$AvroMerge$1$1: org.apache.nifi.processors.standard.MergeContent$AvroMerge$1 this$2>;
v = v.<org.apache.nifi.processors.standard.MergeContent$AvroMerge$1: java.util.concurrent.atomic.AtomicReference val$inputCodec>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: java.lang.Object get()>();
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
v = v.<org.apache.nifi.processors.standard.MergeContent$AvroMerge$1$1: org.apache.nifi.processors.standard.MergeContent$AvroMerge$1 this$2>;
v = v.<org.apache.nifi.processors.standard.MergeContent$AvroMerge$1: org.apache.nifi.processors.standard.MergeContent$AvroMerge this$1>;
v = v.<org.apache.nifi.processors.standard.MergeContent$AvroMerge: org.apache.nifi.processors.standard.MergeContent this$0>;
v = virtualinvoke v.<org.apache.nifi.processors.standard.MergeContent: org.apache.nifi.logging.ComponentLog getLogger()>();
v = newarray (java.lang.Object)[1];
v = v.<org.apache.nifi.processors.standard.MergeContent$AvroMerge$1$1: org.apache.nifi.flowfile.FlowFile val$flowFile>;
v = interfaceinvoke v.<org.apache.nifi.flowfile.FlowFile: long getId()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v[0] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void debug(java.lang.String,java.lang.Object[])>("Input file {} has different codec, not merging", v);
v = 0;
v = v.<org.apache.nifi.processors.standard.MergeContent$AvroMerge$1$1: org.apache.nifi.processors.standard.MergeContent$AvroMerge$1 this$2>;
v = v.<org.apache.nifi.processors.standard.MergeContent$AvroMerge$1: org.apache.nifi.processors.standard.MergeContent$AvroMerge this$1>;
v = v.<org.apache.nifi.processors.standard.MergeContent$AvroMerge: java.util.List unmerged>;
v = v.<org.apache.nifi.processors.standard.MergeContent$AvroMerge$1$1: org.apache.nifi.flowfile.FlowFile val$flowFile>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
label:
if v == 0 goto label;
v = v.<org.apache.nifi.processors.standard.MergeContent$AvroMerge$1$1: org.apache.nifi.processors.standard.MergeContent$AvroMerge$1 this$2>;
v = v.<org.apache.nifi.processors.standard.MergeContent$AvroMerge$1: org.apache.avro.file.DataFileWriter val$writer>;
virtualinvoke v.<org.apache.avro.file.DataFileWriter: void appendAllFrom(org.apache.avro.file.DataFileStream,boolean)>(v, 0);
label:
virtualinvoke v.<org.apache.avro.file.DataFileStream: void close()>();
goto label;
label:
v := @caughtexception;
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
}