class SeekableByteChannelRecordReader
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
private java.nio.channels.SeekableByteChannel |
channel |
Constructor and Description |
---|
SeekableByteChannelRecordReader(java.nio.channels.SeekableByteChannel channel) |
Modifier and Type | Method and Description |
---|---|
private int |
computeLength(RecordDefinition recordDefinition,
long position) |
private long |
offset(RecordDefinition.Field field,
RecordDefinition recordDefinition,
long position) |
private long |
position(RecordDefinition.Field field,
RecordDefinition recordDefinition,
long position) |
java.nio.ByteBuffer |
read(RecordDefinition recordDefinition,
long position) |
private java.nio.ByteBuffer |
readField(RecordDefinition.Field field,
RecordDefinition recordDefinition,
long position) |
private long |
size(RecordDefinition.Field f,
RecordDefinition recordDefinition,
long position) |
java.lang.String |
toString() |
private int |
uint16(RecordDefinition.Field field,
RecordDefinition recordDefinition,
long position) |
com.google.common.primitives.UnsignedInteger |
uint32(RecordDefinition.Field field,
RecordDefinition recordDefinition,
long position) |
private com.google.common.primitives.UnsignedLong |
uint64(RecordDefinition.Field field,
RecordDefinition recordDefinition,
long position) |
public SeekableByteChannelRecordReader(java.nio.channels.SeekableByteChannel channel)
public java.nio.ByteBuffer read(RecordDefinition recordDefinition, long position) throws java.io.IOException
java.io.IOException
private int uint16(RecordDefinition.Field field, RecordDefinition recordDefinition, long position) throws java.io.IOException
java.io.IOException
public com.google.common.primitives.UnsignedInteger uint32(RecordDefinition.Field field, RecordDefinition recordDefinition, long position) throws java.io.IOException
java.io.IOException
private com.google.common.primitives.UnsignedLong uint64(RecordDefinition.Field field, RecordDefinition recordDefinition, long position) throws java.io.IOException
java.io.IOException
private java.nio.ByteBuffer readField(RecordDefinition.Field field, RecordDefinition recordDefinition, long position) throws java.io.IOException
java.io.IOException
private long position(RecordDefinition.Field field, RecordDefinition recordDefinition, long position) throws java.io.IOException
java.io.IOException
private long offset(RecordDefinition.Field field, RecordDefinition recordDefinition, long position) throws java.io.IOException
java.io.IOException
private long size(RecordDefinition.Field f, RecordDefinition recordDefinition, long position) throws java.io.IOException
java.io.IOException
private int computeLength(RecordDefinition recordDefinition, long position) throws java.io.IOException
java.io.IOException
public java.lang.String toString()
toString
in class java.lang.Object