org.apache.ignite.internal.direct

Class DirectByteBufferStream

java.lang.Object

org.apache.ignite.internal.direct.DirectByteBufferStream

public class DirectByteBufferStream
extends Object

Portable stream based on ByteBuffer.

Constructor Summary

Constructors

Constructor and Description
DirectByteBufferStream(MessageFactory msgFactory, MessageFormatter msgFormatter)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	lastFinished()
BitSet	readBitSet()
boolean	readBoolean()
boolean[]	readBooleanArray()
byte	readByte()
byte[]	readByteArray()
char	readChar()
char[]	readCharArray()
<C extends Collection<?>> C	readCollection(MessageCollectionItemType itemType)
double	readDouble()
double[]	readDoubleArray()
float	readFloat()
float[]	readFloatArray()
IgniteUuid	readIgniteUuid()
int	readInt()
int[]	readIntArray()
long	readLong()
long[]	readLongArray()
<M extends Map<?,?>> M	readMap(MessageCollectionItemType keyType, MessageCollectionItemType valType, boolean linked)
<T extends Message> T	readMessage()
<T> T[]	readObjectArray(MessageCollectionItemType itemType, Class<T> itemCls)
short	readShort()
short[]	readShortArray() /**
String	readString()
UUID	readUuid()
int	remaining()
void	setBuffer(ByteBuffer buf)
void	writeBitSet(BitSet val)
void	writeBoolean(boolean val)
void	writeBooleanArray(boolean[] val)
void	writeByte(byte val)
void	writeByteArray(byte[] val)
void	writeByteArray(byte[] val, long off, int len)
void	writeChar(char val)
void	writeCharArray(char[] val)
<T> void	writeCollection(Collection<T> col, MessageCollectionItemType itemType, MessageWriter writer)
void	writeDouble(double val)
void	writeDoubleArray(double[] val)
void	writeFloat(float val)
void	writeFloatArray(float[] val)
void	writeIgniteUuid(IgniteUuid val)
void	writeInt(int val)
void	writeIntArray(int[] val)
void	writeLong(long val)
void	writeLongArray(long[] val)
<K,V> void	writeMap(Map<K,V> map, MessageCollectionItemType keyType, MessageCollectionItemType valType, MessageWriter writer)
void	writeMessage(Message msg, MessageWriter writer)
<T> void	writeObjectArray(T[] arr, MessageCollectionItemType itemType, MessageWriter writer)
void	writeShort(short val)
void	writeShortArray(short[] val)
void	writeString(String val)
void	writeUuid(UUID val)

Methods inherited from class java.lang.Object

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

Constructor Detail

DirectByteBufferStream

public DirectByteBufferStream(MessageFactory msgFactory,
                      MessageFormatter msgFormatter)

Parameters:

msgFactory - Message factory.

msgFormatter - Message formatter.

Method Detail

setBuffer

public void setBuffer(ByteBuffer buf)

Parameters:

buf - Buffer.

remaining

public int remaining()

Returns:

Number of remaining bytes.

lastFinished

public boolean lastFinished()

Returns:

Whether last object was fully written or read.

writeByte

public void writeByte(byte val)

Parameters:

val - Value.

writeShort

public void writeShort(short val)

Parameters:

val - Value.

writeInt

public void writeInt(int val)

Parameters:

val - Value.

writeLong

public void writeLong(long val)

Parameters:

val - Value.

writeFloat

public void writeFloat(float val)

Parameters:

val - Value.

writeDouble

public void writeDouble(double val)

Parameters:

val - Value.

writeChar

public void writeChar(char val)

Parameters:

val - Value.

writeBoolean

public void writeBoolean(boolean val)

Parameters:

val - Value.

writeByteArray

public void writeByteArray(byte[] val)

Parameters:

val - Value.

writeByteArray

public void writeByteArray(byte[] val,
                  long off,
                  int len)

Parameters:

val - Value.

off - Offset.

len - Length.

writeShortArray

public void writeShortArray(short[] val)

Parameters:

val - Value

writeIntArray

public void writeIntArray(int[] val)

Parameters:

val - Value

writeLongArray

public void writeLongArray(long[] val)

Parameters:

val - Value

writeFloatArray

public void writeFloatArray(float[] val)

Parameters:

val - Value

writeDoubleArray

public void writeDoubleArray(double[] val)

Parameters:

val - Value

writeCharArray

public void writeCharArray(char[] val)

Parameters:

val - Value

writeBooleanArray

public void writeBooleanArray(boolean[] val)

Parameters:

val - Value

writeString

public void writeString(String val)

Parameters:

val - Value

writeBitSet

public void writeBitSet(BitSet val)

Parameters:

val - Value

writeUuid

public void writeUuid(UUID val)

Parameters:

val - Value

writeIgniteUuid

public void writeIgniteUuid(IgniteUuid val)

Parameters:

val - Value

writeMessage

public void writeMessage(Message msg,
                MessageWriter writer)

Parameters:

msg - Message.

writeObjectArray

public <T> void writeObjectArray(T[] arr,
                        MessageCollectionItemType itemType,
                        MessageWriter writer)

Parameters:

arr - Array.

itemType - Component type.

writer - Writer.

writeCollection

public <T> void writeCollection(Collection<T> col,
                       MessageCollectionItemType itemType,
                       MessageWriter writer)

Parameters:

col - Collection.

itemType - Item type.

writer - Writer.

writeMap

public <K,V> void writeMap(Map<K,V> map,
                  MessageCollectionItemType keyType,
                  MessageCollectionItemType valType,
                  MessageWriter writer)

Parameters:

map - Map.

keyType - Key type.

valType - Value type.

writer - Writer.

readByte

public byte readByte()

Returns:

Value.

readShort

public short readShort()

Returns:

Value.

readInt

public int readInt()

Returns:

Value.

readLong

public long readLong()

Returns:

Value.

readFloat

public float readFloat()

Returns:

Value.

readDouble

public double readDouble()

Returns:

Value.

readChar

public char readChar()

Returns:

Value.

readBoolean

public boolean readBoolean()

Returns:

Value.

readByteArray

public byte[] readByteArray()

Returns:

Value.

readShortArray

public short[] readShortArray()

/**

Returns:

Value.

readIntArray

public int[] readIntArray()

Returns:

Value.

readLongArray

public long[] readLongArray()

Returns:

Value.

readFloatArray

public float[] readFloatArray()

Returns:

Value.

readDoubleArray

public double[] readDoubleArray()

Returns:

Value.

readCharArray

public char[] readCharArray()

Returns:

Value.

readBooleanArray

public boolean[] readBooleanArray()

Returns:

Value.

readString

public String readString()

Returns:

Value.

readBitSet

public BitSet readBitSet()

Returns:

Value.

readUuid

public UUID readUuid()

Returns:

Value.

readIgniteUuid

public IgniteUuid readIgniteUuid()

Returns:

Value.

readMessage

public <T extends Message> T readMessage()

Returns:

Message.

readObjectArray

public <T> T[] readObjectArray(MessageCollectionItemType itemType,
                      Class<T> itemCls)

Parameters:

itemType - Component type.

itemCls - Component class.

Returns:

Array.

readCollection

public <C extends Collection<?>> C readCollection(MessageCollectionItemType itemType)

Parameters:

itemType - Item type.

Returns:

Collection.

readMap

public <M extends Map<?,?>> M readMap(MessageCollectionItemType keyType,
                             MessageCollectionItemType valType,
                             boolean linked)

Parameters:

keyType - Key type.

valType - Value type.

linked - Whether linked map should be created.

Returns:

Map.