Class GridNearAtomicSingleUpdateInvokeRequest
- java.lang.Object
-
- org.apache.ignite.internal.processors.cache.GridCacheMessage
-
- org.apache.ignite.internal.processors.cache.GridCacheIdMessage
-
- org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridNearAtomicAbstractUpdateRequest
-
- org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridNearAtomicAbstractSingleUpdateRequest
-
- org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridNearAtomicSingleUpdateRequest
-
- org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridNearAtomicSingleUpdateInvokeRequest
-
- All Implemented Interfaces:
Serializable,GridCacheDeployable,Message
public class GridNearAtomicSingleUpdateInvokeRequest extends GridNearAtomicSingleUpdateRequest
- See Also:
- Serialized Form
-
-
Field Summary
-
Fields inherited from class org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridNearAtomicSingleUpdateRequest
key, val
-
Fields inherited from class org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridNearAtomicAbstractUpdateRequest
CACHE_MSG_IDX, flags, futId, nodeId, op, syncMode, taskNameHash, topVer
-
Fields inherited from class org.apache.ignite.internal.processors.cache.GridCacheIdMessage
cacheId
-
Fields inherited from class org.apache.ignite.internal.processors.cache.GridCacheMessage
addDepInfo, CACHE_MSG_INDEX_FIELD_NAME, forceAddDepInfo, MAX_CACHE_MSG_LOOKUP_INDEX
-
Fields inherited from interface org.apache.ignite.plugin.extensions.communication.Message
DIRECT_TYPE_SIZE
-
-
Constructor Summary
Constructors Constructor Description GridNearAtomicSingleUpdateInvokeRequest()Empty constructor required byExternalizable.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidaddUpdateEntry(KeyCacheObject key, @Nullable Object val, long conflictTtl, long conflictExpireTime, @Nullable GridCacheVersion conflictVer)voidcleanup(boolean clearKey)Cleanup values.shortdirectType()Gets message type.javax.cache.processor.EntryProcessor<Object,Object,Object>entryProcessor(int idx)bytefieldsCount()Gets fields count.voidfinishUnmarshal(GridCacheSharedContext ctx, ClassLoader ldr)This method is called after the message is deserialized and is responsible for unmarshalling state marshalled inGridCacheMessage.prepareMarshal(GridCacheSharedContext)method.@Nullable Object[]invokeArguments()voidprepareMarshal(GridCacheSharedContext ctx)This method is called before the whole message is serialized and is responsible for pre-marshalling state.booleanreadFrom(ByteBuffer buf, MessageReader reader)Reads this message from provided byte buffer.StringtoString()CacheObjectvalue(int idx)List<?>values()booleanwriteTo(ByteBuffer buf, MessageWriter writer)Writes this message to provided byte buffer.CacheObjectwriteValue(int idx)-
Methods inherited from class org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridNearAtomicSingleUpdateRequest
conflictExpireTime, conflictTtl, conflictVersion, conflictVersions, key, keys, partition, size
-
Methods inherited from class org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridNearAtomicAbstractSingleUpdateRequest
expiry, filter
-
Methods inherited from class org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridNearAtomicAbstractUpdateRequest
addDeploymentInfo, futureId, keepBinary, keepBinary, lookupIndex, messageLogger, nearCache, nodeId, onResponse, operation, recovery, recovery, response, returnValue, returnValue, skipStore, skipStore, taskNameHash, topologyVersion, writeSynchronizationMode
-
Methods inherited from class org.apache.ignite.internal.processors.cache.GridCacheIdMessage
cacheGroupMessage, cacheId, cacheId, handlerId
-
Methods inherited from class org.apache.ignite.internal.processors.cache.GridCacheMessage
appendFlag, classError, deployInfo, error, finishUnmarshalCacheObjects, finishUnmarshalCacheObjects, ignoreClassErrors, lastAffinityChangedTopologyVersion, lastAffinityChangedTopologyVersion, marshalCollection, marshalInfo, marshalInfos, marshalInvokeArguments, marshalTx, messageId, nextIndexId, onAckReceived, onClassError, partitionExchangeMessage, prepare, prepareMarshalCacheObject, prepareMarshalCacheObjects, prepareMarshalCacheObjects, prepareObject, prepareObject, transferExpiryPolicy, unmarshalCollection, unmarshalInfo, unmarshalInfos, unmarshalInvokeArguments, unmarshalTx
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
-
Methods inherited from interface org.apache.ignite.internal.processors.cache.GridCacheDeployable
deployInfo, prepare
-
-
-
-
Constructor Detail
-
GridNearAtomicSingleUpdateInvokeRequest
public GridNearAtomicSingleUpdateInvokeRequest()
Empty constructor required byExternalizable.
-
-
Method Detail
-
addUpdateEntry
public void addUpdateEntry(KeyCacheObject key, @Nullable @Nullable Object val, long conflictTtl, long conflictExpireTime, @Nullable @Nullable GridCacheVersion conflictVer)
- Overrides:
addUpdateEntryin classGridNearAtomicSingleUpdateRequest- Parameters:
key- Key to add.val- Optional update value.conflictTtl- Conflict TTL (optional).conflictExpireTime- Conflict expire time (optional).conflictVer- Conflict version (optional).
-
values
public List<?> values()
- Overrides:
valuesin classGridNearAtomicSingleUpdateRequest- Returns:
- Values for this update request.
-
value
public CacheObject value(int idx)
- Overrides:
valuein classGridNearAtomicSingleUpdateRequest- Parameters:
idx- Key index.- Returns:
- Value.
-
entryProcessor
public javax.cache.processor.EntryProcessor<Object,Object,Object> entryProcessor(int idx)
- Overrides:
entryProcessorin classGridNearAtomicSingleUpdateRequest- Parameters:
idx- Key index.- Returns:
- Entry processor.
-
writeValue
public CacheObject writeValue(int idx)
- Overrides:
writeValuein classGridNearAtomicSingleUpdateRequest- Parameters:
idx- Index to get.- Returns:
- Write value - either value, or transform closure.
-
invokeArguments
@Nullable public @Nullable Object[] invokeArguments()
- Overrides:
invokeArgumentsin classGridNearAtomicAbstractSingleUpdateRequest- Returns:
- Optional arguments for entry processor.
-
prepareMarshal
public void prepareMarshal(GridCacheSharedContext ctx) throws IgniteCheckedException
This method is called before the whole message is serialized and is responsible for pre-marshalling state.- Overrides:
prepareMarshalin classGridNearAtomicSingleUpdateRequest- Parameters:
ctx- Cache context.- Throws:
IgniteCheckedException- If failed.
-
finishUnmarshal
public void finishUnmarshal(GridCacheSharedContext ctx, ClassLoader ldr) throws IgniteCheckedException
This method is called after the message is deserialized and is responsible for unmarshalling state marshalled inGridCacheMessage.prepareMarshal(GridCacheSharedContext)method.- Overrides:
finishUnmarshalin classGridNearAtomicSingleUpdateRequest- Parameters:
ctx- Context.ldr- Class loader.- Throws:
IgniteCheckedException- If failed.
-
cleanup
public void cleanup(boolean clearKey)
Cleanup values.- Overrides:
cleanupin classGridNearAtomicSingleUpdateRequest- Parameters:
clearKey- Iftrueclears keys.
-
writeTo
public boolean writeTo(ByteBuffer buf, MessageWriter writer)
Writes this message to provided byte buffer.- Specified by:
writeToin interfaceMessage- Overrides:
writeToin classGridNearAtomicSingleUpdateRequest- 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:
readFromin interfaceMessage- Overrides:
readFromin classGridNearAtomicSingleUpdateRequest- Parameters:
buf- Byte buffer.reader- Reader.- Returns:
- Whether message was fully read.
-
fieldsCount
public byte fieldsCount()
Gets fields count.- Specified by:
fieldsCountin interfaceMessage- Overrides:
fieldsCountin classGridNearAtomicSingleUpdateRequest- Returns:
- Fields count.
-
directType
public short directType()
Gets message type.- Specified by:
directTypein interfaceMessage- Overrides:
directTypein classGridNearAtomicSingleUpdateRequest- Returns:
- Message type.
-
toString
public String toString()
- Overrides:
toStringin classGridNearAtomicSingleUpdateRequest
-
-