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() Constructor.
PortableHeapOutputStream(byte[] data) Constructor.
PortableHeapOutputStream(byte[] data, PortableMemoryAllocator alloc) Constructor.
PortableHeapOutputStream(int cap) Constructor.
PortableHeapOutputStream(int cap, PortableMemoryAllocator alloc) 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()
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	writeIntPositioned(int pos, int val) Write int value to the given position.
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, write, write, writeBoolean, writeBooleanArray, writeByte, writeByteArray, writeChar, writeCharArray, writeDouble, writeDoubleArray, writeFloat, writeFloatArray, writeInt, writeInt, writeIntArray, writeLong, writeLongArray, 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()

Constructor.

PortableHeapOutputStream

public PortableHeapOutputStream(int cap)

Constructor.

Parameters:

cap - Initial capacity.

PortableHeapOutputStream

public PortableHeapOutputStream(int cap,
                        PortableMemoryAllocator alloc)

Constructor.

Parameters:

cap - Initial capacity.

alloc - Allocator.

PortableHeapOutputStream

public PortableHeapOutputStream(byte[] data)

Constructor.

Parameters:

data - Data.

PortableHeapOutputStream

public PortableHeapOutputStream(byte[] data,
                        PortableMemoryAllocator alloc)

Constructor.

Parameters:

data - Data.

alloc - Allocator.

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.

writeIntPositioned

protected void writeIntPositioned(int pos,
                      int val)

Write int value to the given position.

Specified by:

writeIntPositioned in class PortableAbstractOutputStream

Parameters:

pos - Position.

val - Value.