Package org.apache.ignite.internal.processors.datastreamer

Class DataStreamerEntry

java.lang.Object

org.apache.ignite.internal.processors.datastreamer.DataStreamerEntry

All Implemented Interfaces:

Serializable, Map.Entry<KeyCacheObject,CacheObject>, Message

Direct Known Subclasses:

GridCacheRawVersionedEntry

public class DataStreamerEntry
extends Object
implements Map.Entry<KeyCacheObject,CacheObject>, Message

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
protected KeyCacheObject	key
protected CacheObject	val

Fields inherited from interface org.apache.ignite.plugin.extensions.communication.Message

DIRECT_TYPE_SIZE

Constructor Summary

Constructors

Constructor	Description
DataStreamerEntry()
DataStreamerEntry(KeyCacheObject key, CacheObject val)

Method Summary

Modifier and Type	Method	Description
short	directType()	Gets message type.
byte	fieldsCount()	Gets fields count.
KeyCacheObject	getKey()
CacheObject	getValue()
void	onAckReceived()	Method called when ack message received.
boolean	readFrom(ByteBuffer buf, MessageReader reader)	Reads this message from provided byte buffer.
CacheObject	setValue(CacheObject val)
<K,V> Map.Entry<K,V>	toEntry(GridCacheContext ctx, boolean keepBinary)
String	toString()
boolean	writeTo(ByteBuffer buf, MessageWriter writer)	Writes this message to provided byte buffer.

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.Map.Entry

equals, hashCode

Field Detail

key

@GridToStringInclude
protected KeyCacheObject key

val

@GridToStringInclude
protected CacheObject val

Constructor Detail

DataStreamerEntry

public DataStreamerEntry()

DataStreamerEntry

public DataStreamerEntry(KeyCacheObject key,
                         CacheObject val)

Parameters:

key - Key.

val - Value.

Method Detail

getKey

public KeyCacheObject getKey()

Specified by:

getKey in interface Map.Entry<KeyCacheObject,CacheObject>

getValue

public CacheObject getValue()

Specified by:

getValue in interface Map.Entry<KeyCacheObject,CacheObject>

setValue

public CacheObject setValue(CacheObject val)

Specified by:

setValue in interface Map.Entry<KeyCacheObject,CacheObject>

toEntry

public <K,V> Map.Entry<K,V> toEntry(GridCacheContext ctx,
                                                boolean keepBinary)

Parameters:

ctx - Cache context.

Returns:

Map entry unwrapping internal key and value.

onAckReceived

public void onAckReceived()

Method called when ack message received.

Specified by:

onAckReceived in interface Message

writeTo

public boolean writeTo(ByteBuffer buf,
                       MessageWriter writer)

Writes this message to provided byte buffer.

Specified by:

writeTo in interface Message

Parameters:

buf - Byte buffer.

writer - Writer.

Returns:

Whether message was fully written.

readFrom

public boolean readFrom(ByteBuffer buf,
                        MessageReader reader)

Reads this message from provided byte buffer.

Specified by:

readFrom in interface Message

Parameters:

buf - Byte buffer.

reader - Reader.

Returns:

Whether message was fully read.

directType

public short directType()

Gets message type.

Specified by:

directType in interface Message

Returns:

Message type.

fieldsCount

public byte fieldsCount()

Gets fields count.

Specified by:

fieldsCount in interface Message

Returns:

Fields count.

toString

public String toString()

Overrides:

toString in class Object