org.apache.giraph.utils

Class UnsafeByteArrayInputStream

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.UnsafeByteArrayInputStream

All Implemented Interfaces:

Closeable, DataInput, AutoCloseable, ExtendedDataInput

public class UnsafeByteArrayInputStream
extends UnsafeArrayReads

UnsafeByteArrayInputStream This stream now extends com.esotericsoftware.kryo.io.Input so that kryo serialization can directly read from this stream without using an additional buffer, providing a faster serialization. Users of this class has to explicitly close the stream to avoid style check errors even though close is no-op when the underlying stream is not set.

Field Summary

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

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

Constructor Summary

Constructors

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

Method Summary

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

UnsafeByteArrayInputStream

public UnsafeByteArrayInputStream(byte[] buf)

Constructor

Parameters:

buf - Buffer to read from

UnsafeByteArrayInputStream

public UnsafeByteArrayInputStream(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