org.apache.ignite.internal.portable.streams

Class PortableHeapInputStream

java.lang.Object

org.apache.ignite.internal.portable.streams.PortableAbstractStream

org.apache.ignite.internal.portable.streams.PortableAbstractInputStream

org.apache.ignite.internal.portable.streams.PortableHeapInputStream

All Implemented Interfaces:

PortableInputStream, PortableStream

public final class PortableHeapInputStream
extends PortableAbstractInputStream

Portable off-heap input stream.

Field Summary

Fields inherited from class org.apache.ignite.internal.portable.streams.PortableAbstractInputStream

len

Fields inherited from class org.apache.ignite.internal.portable.streams.PortableAbstractStream

BOOLEAN_ARR_OFF, BYTE_ARR_OFF, BYTE_ONE, BYTE_ZERO, CHAR_ARR_OFF, DOUBLE_ARR_OFF, FLOAT_ARR_OFF, INT_ARR_OFF, LITTLE_ENDIAN, LONG_ARR_OFF, pos, SHORT_ARR_OFF, UNSAFE

Constructor Summary

Constructors

Constructor and Description
PortableHeapInputStream(byte[] data) Constructor.

Method Summary

Methods

Modifier and Type	Method and Description
byte[]	array()
byte[]	arrayCopy()
PortableHeapInputStream	copy()
protected void	copyAndShift(Object target, long off, int len) Copy data to target object shift position afterwards.
boolean	hasArray()
protected byte	readByteAndShift() Read next byte from the stream and perform shift.
protected char	readCharFast() Read char value (fast path).
protected int	readIntFast() Read int value (fast path).
protected int	readIntPositioned(int pos) Internal routine for positioned int value read.
protected long	readLongFast() Read long value (fast path).
protected short	readShortFast() Read short value (fast path).
int	remaining() Gets amount of remaining data in bytes.
byte[]	resize(int len) Method called from JNI to resize stream.

Methods inherited from class org.apache.ignite.internal.portable.streams.PortableAbstractInputStream

ensureEnoughData, offheapPointer, position, read, readBoolean, readBooleanArray, readByte, readByteArray, readChar, readCharArray, readDouble, readDoubleArray, readFloat, readFloatArray, readInt, readInt, readIntArray, readLong, readLongArray, readShort, readShortArray

Methods inherited from class org.apache.ignite.internal.portable.streams.PortableAbstractStream

position, shift

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.ignite.internal.portable.streams.PortableStream

position

Constructor Detail

PortableHeapInputStream

public PortableHeapInputStream(byte[] data)

Constructor.

Parameters:

data - Data.

Method Detail

copy

public PortableHeapInputStream copy()

Returns:

Copy of this stream.

resize

public byte[] resize(int len)

Method called from JNI to resize stream.

Parameters:

len - Required length.

Returns:

Underlying byte array.

remaining

public int remaining()

Gets amount of remaining data in bytes.

Returns:

Remaining data.

array

public byte[] array()

Returns:

Underlying array.

arrayCopy

public byte[] arrayCopy()

Returns:

Copy of data in the stream.

hasArray

public boolean hasArray()

Returns:

True is stream is array based.

readByteAndShift

protected byte readByteAndShift()

Read next byte from the stream and perform shift.

Specified by:

readByteAndShift in class PortableAbstractInputStream

Returns:

Next byte.

copyAndShift

protected void copyAndShift(Object target,
                long off,
                int len)

Copy data to target object shift position afterwards.

Specified by:

copyAndShift in class PortableAbstractInputStream

Parameters:

target - Target.

off - Offset.

len - Length.

readShortFast

protected short readShortFast()

Read short value (fast path).

Specified by:

readShortFast in class PortableAbstractInputStream

Returns:

Short value.

readCharFast

protected char readCharFast()

Read char value (fast path).

Specified by:

readCharFast in class PortableAbstractInputStream

Returns:

Char value.

readIntFast

protected int readIntFast()

Read int value (fast path).

Specified by:

readIntFast in class PortableAbstractInputStream

Returns:

Int value.

readLongFast

protected long readLongFast()

Read long value (fast path).

Specified by:

readLongFast in class PortableAbstractInputStream

Returns:

Long value.

readIntPositioned

protected int readIntPositioned(int pos)

Internal routine for positioned int value read.

Specified by:

readIntPositioned in class PortableAbstractInputStream

Parameters:

pos - Position.

Returns:

Int value.