org.apache.giraph.utils

Class UnsafeReusableByteArrayInput

java.lang.Object

java.io.InputStream

com.esotericsoftware.kryo.io.Input

org.apache.giraph.utils.UnsafeReads

org.apache.giraph.utils.UnsafeArrayReads

org.apache.giraph.utils.UnsafeReusableByteArrayInput

All Implemented Interfaces:

Closeable, DataInput, AutoCloseable, ExtendedDataInput

public class UnsafeReusableByteArrayInput
extends UnsafeArrayReads

UnsafeReusableByteArrayInput is a data structure to read from a byte buffer with a read pointer that can be moved to desired location

Field Summary

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

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

Constructor Summary

Constructors

Constructor and Description
UnsafeReusableByteArrayInput() Default Constructor

Method Summary

Modifier and Type	Method and Description
void	initialize(byte[] buf, int offset, int length) Initialize the object with all required parameters

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

available, endOfInput, getInt, getPos, readBoolean, readByte, readChar, readDouble, readFloat, readFully, readFully, readInt, readLong, readShort, readUnsignedByte, 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

UnsafeReusableByteArrayInput

public UnsafeReusableByteArrayInput()

Default Constructor

Method Detail

initialize

public void initialize(byte[] buf,
                       int offset,
                       int length)

Initialize the object with all required parameters

Parameters:

buf - byte buffer

offset - offset in the buffer

length - length of the valid data