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 KeyCacheObjectkeyprotected CacheObjectval-
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
All Methods Instance Methods Concrete Methods Modifier and Type Method Description shortdirectType()Gets message type.bytefieldsCount()Gets fields count.KeyCacheObjectgetKey()CacheObjectgetValue()voidonAckReceived()Method called when ack message received.booleanreadFrom(ByteBuffer buf, MessageReader reader)Reads this message from provided byte buffer.CacheObjectsetValue(CacheObject val)<K,V>
Map.Entry<K,V>toEntry(GridCacheContext ctx, boolean keepBinary)StringtoString()booleanwriteTo(ByteBuffer buf, MessageWriter writer)Writes this message to provided byte buffer.
-
-
-
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:
getKeyin interfaceMap.Entry<KeyCacheObject,CacheObject>
-
getValue
public CacheObject getValue()
- Specified by:
getValuein interfaceMap.Entry<KeyCacheObject,CacheObject>
-
setValue
public CacheObject setValue(CacheObject val)
- Specified by:
setValuein interfaceMap.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:
onAckReceivedin interfaceMessage
-
writeTo
public boolean writeTo(ByteBuffer buf, MessageWriter writer)
Writes this message to provided byte buffer.
-
readFrom
public boolean readFrom(ByteBuffer buf, MessageReader reader)
Reads this message from provided byte buffer.
-
directType
public short directType()
Gets message type.- Specified by:
directTypein interfaceMessage- Returns:
- Message type.
-
fieldsCount
public byte fieldsCount()
Gets fields count.- Specified by:
fieldsCountin interfaceMessage- Returns:
- Fields count.
-
-