org.apache.giraph.utils

Class UnsafeReads

java.lang.Object

java.io.InputStream

com.esotericsoftware.kryo.io.Input

org.apache.giraph.utils.UnsafeReads

All Implemented Interfaces:

Closeable, DataInput, AutoCloseable, ExtendedDataInput

Direct Known Subclasses:

UnsafeArrayReads

public abstract class UnsafeReads
extends com.esotericsoftware.kryo.io.Input
implements ExtendedDataInput

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
UnsafeReads(int length) Constructor
UnsafeReads(long offset, int length) Constructor with offset

Method Summary

Modifier and Type	Method and Description
abstract int	available() How many bytes are still available?
abstract int	getPos() What position in the stream?
String	readLine()
String	readUTF()
protected int	require(int requiredBytes) Check whether there are enough remaining bytes for an operation
int	skipBytes(int n)

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

canReadInt, canReadLong, close, eof, fill, getBuffer, getInputStream, limit, position, read, read, read, readBoolean, readByte, readBytes, readBytes, readBytes, readByteUnsigned, readChar, readChars, readDouble, readDouble, readDoubles, readFloat, readFloat, readFloats, readInt, readInt, readInts, readInts, readLong, readLong, readLongs, readLongs, readShort, 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

Methods inherited from interface org.apache.giraph.utils.ExtendedDataInput

endOfInput

Methods inherited from interface java.io.DataInput

readBoolean, readByte, readChar, readDouble, readFloat, readFully, readFully, readInt, readLong, readShort, readUnsignedByte, readUnsignedShort

Constructor Detail

UnsafeReads

public UnsafeReads(int length)

Constructor

Parameters:

length - buf length

UnsafeReads

public UnsafeReads(long offset,
                   int length)

Constructor with offset

Parameters:

offset - offset in memory

length - buf length

Method Detail

available

public abstract int available()

How many bytes are still available?

Specified by:

available in interface ExtendedDataInput

Overrides:

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

Returns:

Number of bytes available

getPos

public abstract int getPos()

What position in the stream?

Specified by:

getPos in interface ExtendedDataInput

Returns:

Position

require

protected int require(int requiredBytes)

Check whether there are enough remaining bytes for an operation

Overrides:

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

Parameters:

requiredBytes - Bytes required to read

skipBytes

public int skipBytes(int n)

Specified by:

skipBytes in interface DataInput

readLine

public String readLine()
                throws IOException

Specified by:

readLine in interface DataInput

Throws:

IOException

readUTF

public String readUTF()
               throws IOException

Specified by:

readUTF in interface DataInput

Throws:

IOException