org.apache.ignite.internal.portable.streams

Class PortableHeapOutputStream

java.lang.Object

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

org.apache.ignite.internal.portable.streams.PortableAbstractOutputStream

org.apache.ignite.internal.portable.streams.PortableHeapOutputStream

All Implemented Interfaces:

AutoCloseable, PortableOutputStream, PortableStream

public final class PortableHeapOutputStream
extends PortableAbstractOutputStream

Portable heap output stream.

Field Summary

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
PortableHeapOutputStream(int cap) Constructor.
PortableHeapOutputStream(int cap, PortableMemoryAllocatorChunk chunk) Constructor.

Method Summary

Methods

Modifier and Type	Method and Description
byte[]	array()
byte[]	arrayCopy()
void	close() Close the stream releasing resources.
protected void	copyAndShift(Object src, long off, int len) Copy source object to the stream shift position afterwards.
void	ensureCapacity(int cnt) Ensure capacity.
boolean	hasArray()
void	unsafeWriteByte(byte val) Write byte in unsafe mode.
void	unsafeWriteChar(char val) Write char in unsafe mode.
void	unsafeWriteInt(int val) Write int in unsafe mode.
void	unsafeWriteInt(int pos, int val) Write int in unsafe mode.
void	unsafeWriteLong(long val) Write long in unsafe mode.
void	unsafeWriteShort(int pos, short val) Write short in unsafe mode.
void	unsafeWriteShort(short val) Write short in unsafe mode.
protected void	writeByteAndShift(byte val) Write next byte to the stream.
protected void	writeCharFast(char val) Write char value (fast path).
protected void	writeIntFast(int val) Write int value (fast path).
protected void	writeLongFast(long val) Write long value (fast path).
protected void	writeShortFast(short val) Write short value (fast path).

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

capacity, offheapPointer, position, unsafeEnsure, unsafePosition, unsafeWriteBoolean, unsafeWriteDouble, unsafeWriteFloat, write, write, writeBoolean, writeBooleanArray, writeByte, writeByteArray, writeChar, writeCharArray, writeDouble, writeDoubleArray, writeFloat, writeFloatArray, writeInt, writeInt, writeIntArray, writeLong, writeLongArray, writeShort, writeShort, writeShortArray

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

PortableHeapOutputStream

public PortableHeapOutputStream(int cap)

Constructor.

Parameters:

cap - Initial capacity.

PortableHeapOutputStream

public PortableHeapOutputStream(int cap,
                        PortableMemoryAllocatorChunk chunk)

Constructor.

Parameters:

cap - Capacity.

chunk - Chunk.

Method Detail

close

public void close()

Close the stream releasing resources.

ensureCapacity

public void ensureCapacity(int cnt)

Ensure capacity.

Specified by:

ensureCapacity in class PortableAbstractOutputStream

Parameters:

cnt - Required byte count.

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.

writeByteAndShift

protected void writeByteAndShift(byte val)

Write next byte to the stream.

Specified by:

writeByteAndShift in class PortableAbstractOutputStream

Parameters:

val - Value.

copyAndShift

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

Copy source object to the stream shift position afterwards.

Specified by:

copyAndShift in class PortableAbstractOutputStream

Parameters:

src - Source.

off - Offset.

len - Length.

writeShortFast

protected void writeShortFast(short val)

Write short value (fast path).

Specified by:

writeShortFast in class PortableAbstractOutputStream

Parameters:

val - Short value.

writeCharFast

protected void writeCharFast(char val)

Write char value (fast path).

Specified by:

writeCharFast in class PortableAbstractOutputStream

Parameters:

val - Char value.

writeIntFast

protected void writeIntFast(int val)

Write int value (fast path).

Specified by:

writeIntFast in class PortableAbstractOutputStream

Parameters:

val - Int value.

writeLongFast

protected void writeLongFast(long val)

Write long value (fast path).

Specified by:

writeLongFast in class PortableAbstractOutputStream

Parameters:

val - Long value.

unsafeWriteByte

public void unsafeWriteByte(byte val)

Write byte in unsafe mode.

Parameters:

val - Value.

unsafeWriteShort

public void unsafeWriteShort(short val)

Write short in unsafe mode.

Parameters:

val - Value.

unsafeWriteShort

public void unsafeWriteShort(int pos,
                    short val)

Write short in unsafe mode.

Parameters:

pos - Position.

val - Value.

unsafeWriteChar

public void unsafeWriteChar(char val)

Write char in unsafe mode.

Parameters:

val - Value.

unsafeWriteInt

public void unsafeWriteInt(int val)

Write int in unsafe mode.

Parameters:

val - Value.

unsafeWriteInt

public void unsafeWriteInt(int pos,
                  int val)

Write int in unsafe mode.

Parameters:

pos - Position.

val - Value.

unsafeWriteLong

public void unsafeWriteLong(long val)

Write long in unsafe mode.

Parameters:

val - Value.