public class org.apache.avro.file.DataFileStream<D> implements java.util.Iterator<D>, java.lang.Iterable<D>, java.io.Closeable
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: org.apache.avro.file.DataFileStream
super_class: java.lang.Object
{
private org.apache.avro.io.DatumReader<D> reader;
descriptor: Lorg/apache/avro/io/DatumReader;
flags: (0x0002) ACC_PRIVATE
Signature: Lorg/apache/avro/io/DatumReader<TD;>;
private long blockSize;
descriptor: J
flags: (0x0002) ACC_PRIVATE
private boolean availableBlock;
descriptor: Z
flags: (0x0002) ACC_PRIVATE
private org.apache.avro.file.DataFileStream$Header ;
descriptor: Lorg/apache/avro/file/DataFileStream$Header;
flags: (0x0002) ACC_PRIVATE
org.apache.avro.io.BinaryDecoder vin;
descriptor: Lorg/apache/avro/io/BinaryDecoder;
flags: (0x0000)
org.apache.avro.io.BinaryDecoder datumIn;
descriptor: Lorg/apache/avro/io/BinaryDecoder;
flags: (0x0000)
java.nio.ByteBuffer blockBuffer;
descriptor: Ljava/nio/ByteBuffer;
flags: (0x0000)
long blockCount;
descriptor: J
flags: (0x0000)
long blockRemaining;
descriptor: J
flags: (0x0000)
byte[] syncBuffer;
descriptor: [B
flags: (0x0000)
private org.apache.avro.file.Codec codec;
descriptor: Lorg/apache/avro/file/Codec;
flags: (0x0002) ACC_PRIVATE
private org.apache.avro.file.DataFileStream$DataBlock block;
descriptor: Lorg/apache/avro/file/DataFileStream$DataBlock;
flags: (0x0002) ACC_PRIVATE
public void <init>(java.io.InputStream, org.apache.avro.io.DatumReader<D>);
descriptor: (Ljava/io/InputStream;Lorg/apache/avro/io/DatumReader;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
iconst_0
putfield org.apache.avro.file.DataFileStream.availableBlock:Z
2: aload 0
aconst_null
putfield org.apache.avro.file.DataFileStream.datumIn:Lorg/apache/avro/io/BinaryDecoder;
3: aload 0
bipush 16
newarray 8
putfield org.apache.avro.file.DataFileStream.syncBuffer:[B
4: aload 0
aconst_null
putfield org.apache.avro.file.DataFileStream.block:Lorg/apache/avro/file/DataFileStream$DataBlock;
5: aload 0
aload 2
putfield org.apache.avro.file.DataFileStream.reader:Lorg/apache/avro/io/DatumReader;
6: aload 0
aload 1
invokevirtual org.apache.avro.file.DataFileStream.initialize:(Ljava/io/InputStream;)V
7: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lorg/apache/avro/file/DataFileStream<TD;>;
0 8 1 in Ljava/io/InputStream;
0 8 2 reader Lorg/apache/avro/io/DatumReader<TD;>;
Exceptions:
throws java.io.IOException
Signature: (Ljava/io/InputStream;Lorg/apache/avro/io/DatumReader<TD;>;)V
MethodParameters:
Name Flags
in
reader
protected void <init>(org.apache.avro.io.DatumReader<D>);
descriptor: (Lorg/apache/avro/io/DatumReader;)V
flags: (0x0004) ACC_PROTECTED
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
iconst_0
putfield org.apache.avro.file.DataFileStream.availableBlock:Z
2: aload 0
aconst_null
putfield org.apache.avro.file.DataFileStream.datumIn:Lorg/apache/avro/io/BinaryDecoder;
3: aload 0
bipush 16
newarray 8
putfield org.apache.avro.file.DataFileStream.syncBuffer:[B
4: aload 0
aconst_null
putfield org.apache.avro.file.DataFileStream.block:Lorg/apache/avro/file/DataFileStream$DataBlock;
5: aload 0
aload 1
putfield org.apache.avro.file.DataFileStream.reader:Lorg/apache/avro/io/DatumReader;
6: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lorg/apache/avro/file/DataFileStream<TD;>;
0 7 1 reader Lorg/apache/avro/io/DatumReader<TD;>;
Exceptions:
throws java.io.IOException
Signature: (Lorg/apache/avro/io/DatumReader<TD;>;)V
MethodParameters:
Name Flags
reader
void initialize(java.io.InputStream);
descriptor: (Ljava/io/InputStream;)V
flags: (0x0000)
Code:
stack=4, locals=10, args_size=2
start local 0 start local 1 0: aload 0
new org.apache.avro.file.DataFileStream$Header
dup
invokespecial org.apache.avro.file.DataFileStream$Header.<init>:()V
putfield org.apache.avro.file.DataFileStream.header:Lorg/apache/avro/file/DataFileStream$Header;
1: aload 0
invokestatic org.apache.avro.io.DecoderFactory.get:()Lorg/apache/avro/io/DecoderFactory;
aload 1
aload 0
getfield org.apache.avro.file.DataFileStream.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.DataFileStream.vin:Lorg/apache/avro/io/BinaryDecoder;
2: getstatic org.apache.avro.file.DataFileConstants.MAGIC:[B
arraylength
newarray 8
astore 2
start local 2 3: aload 0
getfield org.apache.avro.file.DataFileStream.vin:Lorg/apache/avro/io/BinaryDecoder;
aload 2
invokevirtual org.apache.avro.io.BinaryDecoder.readFixed:([B)V
4: goto 7
StackMap locals: org.apache.avro.file.DataFileStream java.io.InputStream byte[]
StackMap stack: java.io.IOException
5: astore 3
start local 3 6: new java.io.IOException
dup
ldc "Not an Avro data file."
aload 3
invokespecial java.io.IOException.<init>:(Ljava/lang/String;Ljava/lang/Throwable;)V
athrow
end local 3 7: StackMap locals:
StackMap stack:
getstatic org.apache.avro.file.DataFileConstants.MAGIC:[B
aload 2
invokestatic java.util.Arrays.equals:([B[B)Z
ifne 9
8: new org.apache.avro.InvalidAvroMagicException
dup
ldc "Not an Avro data file."
invokespecial org.apache.avro.InvalidAvroMagicException.<init>:(Ljava/lang/String;)V
athrow
9: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.avro.file.DataFileStream.vin:Lorg/apache/avro/io/BinaryDecoder;
invokevirtual org.apache.avro.io.BinaryDecoder.readMapStart:()J
lstore 3
start local 3 10: lload 3
lconst_0
lcmp
ifle 22
11: StackMap locals: long
StackMap stack:
lconst_0
lstore 5
start local 5 12: goto 20
13: StackMap locals: long
StackMap stack:
aload 0
getfield org.apache.avro.file.DataFileStream.vin:Lorg/apache/avro/io/BinaryDecoder;
aconst_null
invokevirtual org.apache.avro.io.BinaryDecoder.readString:(Lorg/apache/avro/util/Utf8;)Lorg/apache/avro/util/Utf8;
invokevirtual org.apache.avro.util.Utf8.toString:()Ljava/lang/String;
astore 7
start local 7 14: aload 0
getfield org.apache.avro.file.DataFileStream.vin:Lorg/apache/avro/io/BinaryDecoder;
aconst_null
invokevirtual org.apache.avro.io.BinaryDecoder.readBytes:(Ljava/nio/ByteBuffer;)Ljava/nio/ByteBuffer;
astore 8
start local 8 15: aload 8
invokevirtual java.nio.ByteBuffer.remaining:()I
newarray 8
astore 9
start local 9 16: aload 8
aload 9
invokevirtual java.nio.ByteBuffer.get:([B)Ljava/nio/ByteBuffer;
pop
17: aload 0
getfield org.apache.avro.file.DataFileStream.header:Lorg/apache/avro/file/DataFileStream$Header;
getfield org.apache.avro.file.DataFileStream$Header.meta:Ljava/util/Map;
aload 7
aload 9
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
18: aload 0
getfield org.apache.avro.file.DataFileStream.header:Lorg/apache/avro/file/DataFileStream$Header;
getfield org.apache.avro.file.DataFileStream$Header.metaKeyList:Ljava/util/List;
aload 7
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
end local 9 end local 8 end local 7 19: lload 5
lconst_1
ladd
lstore 5
StackMap locals:
StackMap stack:
20: lload 5
lload 3
lcmp
iflt 13
end local 5 21: aload 0
getfield org.apache.avro.file.DataFileStream.vin:Lorg/apache/avro/io/BinaryDecoder;
invokevirtual org.apache.avro.io.BinaryDecoder.mapNext:()J
dup2
lstore 3
lconst_0
lcmp
ifne 11
22: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.avro.file.DataFileStream.vin:Lorg/apache/avro/io/BinaryDecoder;
aload 0
getfield org.apache.avro.file.DataFileStream.header:Lorg/apache/avro/file/DataFileStream$Header;
getfield org.apache.avro.file.DataFileStream$Header.sync:[B
invokevirtual org.apache.avro.io.BinaryDecoder.readFixed:([B)V
23: aload 0
getfield org.apache.avro.file.DataFileStream.header:Lorg/apache/avro/file/DataFileStream$Header;
aload 0
getfield org.apache.avro.file.DataFileStream.header:Lorg/apache/avro/file/DataFileStream$Header;
getfield org.apache.avro.file.DataFileStream$Header.metaKeyList:Ljava/util/List;
invokestatic java.util.Collections.unmodifiableList:(Ljava/util/List;)Ljava/util/List;
putfield org.apache.avro.file.DataFileStream$Header.metaKeyList:Ljava/util/List;
24: aload 0
getfield org.apache.avro.file.DataFileStream.header:Lorg/apache/avro/file/DataFileStream$Header;
new org.apache.avro.Schema$Parser
dup
invokespecial org.apache.avro.Schema$Parser.<init>:()V
iconst_0
invokevirtual org.apache.avro.Schema$Parser.setValidate:(Z)Lorg/apache/avro/Schema$Parser;
aload 0
ldc "avro.schema"
invokevirtual org.apache.avro.file.DataFileStream.getMetaString:(Ljava/lang/String;)Ljava/lang/String;
invokevirtual org.apache.avro.Schema$Parser.parse:(Ljava/lang/String;)Lorg/apache/avro/Schema;
putfield org.apache.avro.file.DataFileStream$Header.schema:Lorg/apache/avro/Schema;
25: aload 0
aload 0
invokevirtual org.apache.avro.file.DataFileStream.resolveCodec:()Lorg/apache/avro/file/Codec;
putfield org.apache.avro.file.DataFileStream.codec:Lorg/apache/avro/file/Codec;
26: aload 0
getfield org.apache.avro.file.DataFileStream.reader:Lorg/apache/avro/io/DatumReader;
aload 0
getfield org.apache.avro.file.DataFileStream.header:Lorg/apache/avro/file/DataFileStream$Header;
getfield org.apache.avro.file.DataFileStream$Header.schema:Lorg/apache/avro/Schema;
invokeinterface org.apache.avro.io.DatumReader.setSchema:(Lorg/apache/avro/Schema;)V
27: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 28 0 this Lorg/apache/avro/file/DataFileStream<TD;>;
0 28 1 in Ljava/io/InputStream;
3 28 2 magic [B
6 7 3 e Ljava/io/IOException;
10 28 3 l J
12 21 5 i J
14 19 7 key Ljava/lang/String;
15 19 8 value Ljava/nio/ByteBuffer;
16 19 9 bb [B
Exception table:
from to target type
3 4 5 Class java.io.IOException
Exceptions:
throws java.io.IOException
MethodParameters:
Name Flags
in
void (java.io.InputStream, org.apache.avro.file.DataFileStream$Header);
descriptor: (Ljava/io/InputStream;Lorg/apache/avro/file/DataFileStream$Header;)V
flags: (0x0000)
Code:
stack=2, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 2
putfield org.apache.avro.file.DataFileStream.header:Lorg/apache/avro/file/DataFileStream$Header;
1: aload 0
aload 0
invokevirtual org.apache.avro.file.DataFileStream.resolveCodec:()Lorg/apache/avro/file/Codec;
putfield org.apache.avro.file.DataFileStream.codec:Lorg/apache/avro/file/Codec;
2: aload 0
getfield org.apache.avro.file.DataFileStream.reader:Lorg/apache/avro/io/DatumReader;
aload 2
getfield org.apache.avro.file.DataFileStream$Header.schema:Lorg/apache/avro/Schema;
invokeinterface org.apache.avro.io.DatumReader.setSchema:(Lorg/apache/avro/Schema;)V
3: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lorg/apache/avro/file/DataFileStream<TD;>;
0 4 1 in Ljava/io/InputStream;
0 4 2 header Lorg/apache/avro/file/DataFileStream$Header;
Exceptions:
throws java.io.IOException
MethodParameters:
Name Flags
in
header
org.apache.avro.file.Codec resolveCodec();
descriptor: ()Lorg/apache/avro/file/Codec;
flags: (0x0000)
Code:
stack=2, locals=2, args_size=1
start local 0 0: aload 0
ldc "avro.codec"
invokevirtual org.apache.avro.file.DataFileStream.getMetaString:(Ljava/lang/String;)Ljava/lang/String;
astore 1
start local 1 1: aload 1
ifnull 3
2: aload 1
invokestatic org.apache.avro.file.CodecFactory.fromString:(Ljava/lang/String;)Lorg/apache/avro/file/CodecFactory;
invokevirtual org.apache.avro.file.CodecFactory.createInstance:()Lorg/apache/avro/file/Codec;
areturn
3: StackMap locals: java.lang.String
StackMap stack:
invokestatic org.apache.avro.file.CodecFactory.nullCodec:()Lorg/apache/avro/file/CodecFactory;
invokevirtual org.apache.avro.file.CodecFactory.createInstance:()Lorg/apache/avro/file/Codec;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lorg/apache/avro/file/DataFileStream<TD;>;
1 4 1 codecStr Ljava/lang/String;
public org.apache.avro.file.DataFileStream$Header ();
descriptor: ()Lorg/apache/avro/file/DataFileStream$Header;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.avro.file.DataFileStream.header:Lorg/apache/avro/file/DataFileStream$Header;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/avro/file/DataFileStream<TD;>;
public org.apache.avro.Schema getSchema();
descriptor: ()Lorg/apache/avro/Schema;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.avro.file.DataFileStream.header:Lorg/apache/avro/file/DataFileStream$Header;
getfield org.apache.avro.file.DataFileStream$Header.schema:Lorg/apache/avro/Schema;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/avro/file/DataFileStream<TD;>;
public java.util.List<java.lang.String> getMetaKeys();
descriptor: ()Ljava/util/List;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.avro.file.DataFileStream.header:Lorg/apache/avro/file/DataFileStream$Header;
getfield org.apache.avro.file.DataFileStream$Header.metaKeyList:Ljava/util/List;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/avro/file/DataFileStream<TD;>;
Signature: ()Ljava/util/List<Ljava/lang/String;>;
public byte[] getMeta(java.lang.String);
descriptor: (Ljava/lang/String;)[B
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield org.apache.avro.file.DataFileStream.header:Lorg/apache/avro/file/DataFileStream$Header;
getfield org.apache.avro.file.DataFileStream$Header.meta:Ljava/util/Map;
aload 1
invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast byte[]
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/avro/file/DataFileStream<TD;>;
0 1 1 key Ljava/lang/String;
MethodParameters:
Name Flags
key
public java.lang.String getMetaString(java.lang.String);
descriptor: (Ljava/lang/String;)Ljava/lang/String;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=3, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokevirtual org.apache.avro.file.DataFileStream.getMeta:(Ljava/lang/String;)[B
astore 2
start local 2 1: aload 2
ifnonnull 3
2: aconst_null
areturn
3: StackMap locals: byte[]
StackMap stack:
new java.lang.String
dup
aload 2
getstatic java.nio.charset.StandardCharsets.UTF_8:Ljava/nio/charset/Charset;
invokespecial java.lang.String.<init>:([BLjava/nio/charset/Charset;)V
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lorg/apache/avro/file/DataFileStream<TD;>;
0 4 1 key Ljava/lang/String;
1 4 2 value [B
MethodParameters:
Name Flags
key
public long getMetaLong(java.lang.String);
descriptor: (Ljava/lang/String;)J
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokevirtual org.apache.avro.file.DataFileStream.getMetaString:(Ljava/lang/String;)Ljava/lang/String;
invokestatic java.lang.Long.parseLong:(Ljava/lang/String;)J
lreturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/avro/file/DataFileStream<TD;>;
0 1 1 key Ljava/lang/String;
MethodParameters:
Name Flags
key
public java.util.Iterator<D> iterator();
descriptor: ()Ljava/util/Iterator;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/avro/file/DataFileStream<TD;>;
Signature: ()Ljava/util/Iterator<TD;>;
public boolean hasNext();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=2, args_size=1
start local 0 0: aload 0
getfield org.apache.avro.file.DataFileStream.blockRemaining:J
lconst_0
lcmp
ifne 12
1: aload 0
getfield org.apache.avro.file.DataFileStream.datumIn:Lorg/apache/avro/io/BinaryDecoder;
ifnull 5
2: aload 0
getfield org.apache.avro.file.DataFileStream.datumIn:Lorg/apache/avro/io/BinaryDecoder;
invokevirtual org.apache.avro.io.BinaryDecoder.isEnd:()Z
istore 1
start local 1 3: iload 1
ifne 5
4: new java.io.IOException
dup
ldc "Block read partially, the data may be corrupt"
invokespecial java.io.IOException.<init>:(Ljava/lang/String;)V
athrow
end local 1 5: StackMap locals:
StackMap stack:
aload 0
invokevirtual org.apache.avro.file.DataFileStream.hasNextBlock:()Z
ifeq 12
6: aload 0
aload 0
aload 0
getfield org.apache.avro.file.DataFileStream.block:Lorg/apache/avro/file/DataFileStream$DataBlock;
invokevirtual org.apache.avro.file.DataFileStream.nextRawBlock:(Lorg/apache/avro/file/DataFileStream$DataBlock;)Lorg/apache/avro/file/DataFileStream$DataBlock;
putfield org.apache.avro.file.DataFileStream.block:Lorg/apache/avro/file/DataFileStream$DataBlock;
7: aload 0
getfield org.apache.avro.file.DataFileStream.block:Lorg/apache/avro/file/DataFileStream$DataBlock;
aload 0
getfield org.apache.avro.file.DataFileStream.codec:Lorg/apache/avro/file/Codec;
invokevirtual org.apache.avro.file.DataFileStream$DataBlock.decompressUsing:(Lorg/apache/avro/file/Codec;)V
8: aload 0
aload 0
getfield org.apache.avro.file.DataFileStream.block:Lorg/apache/avro/file/DataFileStream$DataBlock;
invokevirtual org.apache.avro.file.DataFileStream$DataBlock.getAsByteBuffer:()Ljava/nio/ByteBuffer;
putfield org.apache.avro.file.DataFileStream.blockBuffer:Ljava/nio/ByteBuffer;
9: aload 0
invokestatic org.apache.avro.io.DecoderFactory.get:()Lorg/apache/avro/io/DecoderFactory;
aload 0
getfield org.apache.avro.file.DataFileStream.blockBuffer:Ljava/nio/ByteBuffer;
invokevirtual java.nio.ByteBuffer.array:()[B
10: aload 0
getfield org.apache.avro.file.DataFileStream.blockBuffer:Ljava/nio/ByteBuffer;
invokevirtual java.nio.ByteBuffer.arrayOffset:()I
aload 0
getfield org.apache.avro.file.DataFileStream.blockBuffer:Ljava/nio/ByteBuffer;
invokevirtual java.nio.ByteBuffer.position:()I
iadd
aload 0
getfield org.apache.avro.file.DataFileStream.blockBuffer:Ljava/nio/ByteBuffer;
invokevirtual java.nio.ByteBuffer.remaining:()I
aload 0
getfield org.apache.avro.file.DataFileStream.datumIn:Lorg/apache/avro/io/BinaryDecoder;
11: invokevirtual org.apache.avro.io.DecoderFactory.binaryDecoder:([BIILorg/apache/avro/io/BinaryDecoder;)Lorg/apache/avro/io/BinaryDecoder;
putfield org.apache.avro.file.DataFileStream.datumIn:Lorg/apache/avro/io/BinaryDecoder;
12: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.avro.file.DataFileStream.blockRemaining:J
lconst_0
lcmp
ifeq 13
iconst_1
ireturn
StackMap locals:
StackMap stack:
13: iconst_0
14: ireturn
15: StackMap locals:
StackMap stack: java.io.EOFException
pop
16: iconst_0
ireturn
17: StackMap locals:
StackMap stack: java.io.IOException
astore 1
start local 1 18: new org.apache.avro.AvroRuntimeException
dup
aload 1
invokespecial org.apache.avro.AvroRuntimeException.<init>:(Ljava/lang/Throwable;)V
athrow
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 19 0 this Lorg/apache/avro/file/DataFileStream<TD;>;
3 5 1 atEnd Z
18 19 1 e Ljava/io/IOException;
Exception table:
from to target type
0 14 15 Class java.io.EOFException
0 14 17 Class java.io.IOException
public D next();
descriptor: ()Ljava/lang/Object;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=1
start local 0 0: aload 0
aconst_null
invokevirtual org.apache.avro.file.DataFileStream.next:(Ljava/lang/Object;)Ljava/lang/Object;
1: areturn
2: StackMap locals:
StackMap stack: java.io.IOException
astore 1
start local 1 3: new org.apache.avro.AvroRuntimeException
dup
aload 1
invokespecial org.apache.avro.AvroRuntimeException.<init>:(Ljava/lang/Throwable;)V
athrow
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lorg/apache/avro/file/DataFileStream<TD;>;
3 4 1 e Ljava/io/IOException;
Exception table:
from to target type
0 1 2 Class java.io.IOException
Signature: ()TD;
public D next();
descriptor: (Ljava/lang/Object;)Ljava/lang/Object;
flags: (0x0001) ACC_PUBLIC
Code:
stack=7, locals=3, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual org.apache.avro.file.DataFileStream.hasNext:()Z
ifne 2
1: new java.util.NoSuchElementException
dup
invokespecial java.util.NoSuchElementException.<init>:()V
athrow
2: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.avro.file.DataFileStream.reader:Lorg/apache/avro/io/DatumReader;
aload 1
aload 0
getfield org.apache.avro.file.DataFileStream.datumIn:Lorg/apache/avro/io/BinaryDecoder;
invokeinterface org.apache.avro.io.DatumReader.read:(Ljava/lang/Object;Lorg/apache/avro/io/Decoder;)Ljava/lang/Object;
astore 2
start local 2 3: lconst_0
aload 0
dup
getfield org.apache.avro.file.DataFileStream.blockRemaining:J
lconst_1
lsub
dup2_x1
putfield org.apache.avro.file.DataFileStream.blockRemaining:J
lcmp
ifne 5
4: aload 0
invokevirtual org.apache.avro.file.DataFileStream.blockFinished:()V
5: StackMap locals: java.lang.Object
StackMap stack:
aload 2
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lorg/apache/avro/file/DataFileStream<TD;>;
0 6 1 reuse TD;
3 6 2 result TD;
Exceptions:
throws java.io.IOException
Signature: (TD;)TD;
MethodParameters:
Name Flags
reuse
public java.nio.ByteBuffer nextBlock();
descriptor: ()Ljava/nio/ByteBuffer;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=1, args_size=1
start local 0 0: aload 0
invokevirtual org.apache.avro.file.DataFileStream.hasNext:()Z
ifne 2
1: new java.util.NoSuchElementException
dup
invokespecial java.util.NoSuchElementException.<init>:()V
athrow
2: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.avro.file.DataFileStream.blockRemaining:J
aload 0
getfield org.apache.avro.file.DataFileStream.blockCount:J
lcmp
ifeq 4
3: new java.lang.IllegalStateException
dup
ldc "Not at block start."
invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
athrow
4: StackMap locals:
StackMap stack:
aload 0
lconst_0
putfield org.apache.avro.file.DataFileStream.blockRemaining:J
5: aload 0
aconst_null
putfield org.apache.avro.file.DataFileStream.datumIn:Lorg/apache/avro/io/BinaryDecoder;
6: aload 0
getfield org.apache.avro.file.DataFileStream.blockBuffer:Ljava/nio/ByteBuffer;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lorg/apache/avro/file/DataFileStream<TD;>;
Exceptions:
throws java.io.IOException
public long getBlockCount();
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.DataFileStream.blockCount:J
lreturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/avro/file/DataFileStream<TD;>;
public long getBlockSize();
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.DataFileStream.blockSize:J
lreturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/avro/file/DataFileStream<TD;>;
protected void blockFinished();
descriptor: ()V
flags: (0x0004) ACC_PROTECTED
Code:
stack=0, locals=1, args_size=1
start local 0 0: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/avro/file/DataFileStream<TD;>;
Exceptions:
throws java.io.IOException
boolean hasNextBlock();
descriptor: ()Z
flags: (0x0000)
Code:
stack=5, locals=2, args_size=1
start local 0 0: aload 0
getfield org.apache.avro.file.DataFileStream.availableBlock:Z
ifeq 2
1: iconst_1
ireturn
2: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.avro.file.DataFileStream.vin:Lorg/apache/avro/io/BinaryDecoder;
invokevirtual org.apache.avro.io.BinaryDecoder.isEnd:()Z
ifeq 4
3: iconst_0
ireturn
4: StackMap locals:
StackMap stack:
aload 0
aload 0
getfield org.apache.avro.file.DataFileStream.vin:Lorg/apache/avro/io/BinaryDecoder;
invokevirtual org.apache.avro.io.BinaryDecoder.readLong:()J
putfield org.apache.avro.file.DataFileStream.blockRemaining:J
5: aload 0
aload 0
getfield org.apache.avro.file.DataFileStream.vin:Lorg/apache/avro/io/BinaryDecoder;
invokevirtual org.apache.avro.io.BinaryDecoder.readLong:()J
putfield org.apache.avro.file.DataFileStream.blockSize:J
6: aload 0
getfield org.apache.avro.file.DataFileStream.blockSize:J
ldc 2147483647
lcmp
ifgt 7
aload 0
getfield org.apache.avro.file.DataFileStream.blockSize:J
lconst_0
lcmp
ifge 8
7: StackMap locals:
StackMap stack:
new java.io.IOException
dup
new java.lang.StringBuilder
dup
ldc "Block size invalid or too large for this implementation: "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 0
getfield org.apache.avro.file.DataFileStream.blockSize:J
invokevirtual java.lang.StringBuilder.append:(J)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokespecial java.io.IOException.<init>:(Ljava/lang/String;)V
athrow
8: StackMap locals:
StackMap stack:
aload 0
aload 0
getfield org.apache.avro.file.DataFileStream.blockRemaining:J
putfield org.apache.avro.file.DataFileStream.blockCount:J
9: aload 0
iconst_1
putfield org.apache.avro.file.DataFileStream.availableBlock:Z
10: iconst_1
ireturn
11: StackMap locals:
StackMap stack: java.io.EOFException
pop
12: iconst_0
ireturn
13: StackMap locals:
StackMap stack: java.io.IOException
astore 1
start local 1 14: new org.apache.avro.AvroRuntimeException
dup
aload 1
invokespecial org.apache.avro.AvroRuntimeException.<init>:(Ljava/lang/Throwable;)V
athrow
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 15 0 this Lorg/apache/avro/file/DataFileStream<TD;>;
14 15 1 e Ljava/io/IOException;
Exception table:
from to target type
0 1 11 Class java.io.EOFException
2 3 11 Class java.io.EOFException
4 10 11 Class java.io.EOFException
0 1 13 Class java.io.IOException
2 3 13 Class java.io.IOException
4 10 13 Class java.io.IOException
org.apache.avro.file.DataFileStream$DataBlock (org.apache.avro.file.DataFileStream$DataBlock);
descriptor: (Lorg/apache/avro/file/DataFileStream$DataBlock;)Lorg/apache/avro/file/DataFileStream$DataBlock;
flags: (0x0000)
Code:
stack=6, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual org.apache.avro.file.DataFileStream.hasNextBlock:()Z
ifne 2
1: new java.util.NoSuchElementException
dup
invokespecial java.util.NoSuchElementException.<init>:()V
athrow
2: StackMap locals:
StackMap stack:
aload 1
ifnull 3
aload 1
getfield org.apache.avro.file.DataFileStream$DataBlock.data:[B
arraylength
aload 0
getfield org.apache.avro.file.DataFileStream.blockSize:J
l2i
if_icmpge 5
3: StackMap locals:
StackMap stack:
new org.apache.avro.file.DataFileStream$DataBlock
dup
aload 0
getfield org.apache.avro.file.DataFileStream.blockRemaining:J
aload 0
getfield org.apache.avro.file.DataFileStream.blockSize:J
l2i
invokespecial org.apache.avro.file.DataFileStream$DataBlock.<init>:(JI)V
astore 1
4: goto 7
5: StackMap locals:
StackMap stack:
aload 1
aload 0
getfield org.apache.avro.file.DataFileStream.blockRemaining:J
putfield org.apache.avro.file.DataFileStream$DataBlock.numEntries:J
6: aload 1
aload 0
getfield org.apache.avro.file.DataFileStream.blockSize:J
l2i
putfield org.apache.avro.file.DataFileStream$DataBlock.blockSize:I
7: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.avro.file.DataFileStream.vin:Lorg/apache/avro/io/BinaryDecoder;
aload 1
getfield org.apache.avro.file.DataFileStream$DataBlock.data:[B
iconst_0
aload 1
getfield org.apache.avro.file.DataFileStream$DataBlock.blockSize:I
invokevirtual org.apache.avro.io.BinaryDecoder.readFixed:([BII)V
8: aload 0
getfield org.apache.avro.file.DataFileStream.vin:Lorg/apache/avro/io/BinaryDecoder;
aload 0
getfield org.apache.avro.file.DataFileStream.syncBuffer:[B
invokevirtual org.apache.avro.io.BinaryDecoder.readFixed:([B)V
9: aload 0
iconst_0
putfield org.apache.avro.file.DataFileStream.availableBlock:Z
10: aload 0
getfield org.apache.avro.file.DataFileStream.syncBuffer:[B
aload 0
getfield org.apache.avro.file.DataFileStream.header:Lorg/apache/avro/file/DataFileStream$Header;
getfield org.apache.avro.file.DataFileStream$Header.sync:[B
invokestatic java.util.Arrays.equals:([B[B)Z
ifne 12
11: new java.io.IOException
dup
ldc "Invalid sync!"
invokespecial java.io.IOException.<init>:(Ljava/lang/String;)V
athrow
12: StackMap locals:
StackMap stack:
aload 1
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 13 0 this Lorg/apache/avro/file/DataFileStream<TD;>;
0 13 1 reuse Lorg/apache/avro/file/DataFileStream$DataBlock;
Exceptions:
throws java.io.IOException
MethodParameters:
Name Flags
reuse
public void remove();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: new java.lang.UnsupportedOperationException
dup
invokespecial java.lang.UnsupportedOperationException.<init>:()V
athrow
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/avro/file/DataFileStream<TD;>;
public void close();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.avro.file.DataFileStream.vin:Lorg/apache/avro/io/BinaryDecoder;
invokevirtual org.apache.avro.io.BinaryDecoder.inputStream:()Ljava/io/InputStream;
invokevirtual java.io.InputStream.close:()V
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/avro/file/DataFileStream<TD;>;
Exceptions:
throws java.io.IOException
}
Signature: <D:Ljava/lang/Object;>Ljava/lang/Object;Ljava/util/Iterator<TD;>;Ljava/lang/Iterable<TD;>;Ljava/io/Closeable;
SourceFile: "DataFileStream.java"
NestMembers:
org.apache.avro.file.DataFileStream$DataBlock org.apache.avro.file.DataFileStream$Header
InnerClasses:
public Parser = org.apache.avro.Schema$Parser of org.apache.avro.Schema
DataBlock = org.apache.avro.file.DataFileStream$DataBlock of org.apache.avro.file.DataFileStream
public final Header = org.apache.avro.file.DataFileStream$Header of org.apache.avro.file.DataFileStream