org.apache.ignite.internal.portable.streams

Class PortableAbstractInputStream

java.lang.Object

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

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

All Implemented Interfaces:

PortableInputStream, PortableStream

Direct Known Subclasses:

PortableHeapInputStream, PortableOffheapInputStream

public abstract class PortableAbstractInputStream
extends PortableAbstractStream
implements PortableInputStream

Portable abstract input stream.

Field Summary

Fields

Modifier and Type	Field and Description
protected int	len Length of data inside array.

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
PortableAbstractInputStream()

Method Summary

Methods

Modifier and Type	Method and Description
protected abstract void	copyAndShift(Object target, long off, int len) Copy data to target object shift position afterwards.
protected void	ensureEnoughData(int cnt) Ensure that there is enough data.
long	offheapPointer()
void	position(int pos)
int	read(byte[] arr, int off, int len) Reads cnt of bytes into byte array.
boolean	readBoolean() Read boolean value.
boolean[]	readBooleanArray(int cnt) Read boolean array.
byte	readByte() Read byte value.
protected abstract byte	readByteAndShift() Read next byte from the stream and perform shift.
byte[]	readByteArray(int cnt) Read byte array.
char	readChar() Read char value.
char[]	readCharArray(int cnt) Read char array.
protected abstract char	readCharFast() Read char value (fast path).
double	readDouble() Read double value.
double[]	readDoubleArray(int cnt) Read double array.
float	readFloat() Read float value.
float[]	readFloatArray(int cnt) Read float array.
int	readInt() Read int value.
int	readInt(int pos) Read int value at the given position.
int[]	readIntArray(int cnt) Read int array.
protected abstract int	readIntFast() Read int value (fast path).
protected abstract int	readIntPositioned(int pos) Internal routine for positioned int value read.
long	readLong() Read long value.
long[]	readLongArray(int cnt) Read long array.
protected abstract long	readLongFast() Read long value (fast path).
short	readShort() Read short value.
short[]	readShortArray(int cnt) Read short array.
protected abstract short	readShortFast() Read short value (fast path).

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

remaining

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

array, arrayCopy, hasArray, position

Field Detail

len

protected int len

Length of data inside array.

Constructor Detail

PortableAbstractInputStream

public PortableAbstractInputStream()

Method Detail

readByte

public byte readByte()

Read byte value.

Specified by:

readByte in interface PortableInputStream

Returns:

Byte value.

readByteArray

public byte[] readByteArray(int cnt)

Read byte array.

Specified by:

readByteArray in interface PortableInputStream

Parameters:

cnt - Expected item count.

Returns:

Byte array.

readBoolean

public boolean readBoolean()

Read boolean value.

Specified by:

readBoolean in interface PortableInputStream

Returns:

Boolean value.

readBooleanArray

public boolean[] readBooleanArray(int cnt)

Read boolean array.

Specified by:

readBooleanArray in interface PortableInputStream

Parameters:

cnt - Expected item count.

Returns:

Boolean array.

readShort

public short readShort()

Read short value.

Specified by:

readShort in interface PortableInputStream

Returns:

Short value.

readShortArray

public short[] readShortArray(int cnt)

Read short array.

Specified by:

readShortArray in interface PortableInputStream

Parameters:

cnt - Expected item count.

Returns:

Short array.

readChar

public char readChar()

Read char value.

Specified by:

readChar in interface PortableInputStream

Returns:

Char value.

readCharArray

public char[] readCharArray(int cnt)

Read char array.

Specified by:

readCharArray in interface PortableInputStream

Parameters:

cnt - Expected item count.

Returns:

Char array.

readInt

public int readInt()

Read int value.

Specified by:

readInt in interface PortableInputStream

Returns:

Int value.

readIntArray

public int[] readIntArray(int cnt)

Read int array.

Specified by:

readIntArray in interface PortableInputStream

Parameters:

cnt - Expected item count.

Returns:

Int array.

readInt

public int readInt(int pos)

Read int value at the given position.

Specified by:

readInt in interface PortableInputStream

Parameters:

pos - Position.

Returns:

Value.

readFloat

public float readFloat()

Read float value.

Specified by:

readFloat in interface PortableInputStream

Returns:

Float value.

readFloatArray

public float[] readFloatArray(int cnt)

Read float array.

Specified by:

readFloatArray in interface PortableInputStream

Parameters:

cnt - Expected item count.

Returns:

Float array.

readLong

public long readLong()

Read long value.

Specified by:

readLong in interface PortableInputStream

Returns:

Long value.

readLongArray

public long[] readLongArray(int cnt)

Read long array.

Specified by:

readLongArray in interface PortableInputStream

Parameters:

cnt - Expected item count.

Returns:

Long array.

readDouble

public double readDouble()

Read double value.

Specified by:

readDouble in interface PortableInputStream

Returns:

Double value.

readDoubleArray

public double[] readDoubleArray(int cnt)

Read double array.

Specified by:

readDoubleArray in interface PortableInputStream

Parameters:

cnt - Expected item count.

Returns:

Double array.

read

public int read(byte[] arr,
       int off,
       int len)

Reads cnt of bytes into byte array.

Specified by:

read in interface PortableInputStream

Parameters:

arr - Expected item count.

off - offset

len - number of bytes to read.

Returns:

actual length read.

position

public void position(int pos)

Specified by:

position in interface PortableStream

Parameters:

pos - Position.

offheapPointer

public long offheapPointer()

Specified by:

offheapPointer in interface PortableStream

Returns:

Offheap pointer if stream is offheap based, otherwise 0.

ensureEnoughData

protected void ensureEnoughData(int cnt)

Ensure that there is enough data.

Parameters:

cnt - Length.

readByteAndShift

protected abstract byte readByteAndShift()

Read next byte from the stream and perform shift.

Returns:

Next byte.

copyAndShift

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

Copy data to target object shift position afterwards.

Parameters:

target - Target.

off - Offset.

len - Length.

readShortFast

protected abstract short readShortFast()

Read short value (fast path).

Returns:

Short value.

readCharFast

protected abstract char readCharFast()

Read char value (fast path).

Returns:

Char value.

readIntFast

protected abstract int readIntFast()

Read int value (fast path).

Returns:

Int value.

readLongFast

protected abstract long readLongFast()

Read long value (fast path).

Returns:

Long value.

readIntPositioned

protected abstract int readIntPositioned(int pos)

Internal routine for positioned int value read.

Parameters:

pos - Position.

Returns:

Int value.