public class org.apache.avro.file.DataFileReader<D> extends org.apache.avro.file.DataFileStream<D> implements org.apache.avro.file.FileReader<D>
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: org.apache.avro.file.DataFileReader
super_class: org.apache.avro.file.DataFileStream
{
private org.apache.avro.file.DataFileReader$SeekableInputStream sin;
descriptor: Lorg/apache/avro/file/DataFileReader$SeekableInputStream;
flags: (0x0002) ACC_PRIVATE
private long blockStart;
descriptor: J
flags: (0x0002) ACC_PRIVATE
public static <D> org.apache.avro.file.FileReader<D> openReader(java.io.File, org.apache.avro.io.DatumReader<D>);
descriptor: (Ljava/io/File;Lorg/apache/avro/io/DatumReader;)Lorg/apache/avro/file/FileReader;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=4, args_size=2
start local 0 start local 1 0: new org.apache.avro.file.SeekableFileInput
dup
aload 0
invokespecial org.apache.avro.file.SeekableFileInput.<init>:(Ljava/io/File;)V
astore 2
start local 2 1: aload 2
aload 1
invokestatic org.apache.avro.file.DataFileReader.openReader:(Lorg/apache/avro/file/SeekableInput;Lorg/apache/avro/io/DatumReader;)Lorg/apache/avro/file/FileReader;
2: areturn
3: StackMap locals: java.io.File org.apache.avro.io.DatumReader org.apache.avro.file.SeekableFileInput
StackMap stack: java.lang.Throwable
astore 3
start local 3 4: aload 2
invokestatic org.apache.commons.compress.utils.IOUtils.closeQuietly:(Ljava/io/Closeable;)V
5: aload 3
athrow
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 file Ljava/io/File;
0 6 1 reader Lorg/apache/avro/io/DatumReader<TD;>;
1 6 2 input Lorg/apache/avro/file/SeekableFileInput;
4 6 3 e Ljava/lang/Throwable;
Exception table:
from to target type
1 2 3 Class java.lang.Throwable
Exceptions:
throws java.io.IOException
Signature: <D:Ljava/lang/Object;>(Ljava/io/File;Lorg/apache/avro/io/DatumReader<TD;>;)Lorg/apache/avro/file/FileReader<TD;>;
MethodParameters:
Name Flags
file
reader
public static <D> org.apache.avro.file.FileReader<D> openReader(org.apache.avro.file.SeekableInput, org.apache.avro.io.DatumReader<D>);
descriptor: (Lorg/apache/avro/file/SeekableInput;Lorg/apache/avro/io/DatumReader;)Lorg/apache/avro/file/FileReader;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=5, locals=4, args_size=2
start local 0 start local 1 0: aload 0
invokeinterface org.apache.avro.file.SeekableInput.length:()J
getstatic org.apache.avro.file.DataFileConstants.MAGIC:[B
arraylength
i2l
lcmp
ifge 2
1: new org.apache.avro.InvalidAvroMagicException
dup
ldc "Not an Avro data file"
invokespecial org.apache.avro.InvalidAvroMagicException.<init>:(Ljava/lang/String;)V
athrow
2: StackMap locals:
StackMap stack:
getstatic org.apache.avro.file.DataFileConstants.MAGIC:[B
arraylength
newarray 8
astore 2
start local 2 3: aload 0
lconst_0
invokeinterface org.apache.avro.file.SeekableInput.seek:(J)V
4: iconst_0
istore 3
start local 3 5: goto 7
StackMap locals: byte[] int
StackMap stack:
6: aload 0
aload 2
iload 3
aload 2
arraylength
iload 3
isub
invokeinterface org.apache.avro.file.SeekableInput.read:([BII)I
istore 3
StackMap locals:
StackMap stack:
7: iload 3
aload 2
arraylength
if_icmplt 6
end local 3 8: aload 0
lconst_0
invokeinterface org.apache.avro.file.SeekableInput.seek:(J)V
9: getstatic org.apache.avro.file.DataFileConstants.MAGIC:[B
aload 2
invokestatic java.util.Arrays.equals:([B[B)Z
ifeq 11
10: new org.apache.avro.file.DataFileReader
dup
aload 0
aload 1
invokespecial org.apache.avro.file.DataFileReader.<init>:(Lorg/apache/avro/file/SeekableInput;Lorg/apache/avro/io/DatumReader;)V
areturn
11: StackMap locals:
StackMap stack:
getstatic org.apache.avro.file.DataFileReader12.MAGIC:[B
aload 2
invokestatic java.util.Arrays.equals:([B[B)Z
ifeq 13
12: new org.apache.avro.file.DataFileReader12
dup
aload 0
aload 1
invokespecial org.apache.avro.file.DataFileReader12.<init>:(Lorg/apache/avro/file/SeekableInput;Lorg/apache/avro/io/DatumReader;)V
areturn
13: StackMap locals:
StackMap stack:
new org.apache.avro.InvalidAvroMagicException
dup
ldc "Not an Avro data file"
invokespecial org.apache.avro.InvalidAvroMagicException.<init>:(Ljava/lang/String;)V
athrow
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 14 0 in Lorg/apache/avro/file/SeekableInput;
0 14 1 reader Lorg/apache/avro/io/DatumReader<TD;>;
3 14 2 magic [B
5 8 3 c I
Exceptions:
throws java.io.IOException
Signature: <D:Ljava/lang/Object;>(Lorg/apache/avro/file/SeekableInput;Lorg/apache/avro/io/DatumReader<TD;>;)Lorg/apache/avro/file/FileReader<TD;>;
MethodParameters:
Name Flags
in
reader
public static <D> org.apache.avro.file.DataFileReader<D> openReader(org.apache.avro.file.SeekableInput, org.apache.avro.io.DatumReader<D>, org.apache.avro.file.DataFileStream$Header, boolean);
descriptor: (Lorg/apache/avro/file/SeekableInput;Lorg/apache/avro/io/DatumReader;Lorg/apache/avro/file/DataFileStream$Header;Z)Lorg/apache/avro/file/DataFileReader;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=5, locals=5, args_size=4
start local 0 start local 1 start local 2 start local 3 0: new org.apache.avro.file.DataFileReader
dup
aload 0
aload 1
aload 2
invokespecial org.apache.avro.file.DataFileReader.<init>:(Lorg/apache/avro/file/SeekableInput;Lorg/apache/avro/io/DatumReader;Lorg/apache/avro/file/DataFileStream$Header;)V
astore 4
start local 4 1: iload 3
ifeq 3
2: aload 4
aload 0
invokeinterface org.apache.avro.file.SeekableInput.tell:()J
invokevirtual org.apache.avro.file.DataFileReader.sync:(J)V
goto 4
3: StackMap locals: org.apache.avro.file.DataFileReader
StackMap stack:
aload 4
aload 0
invokeinterface org.apache.avro.file.SeekableInput.tell:()J
invokevirtual org.apache.avro.file.DataFileReader.seek:(J)V
4: StackMap locals:
StackMap stack:
aload 4
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 in Lorg/apache/avro/file/SeekableInput;
0 5 1 reader Lorg/apache/avro/io/DatumReader<TD;>;
0 5 2 header Lorg/apache/avro/file/DataFileStream$Header;
0 5 3 sync Z
1 5 4 dreader Lorg/apache/avro/file/DataFileReader<TD;>;
Exceptions:
throws java.io.IOException
Signature: <D:Ljava/lang/Object;>(Lorg/apache/avro/file/SeekableInput;Lorg/apache/avro/io/DatumReader<TD;>;Lorg/apache/avro/file/DataFileStream$Header;Z)Lorg/apache/avro/file/DataFileReader<TD;>;
MethodParameters:
Name Flags
in
reader
header
sync
public void <init>(java.io.File, org.apache.avro.io.DatumReader<D>);
descriptor: (Ljava/io/File;Lorg/apache/avro/io/DatumReader;)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
new org.apache.avro.file.SeekableFileInput
dup
aload 1
invokespecial org.apache.avro.file.SeekableFileInput.<init>:(Ljava/io/File;)V
aload 2
iconst_1
invokespecial org.apache.avro.file.DataFileReader.<init>:(Lorg/apache/avro/file/SeekableInput;Lorg/apache/avro/io/DatumReader;Z)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/file/DataFileReader<TD;>;
0 2 1 file Ljava/io/File;
0 2 2 reader Lorg/apache/avro/io/DatumReader<TD;>;
Exceptions:
throws java.io.IOException
Signature: (Ljava/io/File;Lorg/apache/avro/io/DatumReader<TD;>;)V
MethodParameters:
Name Flags
file
reader
public void <init>(org.apache.avro.file.SeekableInput, org.apache.avro.io.DatumReader<D>);
descriptor: (Lorg/apache/avro/file/SeekableInput;Lorg/apache/avro/io/DatumReader;)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
iconst_0
invokespecial org.apache.avro.file.DataFileReader.<init>:(Lorg/apache/avro/file/SeekableInput;Lorg/apache/avro/io/DatumReader;Z)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/file/DataFileReader<TD;>;
0 2 1 sin Lorg/apache/avro/file/SeekableInput;
0 2 2 reader Lorg/apache/avro/io/DatumReader<TD;>;
Exceptions:
throws java.io.IOException
Signature: (Lorg/apache/avro/file/SeekableInput;Lorg/apache/avro/io/DatumReader<TD;>;)V
MethodParameters:
Name Flags
sin
reader
protected void <init>(org.apache.avro.file.SeekableInput, org.apache.avro.io.DatumReader<D>, );
descriptor: (Lorg/apache/avro/file/SeekableInput;Lorg/apache/avro/io/DatumReader;Z)V
flags: (0x0004) ACC_PROTECTED
Code:
stack=4, locals=5, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
aload 2
invokespecial org.apache.avro.file.DataFileStream.<init>:(Lorg/apache/avro/io/DatumReader;)V
1: aload 0
new org.apache.avro.file.DataFileReader$SeekableInputStream
dup
aload 1
invokespecial org.apache.avro.file.DataFileReader$SeekableInputStream.<init>:(Lorg/apache/avro/file/SeekableInput;)V
putfield org.apache.avro.file.DataFileReader.sin:Lorg/apache/avro/file/DataFileReader$SeekableInputStream;
2: aload 0
aload 0
getfield org.apache.avro.file.DataFileReader.sin:Lorg/apache/avro/file/DataFileReader$SeekableInputStream;
invokevirtual org.apache.avro.file.DataFileReader.initialize:(Ljava/io/InputStream;)V
3: aload 0
invokevirtual org.apache.avro.file.DataFileReader.blockFinished:()V
4: goto 9
StackMap locals: org.apache.avro.file.DataFileReader org.apache.avro.file.SeekableInput org.apache.avro.io.DatumReader int
StackMap stack: java.lang.Throwable
5: astore 4
start local 4 6: iload 3
ifeq 8
7: aload 1
invokestatic org.apache.commons.compress.utils.IOUtils.closeQuietly:(Ljava/io/Closeable;)V
8: StackMap locals: java.lang.Throwable
StackMap stack:
aload 4
athrow
end local 4 9: StackMap locals:
StackMap stack:
return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 10 0 this Lorg/apache/avro/file/DataFileReader<TD;>;
0 10 1 sin Lorg/apache/avro/file/SeekableInput;
0 10 2 reader Lorg/apache/avro/io/DatumReader<TD;>;
0 10 3 closeOnError Z
6 9 4 e Ljava/lang/Throwable;
Exception table:
from to target type
1 4 5 Class java.lang.Throwable
Exceptions:
throws java.io.IOException
Signature: (Lorg/apache/avro/file/SeekableInput;Lorg/apache/avro/io/DatumReader<TD;>;Z)V
MethodParameters:
Name Flags
sin
reader
closeOnError
protected void <init>(org.apache.avro.file.SeekableInput, org.apache.avro.io.DatumReader<D>, org.apache.avro.file.DataFileStream$Header);
descriptor: (Lorg/apache/avro/file/SeekableInput;Lorg/apache/avro/io/DatumReader;Lorg/apache/avro/file/DataFileStream$Header;)V
flags: (0x0004) ACC_PROTECTED
Code:
stack=4, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
aload 2
invokespecial org.apache.avro.file.DataFileStream.<init>:(Lorg/apache/avro/io/DatumReader;)V
1: aload 0
new org.apache.avro.file.DataFileReader$SeekableInputStream
dup
aload 1
invokespecial org.apache.avro.file.DataFileReader$SeekableInputStream.<init>:(Lorg/apache/avro/file/SeekableInput;)V
putfield org.apache.avro.file.DataFileReader.sin:Lorg/apache/avro/file/DataFileReader$SeekableInputStream;
2: aload 0
aload 0
getfield org.apache.avro.file.DataFileReader.sin:Lorg/apache/avro/file/DataFileReader$SeekableInputStream;
aload 3
invokevirtual org.apache.avro.file.DataFileReader.initialize:(Ljava/io/InputStream;Lorg/apache/avro/file/DataFileStream$Header;)V
3: return
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/file/DataFileReader<TD;>;
0 4 1 sin Lorg/apache/avro/file/SeekableInput;
0 4 2 reader Lorg/apache/avro/io/DatumReader<TD;>;
0 4 3 header Lorg/apache/avro/file/DataFileStream$Header;
Exceptions:
throws java.io.IOException
Signature: (Lorg/apache/avro/file/SeekableInput;Lorg/apache/avro/io/DatumReader<TD;>;Lorg/apache/avro/file/DataFileStream$Header;)V
MethodParameters:
Name Flags
sin
reader
header
public void seek(long);
descriptor: (J)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=3, args_size=2
start local 0 start local 1 0: aload 0
getfield org.apache.avro.file.DataFileReader.sin:Lorg/apache/avro/file/DataFileReader$SeekableInputStream;
lload 1
invokevirtual org.apache.avro.file.DataFileReader$SeekableInputStream.seek:(J)V
1: aload 0
invokestatic org.apache.avro.io.DecoderFactory.get:()Lorg/apache/avro/io/DecoderFactory;
aload 0
getfield org.apache.avro.file.DataFileReader.sin:Lorg/apache/avro/file/DataFileReader$SeekableInputStream;
aload 0
getfield org.apache.avro.file.DataFileReader.vin:Lorg/apache/avro/io/BinaryDecoder;
invokevirtual org.apache.avro.io.DecoderFactory.binaryDecoder:(Ljava/io/InputStream;Lorg/apache/avro/io/BinaryDecoder;)Lorg/apache/avro/io/BinaryDecoder;
putfield org.apache.avro.file.DataFileReader.vin:Lorg/apache/avro/io/BinaryDecoder;
2: aload 0
aconst_null
putfield org.apache.avro.file.DataFileReader.datumIn:Lorg/apache/avro/io/BinaryDecoder;
3: aload 0
lconst_0
putfield org.apache.avro.file.DataFileReader.blockRemaining:J
4: aload 0
lload 1
putfield org.apache.avro.file.DataFileReader.blockStart:J
5: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lorg/apache/avro/file/DataFileReader<TD;>;
0 6 1 position J
Exceptions:
throws java.io.IOException
MethodParameters:
Name Flags
position
public void sync(long);
descriptor: (J)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=7, args_size=2
start local 0 start local 1 0: aload 0
lload 1
invokevirtual org.apache.avro.file.DataFileReader.seek:(J)V
1: lload 1
lconst_0
lcmp
ifne 4
aload 0
ldc "avro.sync"
invokevirtual org.apache.avro.file.DataFileReader.getMeta:(Ljava/lang/String;)[B
ifnull 4
2: aload 0
aload 0
getfield org.apache.avro.file.DataFileReader.sin:Lorg/apache/avro/file/DataFileReader$SeekableInputStream;
invokevirtual org.apache.avro.file.DataFileReader.initialize:(Ljava/io/InputStream;)V
3: return
4: StackMap locals:
StackMap stack:
iconst_0
istore 3
start local 3 5: aload 0
getfield org.apache.avro.file.DataFileReader.vin:Lorg/apache/avro/io/BinaryDecoder;
invokevirtual org.apache.avro.io.BinaryDecoder.inputStream:()Ljava/io/InputStream;
astore 5
start local 5 6: aload 0
getfield org.apache.avro.file.DataFileReader.vin:Lorg/apache/avro/io/BinaryDecoder;
aload 0
getfield org.apache.avro.file.DataFileReader.syncBuffer:[B
invokevirtual org.apache.avro.io.BinaryDecoder.readFixed:([B)V
7: StackMap locals: org.apache.avro.file.DataFileReader long int top java.io.InputStream
StackMap stack:
iconst_0
istore 6
start local 6 8: goto 12
9: StackMap locals: int
StackMap stack:
aload 0
invokevirtual org.apache.avro.file.DataFileReader.getHeader:()Lorg/apache/avro/file/DataFileStream$Header;
getfield org.apache.avro.file.DataFileStream$Header.sync:[B
iload 6
baload
aload 0
getfield org.apache.avro.file.DataFileReader.syncBuffer:[B
iload 3
iload 6
iadd
bipush 16
irem
baload
if_icmpeq 11
10: goto 13
11: StackMap locals:
StackMap stack:
iinc 6 1
StackMap locals:
StackMap stack:
12: iload 6
bipush 16
if_icmplt 9
13: StackMap locals:
StackMap stack:
iload 6
bipush 16
if_icmpne 16
14: aload 0
lload 1
iload 3
i2l
ladd
ldc 16
ladd
putfield org.apache.avro.file.DataFileReader.blockStart:J
15: return
16: StackMap locals:
StackMap stack:
aload 5
invokevirtual java.io.InputStream.read:()I
istore 4
start local 4 17: aload 0
getfield org.apache.avro.file.DataFileReader.syncBuffer:[B
iload 3
iinc 3 1
bipush 16
irem
iload 4
i2b
bastore
end local 6 18: iload 4
iconst_m1
if_icmpne 7
end local 5 end local 4 end local 3 19: goto 21
StackMap locals: org.apache.avro.file.DataFileReader long
StackMap stack: java.io.EOFException
20: pop
21: StackMap locals:
StackMap stack:
aload 0
aload 0
getfield org.apache.avro.file.DataFileReader.sin:Lorg/apache/avro/file/DataFileReader$SeekableInputStream;
invokevirtual org.apache.avro.file.DataFileReader$SeekableInputStream.tell:()J
putfield org.apache.avro.file.DataFileReader.blockStart:J
22: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 23 0 this Lorg/apache/avro/file/DataFileReader<TD;>;
0 23 1 position J
5 19 3 i I
17 19 4 b I
6 19 5 in Ljava/io/InputStream;
8 18 6 j I
Exception table:
from to target type
4 15 20 Class java.io.EOFException
16 19 20 Class java.io.EOFException
Exceptions:
throws java.io.IOException
MethodParameters:
Name Flags
position
protected void blockFinished();
descriptor: ()V
flags: (0x0004) ACC_PROTECTED
Code:
stack=5, locals=1, args_size=1
start local 0 0: aload 0
aload 0
getfield org.apache.avro.file.DataFileReader.sin:Lorg/apache/avro/file/DataFileReader$SeekableInputStream;
invokevirtual org.apache.avro.file.DataFileReader$SeekableInputStream.tell:()J
aload 0
getfield org.apache.avro.file.DataFileReader.vin:Lorg/apache/avro/io/BinaryDecoder;
invokevirtual org.apache.avro.io.BinaryDecoder.inputStream:()Ljava/io/InputStream;
invokevirtual java.io.InputStream.available:()I
i2l
lsub
putfield org.apache.avro.file.DataFileReader.blockStart:J
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/avro/file/DataFileReader<TD;>;
Exceptions:
throws java.io.IOException
public long previousSync();
descriptor: ()J
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.avro.file.DataFileReader.blockStart:J
lreturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/avro/file/DataFileReader<TD;>;
public boolean pastSync(long);
descriptor: (J)Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=3, args_size=2
start local 0 start local 1 0: aload 0
getfield org.apache.avro.file.DataFileReader.blockStart:J
lload 1
ldc 16
ladd
lcmp
ifge 1
aload 0
getfield org.apache.avro.file.DataFileReader.blockStart:J
aload 0
getfield org.apache.avro.file.DataFileReader.sin:Lorg/apache/avro/file/DataFileReader$SeekableInputStream;
invokevirtual org.apache.avro.file.DataFileReader$SeekableInputStream.length:()J
lcmp
ifge 1
iconst_0
ireturn
StackMap locals:
StackMap stack:
1: iconst_1
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/avro/file/DataFileReader<TD;>;
0 2 1 position J
Exceptions:
throws java.io.IOException
MethodParameters:
Name Flags
position
public long tell();
descriptor: ()J
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.avro.file.DataFileReader.sin:Lorg/apache/avro/file/DataFileReader$SeekableInputStream;
invokevirtual org.apache.avro.file.DataFileReader$SeekableInputStream.tell:()J
lreturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/avro/file/DataFileReader<TD;>;
Exceptions:
throws java.io.IOException
}
Signature: <D:Ljava/lang/Object;>Lorg/apache/avro/file/DataFileStream<TD;>;Lorg/apache/avro/file/FileReader<TD;>;
SourceFile: "DataFileReader.java"
NestMembers:
org.apache.avro.file.DataFileReader$SeekableInputStream
InnerClasses:
SeekableInputStream = org.apache.avro.file.DataFileReader$SeekableInputStream of org.apache.avro.file.DataFileReader
public final Header = org.apache.avro.file.DataFileStream$Header of org.apache.avro.file.DataFileStream