org.apache.giraph.utils

Class UnsafeArrayReads

java.lang.Object

java.io.InputStream

com.esotericsoftware.kryo.io.Input

org.apache.giraph.utils.UnsafeReads

org.apache.giraph.utils.UnsafeArrayReads

All Implemented Interfaces:

Closeable, DataInput, AutoCloseable, ExtendedDataInput

Direct Known Subclasses:

UnsafeByteArrayInputStream, UnsafeReusableByteArrayInput

public class UnsafeArrayReads
extends UnsafeReads

Byte array input stream that uses Unsafe methods to deserialize much faster

Field Summary

Fields inherited from class com.esotericsoftware.kryo.io.Input

buffer, capacity, chars, inputStream, limit, position, total

Constructor Summary

Constructors

Constructor and Description
UnsafeArrayReads(byte[] buf) Constructor
UnsafeArrayReads(byte[] buf, int offset, int length) Constructor.

Method Summary

Modifier and Type	Method and Description
int	available() How many bytes are still available?
boolean	endOfInput() Check if we read everything from the input
static int	getInt(byte[] buf, int pos) Get an int at an arbitrary position in a byte[]
int	getPos() What position in the stream?
boolean	readBoolean()
byte	readByte()
char	readChar()
double	readDouble()
float	readFloat()
void	readFully(byte[] b)
void	readFully(byte[] b, int off, int len)
int	readInt()
long	readLong()
short	readShort()
int	readUnsignedByte()
int	readUnsignedShort()

Methods inherited from class org.apache.giraph.utils.UnsafeReads

readLine, readUTF, require, skipBytes

Methods inherited from class com.esotericsoftware.kryo.io.Input

canReadInt, canReadLong, close, eof, fill, getBuffer, getInputStream, limit, position, read, read, read, readBytes, readBytes, readBytes, readByteUnsigned, readChars, readDouble, readDoubles, readFloat, readFloats, readInt, readInts, readInts, readLong, readLongs, readLongs, readShorts, readShortUnsigned, readString, readStringBuilder, readVarInt, readVarLong, rewind, setBuffer, setBuffer, setInputStream, setLimit, setPosition, setTotal, skip, skip, total

Methods inherited from class java.io.InputStream

mark, markSupported, reset

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

UnsafeArrayReads

public UnsafeArrayReads(byte[] buf)

Constructor

Parameters:

buf - Buffer to read from

UnsafeArrayReads

public UnsafeArrayReads(byte[] buf,
                        int offset,
                        int length)

Constructor.

Parameters:

buf - Buffer to read from

offset - Offsetin the buffer to start reading from

length - Max length of the buffer to read

Method Detail

available

public int available()

Description copied from class: UnsafeReads

How many bytes are still available?

Specified by:

available in interface ExtendedDataInput

Specified by:

available in class UnsafeReads

Returns:

Number of bytes available

endOfInput

public boolean endOfInput()

Description copied from interface: ExtendedDataInput

Check if we read everything from the input

Returns:

True iff we read everything from the input

getPos

public int getPos()

Description copied from class: UnsafeReads

What position in the stream?

Specified by:

getPos in interface ExtendedDataInput

Specified by:

getPos in class UnsafeReads

Returns:

Position

readFully

public void readFully(byte[] b)
               throws IOException

Throws:

IOException

readFully

public void readFully(byte[] b,
                      int off,
                      int len)
               throws IOException

Throws:

IOException

readBoolean

public boolean readBoolean()

Specified by:

readBoolean in interface DataInput

Overrides:

readBoolean in class com.esotericsoftware.kryo.io.Input

readByte

public byte readByte()

Specified by:

readByte in interface DataInput

Overrides:

readByte in class com.esotericsoftware.kryo.io.Input

readUnsignedByte

public int readUnsignedByte()
                     throws IOException

Throws:

IOException

readShort

public short readShort()

Specified by:

readShort in interface DataInput

Overrides:

readShort in class com.esotericsoftware.kryo.io.Input

readUnsignedShort

public int readUnsignedShort()
                      throws IOException

Throws:

IOException

readChar

public char readChar()

Specified by:

readChar in interface DataInput

Overrides:

readChar in class com.esotericsoftware.kryo.io.Input

readInt

public int readInt()

Specified by:

readInt in interface DataInput

Overrides:

readInt in class com.esotericsoftware.kryo.io.Input

readLong

public long readLong()

Specified by:

readLong in interface DataInput

Overrides:

readLong in class com.esotericsoftware.kryo.io.Input

readFloat

public float readFloat()

Specified by:

readFloat in interface DataInput

Overrides:

readFloat in class com.esotericsoftware.kryo.io.Input

readDouble

public double readDouble()

Specified by:

readDouble in interface DataInput

Overrides:

readDouble in class com.esotericsoftware.kryo.io.Input

getInt

public static int getInt(byte[] buf,
                         int pos)

Get an int at an arbitrary position in a byte[]

Parameters:

buf - Buffer to get the int from

pos - Position in the buffer to get the int from

Returns:

Int at the buffer position