public class org.apache.avro.reflect.ReflectDatumReader<T> extends org.apache.avro.specific.SpecificDatumReader<T>
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: org.apache.avro.reflect.ReflectDatumReader
super_class: org.apache.avro.specific.SpecificDatumReader
{
public void <init>();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=1, args_size=1
start local 0 0: aload 0
aconst_null
aconst_null
invokestatic org.apache.avro.reflect.ReflectData.get:()Lorg/apache/avro/reflect/ReflectData;
invokespecial org.apache.avro.reflect.ReflectDatumReader.<init>:(Lorg/apache/avro/Schema;Lorg/apache/avro/Schema;Lorg/apache/avro/reflect/ReflectData;)V
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/avro/reflect/ReflectDatumReader<TT;>;
public void <init>(java.lang.Class<T>);
descriptor: (Ljava/lang/Class;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 0
new org.apache.avro.reflect.ReflectData
dup
aload 1
invokevirtual java.lang.Class.getClassLoader:()Ljava/lang/ClassLoader;
invokespecial org.apache.avro.reflect.ReflectData.<init>:(Ljava/lang/ClassLoader;)V
invokespecial org.apache.avro.reflect.ReflectDatumReader.<init>:(Lorg/apache/avro/reflect/ReflectData;)V
1: aload 0
aload 0
invokevirtual org.apache.avro.reflect.ReflectDatumReader.getSpecificData:()Lorg/apache/avro/specific/SpecificData;
aload 1
invokevirtual org.apache.avro.specific.SpecificData.getSchema:(Ljava/lang/reflect/Type;)Lorg/apache/avro/Schema;
invokevirtual org.apache.avro.reflect.ReflectDatumReader.setSchema:(Lorg/apache/avro/Schema;)V
2: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lorg/apache/avro/reflect/ReflectDatumReader<TT;>;
0 3 1 c Ljava/lang/Class<TT;>;
Signature: (Ljava/lang/Class<TT;>;)V
MethodParameters:
Name Flags
c
public void <init>(org.apache.avro.Schema);
descriptor: (Lorg/apache/avro/Schema;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
aload 1
invokestatic org.apache.avro.reflect.ReflectData.get:()Lorg/apache/avro/reflect/ReflectData;
invokespecial org.apache.avro.reflect.ReflectDatumReader.<init>:(Lorg/apache/avro/Schema;Lorg/apache/avro/Schema;Lorg/apache/avro/reflect/ReflectData;)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/avro/reflect/ReflectDatumReader<TT;>;
0 2 1 root Lorg/apache/avro/Schema;
MethodParameters:
Name Flags
root
public void <init>(org.apache.avro.Schema, org.apache.avro.Schema);
descriptor: (Lorg/apache/avro/Schema;Lorg/apache/avro/Schema;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
aload 2
invokestatic org.apache.avro.reflect.ReflectData.get:()Lorg/apache/avro/reflect/ReflectData;
invokespecial org.apache.avro.reflect.ReflectDatumReader.<init>:(Lorg/apache/avro/Schema;Lorg/apache/avro/Schema;Lorg/apache/avro/reflect/ReflectData;)V
1: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/avro/reflect/ReflectDatumReader<TT;>;
0 2 1 writer Lorg/apache/avro/Schema;
0 2 2 reader Lorg/apache/avro/Schema;
MethodParameters:
Name Flags
writer
reader
public void <init>(org.apache.avro.Schema, org.apache.avro.Schema, org.apache.avro.reflect.ReflectData);
descriptor: (Lorg/apache/avro/Schema;Lorg/apache/avro/Schema;Lorg/apache/avro/reflect/ReflectData;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
aload 1
aload 2
aload 3
invokespecial org.apache.avro.specific.SpecificDatumReader.<init>:(Lorg/apache/avro/Schema;Lorg/apache/avro/Schema;Lorg/apache/avro/specific/SpecificData;)V
1: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/avro/reflect/ReflectDatumReader<TT;>;
0 2 1 writer Lorg/apache/avro/Schema;
0 2 2 reader Lorg/apache/avro/Schema;
0 2 3 data Lorg/apache/avro/reflect/ReflectData;
MethodParameters:
Name Flags
writer
reader
data
public void <init>(org.apache.avro.reflect.ReflectData);
descriptor: (Lorg/apache/avro/reflect/ReflectData;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokespecial org.apache.avro.specific.SpecificDatumReader.<init>:(Lorg/apache/avro/specific/SpecificData;)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/avro/reflect/ReflectDatumReader<TT;>;
0 2 1 data Lorg/apache/avro/reflect/ReflectData;
MethodParameters:
Name Flags
data
protected java.lang.Object newArray(java.lang.Object, int, org.apache.avro.Schema);
descriptor: (Ljava/lang/Object;ILorg/apache/avro/Schema;)Ljava/lang/Object;
flags: (0x0004) ACC_PROTECTED
Code:
stack=4, locals=7, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 3
ldc "java-class"
invokestatic org.apache.avro.reflect.ReflectData.getClassProp:(Lorg/apache/avro/Schema;Ljava/lang/String;)Ljava/lang/Class;
astore 4
start local 4 1: aload 3
ldc "java-element-class"
invokestatic org.apache.avro.reflect.ReflectData.getClassProp:(Lorg/apache/avro/Schema;Ljava/lang/String;)Ljava/lang/Class;
astore 5
start local 5 2: aload 5
ifnonnull 6
3: aload 0
invokevirtual org.apache.avro.reflect.ReflectDatumReader.getData:()Lorg/apache/avro/generic/GenericData;
aload 3
invokevirtual org.apache.avro.Schema.getElementType:()Lorg/apache/avro/Schema;
invokevirtual org.apache.avro.Schema.getLogicalType:()Lorg/apache/avro/LogicalType;
invokevirtual org.apache.avro.generic.GenericData.getConversionFor:(Lorg/apache/avro/LogicalType;)Lorg/apache/avro/Conversion;
astore 6
start local 6 4: aload 6
ifnull 6
5: aload 6
invokevirtual org.apache.avro.Conversion.getConvertedType:()Ljava/lang/Class;
astore 5
end local 6 6: StackMap locals: java.lang.Class java.lang.Class
StackMap stack:
aload 4
ifnonnull 8
aload 5
ifnonnull 8
7: aload 0
aload 1
iload 2
aload 3
invokespecial org.apache.avro.specific.SpecificDatumReader.newArray:(Ljava/lang/Object;ILorg/apache/avro/Schema;)Ljava/lang/Object;
areturn
8: StackMap locals:
StackMap stack:
aload 4
ifnull 15
aload 4
invokevirtual java.lang.Class.isArray:()Z
ifne 15
9: aload 1
instanceof java.util.Collection
ifeq 12
10: aload 1
checkcast java.util.Collection
invokeinterface java.util.Collection.clear:()V
11: aload 1
areturn
12: StackMap locals:
StackMap stack:
aload 4
ldc Ljava/util/ArrayList;
invokevirtual java.lang.Class.isAssignableFrom:(Ljava/lang/Class;)Z
ifeq 14
13: new java.util.ArrayList
dup
invokespecial java.util.ArrayList.<init>:()V
areturn
14: StackMap locals:
StackMap stack:
aload 4
aload 3
invokestatic org.apache.avro.specific.SpecificData.newInstance:(Ljava/lang/Class;Lorg/apache/avro/Schema;)Ljava/lang/Object;
areturn
15: StackMap locals:
StackMap stack:
aload 5
ifnonnull 17
16: aload 4
invokevirtual java.lang.Class.getComponentType:()Ljava/lang/Class;
astore 5
17: StackMap locals:
StackMap stack:
aload 5
ifnonnull 20
18: aload 0
invokevirtual org.apache.avro.reflect.ReflectDatumReader.getData:()Lorg/apache/avro/generic/GenericData;
checkcast org.apache.avro.reflect.ReflectData
astore 6
start local 6 19: aload 6
aload 3
invokevirtual org.apache.avro.Schema.getElementType:()Lorg/apache/avro/Schema;
invokevirtual org.apache.avro.reflect.ReflectData.getClass:(Lorg/apache/avro/Schema;)Ljava/lang/Class;
astore 5
end local 6 20: StackMap locals:
StackMap stack:
aload 5
iload 2
invokestatic java.lang.reflect.Array.newInstance:(Ljava/lang/Class;I)Ljava/lang/Object;
areturn
end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 21 0 this Lorg/apache/avro/reflect/ReflectDatumReader<TT;>;
0 21 1 old Ljava/lang/Object;
0 21 2 size I
0 21 3 schema Lorg/apache/avro/Schema;
1 21 4 collectionClass Ljava/lang/Class<*>;
2 21 5 elementClass Ljava/lang/Class<*>;
4 6 6 elementConversion Lorg/apache/avro/Conversion<*>;
19 20 6 data Lorg/apache/avro/reflect/ReflectData;
MethodParameters:
Name Flags
old
size
schema
protected java.lang.Object peekArray(java.lang.Object);
descriptor: (Ljava/lang/Object;)Ljava/lang/Object;
flags: (0x0004) ACC_PROTECTED
Code:
stack=1, locals=2, args_size=2
start local 0 start local 1 0: aconst_null
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/avro/reflect/ReflectDatumReader<TT;>;
0 1 1 array Ljava/lang/Object;
MethodParameters:
Name Flags
array
protected void addToArray(java.lang.Object, long, java.lang.Object);
descriptor: (Ljava/lang/Object;JLjava/lang/Object;)V
flags: (0x0004) ACC_PROTECTED
Code:
stack=3, locals=5, args_size=4
start local 0 start local 1 start local 2 start local 4 0: new org.apache.avro.AvroRuntimeException
dup
ldc "reflectDatumReader does not use addToArray"
invokespecial org.apache.avro.AvroRuntimeException.<init>:(Ljava/lang/String;)V
athrow
end local 4 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/avro/reflect/ReflectDatumReader<TT;>;
0 1 1 array Ljava/lang/Object;
0 1 2 pos J
0 1 4 e Ljava/lang/Object;
MethodParameters:
Name Flags
array
pos
e
protected java.lang.Object readArray(java.lang.Object, org.apache.avro.Schema, org.apache.avro.io.ResolvingDecoder);
descriptor: (Ljava/lang/Object;Lorg/apache/avro/Schema;Lorg/apache/avro/io/ResolvingDecoder;)Ljava/lang/Object;
flags: (0x0004) ACC_PROTECTED
Code:
stack=6, locals=15, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 2
invokevirtual org.apache.avro.Schema.getElementType:()Lorg/apache/avro/Schema;
astore 4
start local 4 1: aload 3
invokevirtual org.apache.avro.io.ResolvingDecoder.readArrayStart:()J
lstore 5
start local 5 2: lload 5
lconst_0
lcmp
ifgt 4
3: aload 0
aload 1
iconst_0
aload 2
invokevirtual org.apache.avro.reflect.ReflectDatumReader.newArray:(Ljava/lang/Object;ILorg/apache/avro/Schema;)Ljava/lang/Object;
areturn
4: StackMap locals: org.apache.avro.Schema long
StackMap stack:
aload 0
aload 1
lload 5
l2i
aload 2
invokevirtual org.apache.avro.reflect.ReflectDatumReader.newArray:(Ljava/lang/Object;ILorg/apache/avro/Schema;)Ljava/lang/Object;
astore 7
start local 7 5: aload 7
instanceof java.util.Collection
ifeq 8
6: aload 7
checkcast java.util.Collection
astore 8
start local 8 7: aload 0
aload 8
aload 4
lload 5
aload 3
invokevirtual org.apache.avro.reflect.ReflectDatumReader.readCollection:(Ljava/util/Collection;Lorg/apache/avro/Schema;JLorg/apache/avro/io/ResolvingDecoder;)Ljava/lang/Object;
areturn
end local 8 8: StackMap locals: java.lang.Object
StackMap stack:
aload 7
instanceof java.util.Map
ifeq 23
9: aload 2
invokestatic org.apache.avro.reflect.ReflectData.isNonStringMapSchema:(Lorg/apache/avro/Schema;)Z
ifeq 21
10: new java.util.ArrayList
dup
invokespecial java.util.ArrayList.<init>:()V
astore 8
start local 8 11: aload 0
aload 8
aload 4
lload 5
aload 3
invokevirtual org.apache.avro.reflect.ReflectDatumReader.readCollection:(Ljava/util/Collection;Lorg/apache/avro/Schema;JLorg/apache/avro/io/ResolvingDecoder;)Ljava/lang/Object;
pop
12: aload 7
checkcast java.util.Map
astore 9
start local 9 13: aload 8
invokeinterface java.util.Collection.iterator:()Ljava/util/Iterator;
astore 11
goto 19
StackMap locals: org.apache.avro.reflect.ReflectDatumReader java.lang.Object org.apache.avro.Schema org.apache.avro.io.ResolvingDecoder org.apache.avro.Schema long java.lang.Object java.util.Collection java.util.Map top java.util.Iterator
StackMap stack:
14: aload 11
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
astore 10
start local 10 15: aload 10
checkcast org.apache.avro.generic.IndexedRecord
astore 12
start local 12 16: aload 12
iconst_0
invokeinterface org.apache.avro.generic.IndexedRecord.get:(I)Ljava/lang/Object;
astore 13
start local 13 17: aload 12
iconst_1
invokeinterface org.apache.avro.generic.IndexedRecord.get:(I)Ljava/lang/Object;
astore 14
start local 14 18: aload 9
aload 13
aload 14
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
end local 14 end local 13 end local 12 end local 10 19: StackMap locals:
StackMap stack:
aload 11
invokeinterface java.util.Iterator.hasNext:()Z
ifne 14
20: aload 7
areturn
end local 9 end local 8 21: StackMap locals: org.apache.avro.reflect.ReflectDatumReader java.lang.Object org.apache.avro.Schema org.apache.avro.io.ResolvingDecoder org.apache.avro.Schema long java.lang.Object
StackMap stack:
new java.lang.StringBuilder
dup
ldc "Expected a schema of map with non-string keys but got "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 2
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
astore 8
start local 8 22: new org.apache.avro.AvroRuntimeException
dup
aload 8
invokespecial org.apache.avro.AvroRuntimeException.<init>:(Ljava/lang/String;)V
athrow
end local 8 23: StackMap locals:
StackMap stack:
aload 0
aload 7
aload 4
lload 5
aload 3
invokevirtual org.apache.avro.reflect.ReflectDatumReader.readJavaArray:(Ljava/lang/Object;Lorg/apache/avro/Schema;JLorg/apache/avro/io/ResolvingDecoder;)Ljava/lang/Object;
areturn
end local 7 end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 24 0 this Lorg/apache/avro/reflect/ReflectDatumReader<TT;>;
0 24 1 old Ljava/lang/Object;
0 24 2 expected Lorg/apache/avro/Schema;
0 24 3 in Lorg/apache/avro/io/ResolvingDecoder;
1 24 4 expectedType Lorg/apache/avro/Schema;
2 24 5 l J
5 24 7 array Ljava/lang/Object;
7 8 8 c Ljava/util/Collection<Ljava/lang/Object;>;
11 21 8 c Ljava/util/Collection<Ljava/lang/Object;>;
13 21 9 m Ljava/util/Map;
15 19 10 ele Ljava/lang/Object;
16 19 12 rec Lorg/apache/avro/generic/IndexedRecord;
17 19 13 key Ljava/lang/Object;
18 19 14 value Ljava/lang/Object;
22 23 8 msg Ljava/lang/String;
Exceptions:
throws java.io.IOException
MethodParameters:
Name Flags
old
expected
in
private java.lang.Object readJavaArray(java.lang.Object, org.apache.avro.Schema, long, org.apache.avro.io.ResolvingDecoder);
descriptor: (Ljava/lang/Object;Lorg/apache/avro/Schema;JLorg/apache/avro/io/ResolvingDecoder;)Ljava/lang/Object;
flags: (0x0002) ACC_PRIVATE
Code:
stack=6, locals=7, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 5 0: aload 1
invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
invokevirtual java.lang.Class.getComponentType:()Ljava/lang/Class;
astore 6
start local 6 1: aload 6
invokevirtual java.lang.Class.isPrimitive:()Z
ifeq 3
2: aload 0
aload 1
aload 6
lload 3
aload 5
invokevirtual org.apache.avro.reflect.ReflectDatumReader.readPrimitiveArray:(Ljava/lang/Object;Ljava/lang/Class;JLorg/apache/avro/io/ResolvingDecoder;)Ljava/lang/Object;
areturn
3: StackMap locals: java.lang.Class
StackMap stack:
aload 0
aload 1
checkcast java.lang.Object[]
aload 2
lload 3
aload 5
invokevirtual org.apache.avro.reflect.ReflectDatumReader.readObjectArray:([Ljava/lang/Object;Lorg/apache/avro/Schema;JLorg/apache/avro/io/ResolvingDecoder;)Ljava/lang/Object;
areturn
end local 6 end local 5 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lorg/apache/avro/reflect/ReflectDatumReader<TT;>;
0 4 1 array Ljava/lang/Object;
0 4 2 expectedType Lorg/apache/avro/Schema;
0 4 3 l J
0 4 5 in Lorg/apache/avro/io/ResolvingDecoder;
1 4 6 elementType Ljava/lang/Class<*>;
Exceptions:
throws java.io.IOException
MethodParameters:
Name Flags
array
expectedType
l
in
private readPrimitiveArray(, java.lang.Class<?>, long, org.apache.avro.io.ResolvingDecoder);
descriptor: (Ljava/lang/Object;Ljava/lang/Class;JLorg/apache/avro/io/ResolvingDecoder;)Ljava/lang/Object;
flags: (0x0002) ACC_PRIVATE
Code:
stack=5, locals=6, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 5 0: aload 1
aload 2
lload 3
aload 5
invokestatic org.apache.avro.reflect.ArrayAccessor.readArray:(Ljava/lang/Object;Ljava/lang/Class;JLorg/apache/avro/io/ResolvingDecoder;)Ljava/lang/Object;
areturn
end local 5 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/avro/reflect/ReflectDatumReader<TT;>;
0 1 1 array Ljava/lang/Object;
0 1 2 c Ljava/lang/Class<*>;
0 1 3 l J
0 1 5 in Lorg/apache/avro/io/ResolvingDecoder;
Exceptions:
throws java.io.IOException
Signature: (Ljava/lang/Object;Ljava/lang/Class<*>;JLorg/apache/avro/io/ResolvingDecoder;)Ljava/lang/Object;
MethodParameters:
Name Flags
array
c
l
in
private java.lang.Object readObjectArray(java.lang.Object[], org.apache.avro.Schema, long, org.apache.avro.io.ResolvingDecoder);
descriptor: ([Ljava/lang/Object;Lorg/apache/avro/Schema;JLorg/apache/avro/io/ResolvingDecoder;)Ljava/lang/Object;
flags: (0x0002) ACC_PRIVATE
Code:
stack=6, locals=11, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 5 0: aload 2
invokevirtual org.apache.avro.Schema.getLogicalType:()Lorg/apache/avro/LogicalType;
astore 6
start local 6 1: aload 0
invokevirtual org.apache.avro.reflect.ReflectDatumReader.getData:()Lorg/apache/avro/generic/GenericData;
aload 6
invokevirtual org.apache.avro.generic.GenericData.getConversionFor:(Lorg/apache/avro/LogicalType;)Lorg/apache/avro/Conversion;
astore 7
start local 7 2: iconst_0
istore 8
start local 8 3: aload 6
ifnull 13
aload 7
ifnull 13
4: StackMap locals: org.apache.avro.LogicalType org.apache.avro.Conversion int
StackMap stack:
iload 8
lload 3
l2i
iadd
istore 9
start local 9 5: goto 9
6: StackMap locals: int
StackMap stack:
aload 0
aconst_null
aload 2
aload 6
aload 7
aload 5
invokevirtual org.apache.avro.reflect.ReflectDatumReader.readWithConversion:(Ljava/lang/Object;Lorg/apache/avro/Schema;Lorg/apache/avro/LogicalType;Lorg/apache/avro/Conversion;Lorg/apache/avro/io/ResolvingDecoder;)Ljava/lang/Object;
astore 10
start local 10 7: aload 1
iload 8
aload 10
aastore
8: iinc 8 1
end local 10 9: StackMap locals:
StackMap stack:
iload 8
iload 9
if_icmplt 6
end local 9 10: aload 5
invokevirtual org.apache.avro.io.ResolvingDecoder.arrayNext:()J
dup2
lstore 3
lconst_0
11: lcmp
ifgt 4
12: goto 21
13: StackMap locals:
StackMap stack:
iload 8
lload 3
l2i
iadd
istore 9
start local 9 14: goto 18
15: StackMap locals: int
StackMap stack:
aload 0
aconst_null
aload 2
aload 5
invokevirtual org.apache.avro.reflect.ReflectDatumReader.readWithoutConversion:(Ljava/lang/Object;Lorg/apache/avro/Schema;Lorg/apache/avro/io/ResolvingDecoder;)Ljava/lang/Object;
astore 10
start local 10 16: aload 1
iload 8
aload 10
aastore
17: iinc 8 1
end local 10 18: StackMap locals:
StackMap stack:
iload 8
iload 9
if_icmplt 15
end local 9 19: aload 5
invokevirtual org.apache.avro.io.ResolvingDecoder.arrayNext:()J
dup2
lstore 3
lconst_0
20: lcmp
ifgt 13
21: StackMap locals:
StackMap stack:
aload 1
areturn
end local 8 end local 7 end local 6 end local 5 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 22 0 this Lorg/apache/avro/reflect/ReflectDatumReader<TT;>;
0 22 1 array [Ljava/lang/Object;
0 22 2 expectedType Lorg/apache/avro/Schema;
0 22 3 l J
0 22 5 in Lorg/apache/avro/io/ResolvingDecoder;
1 22 6 logicalType Lorg/apache/avro/LogicalType;
2 22 7 conversion Lorg/apache/avro/Conversion<*>;
3 22 8 index I
5 10 9 limit I
7 9 10 element Ljava/lang/Object;
14 19 9 limit I
16 18 10 element Ljava/lang/Object;
Exceptions:
throws java.io.IOException
MethodParameters:
Name Flags
array
expectedType
l
in
private readCollection(java.util.Collection<java.lang.Object>, org.apache.avro.Schema, long, org.apache.avro.io.ResolvingDecoder);
descriptor: (Ljava/util/Collection;Lorg/apache/avro/Schema;JLorg/apache/avro/io/ResolvingDecoder;)Ljava/lang/Object;
flags: (0x0002) ACC_PRIVATE
Code:
stack=6, locals=10, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 5 0: aload 2
invokevirtual org.apache.avro.Schema.getLogicalType:()Lorg/apache/avro/LogicalType;
astore 6
start local 6 1: aload 0
invokevirtual org.apache.avro.reflect.ReflectDatumReader.getData:()Lorg/apache/avro/generic/GenericData;
aload 6
invokevirtual org.apache.avro.generic.GenericData.getConversionFor:(Lorg/apache/avro/LogicalType;)Lorg/apache/avro/Conversion;
astore 7
start local 7 2: aload 6
ifnull 12
aload 7
ifnull 12
3: StackMap locals: org.apache.avro.LogicalType org.apache.avro.Conversion
StackMap stack:
iconst_0
istore 8
start local 8 4: goto 8
5: StackMap locals: int
StackMap stack:
aload 0
aconst_null
aload 2
aload 6
aload 7
aload 5
invokevirtual org.apache.avro.reflect.ReflectDatumReader.readWithConversion:(Ljava/lang/Object;Lorg/apache/avro/Schema;Lorg/apache/avro/LogicalType;Lorg/apache/avro/Conversion;Lorg/apache/avro/io/ResolvingDecoder;)Ljava/lang/Object;
astore 9
start local 9 6: aload 1
aload 9
invokeinterface java.util.Collection.add:(Ljava/lang/Object;)Z
pop
end local 9 7: iinc 8 1
StackMap locals:
StackMap stack:
8: iload 8
i2l
lload 3
lcmp
iflt 5
end local 8 9: aload 5
invokevirtual org.apache.avro.io.ResolvingDecoder.arrayNext:()J
dup2
lstore 3
lconst_0
10: lcmp
ifgt 3
11: goto 20
12: StackMap locals:
StackMap stack:
iconst_0
istore 8
start local 8 13: goto 17
14: StackMap locals: int
StackMap stack:
aload 0
aconst_null
aload 2
aload 5
invokevirtual org.apache.avro.reflect.ReflectDatumReader.readWithoutConversion:(Ljava/lang/Object;Lorg/apache/avro/Schema;Lorg/apache/avro/io/ResolvingDecoder;)Ljava/lang/Object;
astore 9
start local 9 15: aload 1
aload 9
invokeinterface java.util.Collection.add:(Ljava/lang/Object;)Z
pop
end local 9 16: iinc 8 1
StackMap locals:
StackMap stack:
17: iload 8
i2l
lload 3
lcmp
iflt 14
end local 8 18: aload 5
invokevirtual org.apache.avro.io.ResolvingDecoder.arrayNext:()J
dup2
lstore 3
lconst_0
19: lcmp
ifgt 12
20: StackMap locals:
StackMap stack:
aload 1
areturn
end local 7 end local 6 end local 5 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 21 0 this Lorg/apache/avro/reflect/ReflectDatumReader<TT;>;
0 21 1 c Ljava/util/Collection<Ljava/lang/Object;>;
0 21 2 expectedType Lorg/apache/avro/Schema;
0 21 3 l J
0 21 5 in Lorg/apache/avro/io/ResolvingDecoder;
1 21 6 logicalType Lorg/apache/avro/LogicalType;
2 21 7 conversion Lorg/apache/avro/Conversion<*>;
4 9 8 i I
6 7 9 element Ljava/lang/Object;
13 18 8 i I
15 16 9 element Ljava/lang/Object;
Exceptions:
throws java.io.IOException
Signature: (Ljava/util/Collection<Ljava/lang/Object;>;Lorg/apache/avro/Schema;JLorg/apache/avro/io/ResolvingDecoder;)Ljava/lang/Object;
MethodParameters:
Name Flags
c
expectedType
l
in
protected java.lang.Object readString(java.lang.Object, org.apache.avro.io.Decoder);
descriptor: (Ljava/lang/Object;Lorg/apache/avro/io/Decoder;)Ljava/lang/Object;
flags: (0x0004) ACC_PROTECTED
Code:
stack=3, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aconst_null
aload 2
invokespecial org.apache.avro.specific.SpecificDatumReader.readString:(Ljava/lang/Object;Lorg/apache/avro/io/Decoder;)Ljava/lang/Object;
invokevirtual java.lang.Object.toString:()Ljava/lang/String;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/avro/reflect/ReflectDatumReader<TT;>;
0 1 1 old Ljava/lang/Object;
0 1 2 in Lorg/apache/avro/io/Decoder;
Exceptions:
throws java.io.IOException
MethodParameters:
Name Flags
old
in
protected java.lang.Object createString(java.lang.String);
descriptor: (Ljava/lang/String;)Ljava/lang/Object;
flags: (0x0004) ACC_PROTECTED
Code:
stack=1, locals=2, args_size=2
start local 0 start local 1 0: aload 1
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/avro/reflect/ReflectDatumReader<TT;>;
0 1 1 value Ljava/lang/String;
MethodParameters:
Name Flags
value
protected java.lang.Object readBytes(java.lang.Object, org.apache.avro.Schema, org.apache.avro.io.Decoder);
descriptor: (Ljava/lang/Object;Lorg/apache/avro/Schema;Lorg/apache/avro/io/Decoder;)Ljava/lang/Object;
flags: (0x0004) ACC_PROTECTED
Code:
stack=2, locals=7, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 3
aconst_null
invokevirtual org.apache.avro.io.Decoder.readBytes:(Ljava/nio/ByteBuffer;)Ljava/nio/ByteBuffer;
astore 4
start local 4 1: aload 2
ldc "java-class"
invokestatic org.apache.avro.reflect.ReflectData.getClassProp:(Lorg/apache/avro/Schema;Ljava/lang/String;)Ljava/lang/Class;
astore 5
start local 5 2: aload 5
ifnull 6
aload 5
invokevirtual java.lang.Class.isArray:()Z
ifeq 6
3: aload 4
invokevirtual java.nio.ByteBuffer.remaining:()I
newarray 8
astore 6
start local 6 4: aload 4
aload 6
invokevirtual java.nio.ByteBuffer.get:([B)Ljava/nio/ByteBuffer;
pop
5: aload 6
areturn
end local 6 6: StackMap locals: java.nio.ByteBuffer java.lang.Class
StackMap stack:
aload 4
areturn
end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lorg/apache/avro/reflect/ReflectDatumReader<TT;>;
0 7 1 old Ljava/lang/Object;
0 7 2 s Lorg/apache/avro/Schema;
0 7 3 in Lorg/apache/avro/io/Decoder;
1 7 4 bytes Ljava/nio/ByteBuffer;
2 7 5 c Ljava/lang/Class<*>;
4 6 6 result [B
Exceptions:
throws java.io.IOException
MethodParameters:
Name Flags
old
s
in
protected java.lang.Object readInt(java.lang.Object, org.apache.avro.Schema, org.apache.avro.io.Decoder);
descriptor: (Ljava/lang/Object;Lorg/apache/avro/Schema;Lorg/apache/avro/io/Decoder;)Ljava/lang/Object;
flags: (0x0004) ACC_PROTECTED
Code:
stack=2, locals=6, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 3
invokevirtual org.apache.avro.io.Decoder.readInt:()I
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
astore 4
start local 4 1: aload 2
ldc "java-class"
invokevirtual org.apache.avro.Schema.getProp:(Ljava/lang/String;)Ljava/lang/String;
astore 5
start local 5 2: ldc Ljava/lang/Byte;
invokevirtual java.lang.Class.getName:()Ljava/lang/String;
aload 5
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifeq 4
3: aload 4
checkcast java.lang.Integer
invokevirtual java.lang.Integer.byteValue:()B
invokestatic java.lang.Byte.valueOf:(B)Ljava/lang/Byte;
astore 4
goto 8
4: StackMap locals: java.lang.Object java.lang.String
StackMap stack:
ldc Ljava/lang/Short;
invokevirtual java.lang.Class.getName:()Ljava/lang/String;
aload 5
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifeq 6
5: aload 4
checkcast java.lang.Integer
invokevirtual java.lang.Integer.shortValue:()S
invokestatic java.lang.Short.valueOf:(S)Ljava/lang/Short;
astore 4
goto 8
6: StackMap locals:
StackMap stack:
ldc Ljava/lang/Character;
invokevirtual java.lang.Class.getName:()Ljava/lang/String;
aload 5
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifeq 8
7: aload 4
checkcast java.lang.Integer
invokevirtual java.lang.Integer.intValue:()I
i2c
invokestatic java.lang.Character.valueOf:(C)Ljava/lang/Character;
astore 4
8: StackMap locals:
StackMap stack:
aload 4
areturn
end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lorg/apache/avro/reflect/ReflectDatumReader<TT;>;
0 9 1 old Ljava/lang/Object;
0 9 2 expected Lorg/apache/avro/Schema;
0 9 3 in Lorg/apache/avro/io/Decoder;
1 9 4 value Ljava/lang/Object;
2 9 5 intClass Ljava/lang/String;
Exceptions:
throws java.io.IOException
MethodParameters:
Name Flags
old
expected
in
protected void readField(java.lang.Object, org.apache.avro.Schema$Field, java.lang.Object, org.apache.avro.io.ResolvingDecoder, java.lang.Object);
descriptor: (Ljava/lang/Object;Lorg/apache/avro/Schema$Field;Ljava/lang/Object;Lorg/apache/avro/io/ResolvingDecoder;Ljava/lang/Object;)V
flags: (0x0004) ACC_PROTECTED
Code:
stack=7, locals=9, args_size=6
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 0: aload 5
ifnull 30
1: aload 5
checkcast org.apache.avro.reflect.FieldAccessor[]
aload 2
invokevirtual org.apache.avro.Schema$Field.pos:()I
aaload
astore 6
start local 6 2: aload 6
ifnull 30
3: aload 6
invokevirtual org.apache.avro.reflect.FieldAccessor.supportsIO:()Z
ifeq 6
getstatic org.apache.avro.Schema$Type.UNION:Lorg/apache/avro/Schema$Type;
aload 2
invokevirtual org.apache.avro.Schema$Field.schema:()Lorg/apache/avro/Schema;
invokevirtual org.apache.avro.Schema.getType:()Lorg/apache/avro/Schema$Type;
invokevirtual org.apache.avro.Schema$Type.equals:(Ljava/lang/Object;)Z
ifeq 4
aload 6
invokevirtual org.apache.avro.reflect.FieldAccessor.isCustomEncoded:()Z
ifeq 6
4: StackMap locals: org.apache.avro.reflect.FieldAccessor
StackMap stack:
aload 6
aload 1
aload 4
invokevirtual org.apache.avro.reflect.FieldAccessor.read:(Ljava/lang/Object;Lorg/apache/avro/io/Decoder;)V
5: return
6: StackMap locals:
StackMap stack:
aload 6
invokevirtual org.apache.avro.reflect.FieldAccessor.isStringable:()Z
ifeq 15
7: aload 0
aconst_null
aload 2
invokevirtual org.apache.avro.Schema$Field.schema:()Lorg/apache/avro/Schema;
aload 4
invokevirtual org.apache.avro.reflect.ReflectDatumReader.read:(Ljava/lang/Object;Lorg/apache/avro/Schema;Lorg/apache/avro/io/ResolvingDecoder;)Ljava/lang/Object;
checkcast java.lang.String
astore 7
start local 7 8: aload 6
aload 1
9: aload 7
ifnonnull 10
aconst_null
goto 11
StackMap locals: org.apache.avro.reflect.ReflectDatumReader java.lang.Object org.apache.avro.Schema$Field java.lang.Object org.apache.avro.io.ResolvingDecoder java.lang.Object org.apache.avro.reflect.FieldAccessor java.lang.String
StackMap stack: org.apache.avro.reflect.FieldAccessor java.lang.Object
10: aload 0
aload 6
invokevirtual org.apache.avro.reflect.FieldAccessor.getField:()Ljava/lang/reflect/Field;
invokevirtual java.lang.reflect.Field.getType:()Ljava/lang/Class;
aload 7
invokevirtual org.apache.avro.reflect.ReflectDatumReader.newInstanceFromString:(Ljava/lang/Class;Ljava/lang/String;)Ljava/lang/Object;
11: StackMap locals: org.apache.avro.reflect.ReflectDatumReader java.lang.Object org.apache.avro.Schema$Field java.lang.Object org.apache.avro.io.ResolvingDecoder java.lang.Object org.apache.avro.reflect.FieldAccessor java.lang.String
StackMap stack: org.apache.avro.reflect.FieldAccessor java.lang.Object java.lang.Object
invokevirtual org.apache.avro.reflect.FieldAccessor.set:(Ljava/lang/Object;Ljava/lang/Object;)V
12: return
end local 7 13: StackMap locals: org.apache.avro.reflect.ReflectDatumReader java.lang.Object org.apache.avro.Schema$Field java.lang.Object org.apache.avro.io.ResolvingDecoder java.lang.Object org.apache.avro.reflect.FieldAccessor
StackMap stack: java.lang.Exception
astore 7
start local 7 14: new org.apache.avro.AvroRuntimeException
dup
ldc "Failed to read Stringable"
aload 7
invokespecial org.apache.avro.AvroRuntimeException.<init>:(Ljava/lang/String;Ljava/lang/Throwable;)V
athrow
end local 7 15: StackMap locals:
StackMap stack:
aload 2
invokevirtual org.apache.avro.Schema$Field.schema:()Lorg/apache/avro/Schema;
invokevirtual org.apache.avro.Schema.getLogicalType:()Lorg/apache/avro/LogicalType;
astore 7
start local 7 16: aload 7
ifnull 26
17: aload 0
invokevirtual org.apache.avro.reflect.ReflectDatumReader.getData:()Lorg/apache/avro/generic/GenericData;
aload 6
invokevirtual org.apache.avro.reflect.FieldAccessor.getField:()Ljava/lang/reflect/Field;
invokevirtual java.lang.reflect.Field.getType:()Ljava/lang/Class;
aload 7
invokevirtual org.apache.avro.generic.GenericData.getConversionByClass:(Ljava/lang/Class;Lorg/apache/avro/LogicalType;)Lorg/apache/avro/Conversion;
astore 8
start local 8 18: aload 8
ifnull 26
19: aload 6
aload 1
20: aload 0
aload 0
aload 3
aload 2
invokevirtual org.apache.avro.Schema$Field.schema:()Lorg/apache/avro/Schema;
aload 4
invokevirtual org.apache.avro.reflect.ReflectDatumReader.readWithoutConversion:(Ljava/lang/Object;Lorg/apache/avro/Schema;Lorg/apache/avro/io/ResolvingDecoder;)Ljava/lang/Object;
aload 2
invokevirtual org.apache.avro.Schema$Field.schema:()Lorg/apache/avro/Schema;
aload 7
aload 8
invokevirtual org.apache.avro.reflect.ReflectDatumReader.convert:(Ljava/lang/Object;Lorg/apache/avro/Schema;Lorg/apache/avro/LogicalType;Lorg/apache/avro/Conversion;)Ljava/lang/Object;
21: invokevirtual org.apache.avro.reflect.FieldAccessor.set:(Ljava/lang/Object;Ljava/lang/Object;)V
22: goto 25
StackMap locals: org.apache.avro.reflect.ReflectDatumReader java.lang.Object org.apache.avro.Schema$Field java.lang.Object org.apache.avro.io.ResolvingDecoder java.lang.Object org.apache.avro.reflect.FieldAccessor org.apache.avro.LogicalType org.apache.avro.Conversion
StackMap stack: java.lang.IllegalAccessException
23: pop
24: new org.apache.avro.AvroRuntimeException
dup
new java.lang.StringBuilder
dup
ldc "Failed to set "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 2
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokespecial org.apache.avro.AvroRuntimeException.<init>:(Ljava/lang/String;)V
athrow
25: StackMap locals:
StackMap stack:
return
end local 8 26: StackMap locals:
StackMap stack:
aload 6
aload 1
aload 0
aload 3
aload 2
invokevirtual org.apache.avro.Schema$Field.schema:()Lorg/apache/avro/Schema;
aload 4
invokevirtual org.apache.avro.reflect.ReflectDatumReader.readWithoutConversion:(Ljava/lang/Object;Lorg/apache/avro/Schema;Lorg/apache/avro/io/ResolvingDecoder;)Ljava/lang/Object;
invokevirtual org.apache.avro.reflect.FieldAccessor.set:(Ljava/lang/Object;Ljava/lang/Object;)V
27: return
28: StackMap locals:
StackMap stack: java.lang.IllegalAccessException
pop
29: new org.apache.avro.AvroRuntimeException
dup
new java.lang.StringBuilder
dup
ldc "Failed to set "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 2
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokespecial org.apache.avro.AvroRuntimeException.<init>:(Ljava/lang/String;)V
athrow
end local 7 end local 6 30: StackMap locals:
StackMap stack:
aload 0
aload 1
aload 2
aload 3
aload 4
aload 5
invokespecial org.apache.avro.specific.SpecificDatumReader.readField:(Ljava/lang/Object;Lorg/apache/avro/Schema$Field;Ljava/lang/Object;Lorg/apache/avro/io/ResolvingDecoder;Ljava/lang/Object;)V
31: return
end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 32 0 this Lorg/apache/avro/reflect/ReflectDatumReader<TT;>;
0 32 1 record Ljava/lang/Object;
0 32 2 f Lorg/apache/avro/Schema$Field;
0 32 3 oldDatum Ljava/lang/Object;
0 32 4 in Lorg/apache/avro/io/ResolvingDecoder;
0 32 5 state Ljava/lang/Object;
2 30 6 accessor Lorg/apache/avro/reflect/FieldAccessor;
8 13 7 asString Ljava/lang/String;
14 15 7 e Ljava/lang/Exception;
16 30 7 logicalType Lorg/apache/avro/LogicalType;
18 26 8 conversion Lorg/apache/avro/Conversion<*>;
Exception table:
from to target type
7 12 13 Class java.lang.Exception
19 22 23 Class java.lang.IllegalAccessException
26 27 28 Class java.lang.IllegalAccessException
Exceptions:
throws java.io.IOException
MethodParameters:
Name Flags
record
f
oldDatum
in
state
}
Signature: <T:Ljava/lang/Object;>Lorg/apache/avro/specific/SpecificDatumReader<TT;>;
SourceFile: "ReflectDatumReader.java"
InnerClasses:
public Field = org.apache.avro.Schema$Field of org.apache.avro.Schema
public final Type = org.apache.avro.Schema$Type of org.apache.avro.Schema