Toggle navigation
Home
org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridNearAtomicUpdateRequest to org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridNearAtomicAbstractUpdateRequest
No. of Instances - 32
No. of Commits - 1
No. of Projects - {'ignite'}
Hierarchy/Composition: SIBLING
Primitive Info: -
NameSpace: Internal -> Internal
Mapping:
Add or Remove Method invocation
updateReq.keys().size()
to
updateReq.size()
U.newHashMap(updateReq.keys().size())
to
U.newHashMap(updateReq.size())
req.keys().size()
to
req.size()
req.keys().size()
to
req.size()
req.keys()
to
req
keys.size()
to
req.size()
req.keys()
to
req
Rename Method invocation
keys
to
key
keys
to
key
Cascading Type Change (Similar)
CI2<GridNearAtomicUpdateRequest,GridNearAtomicUpdateResponse>
to
CI2<GridNearAtomicAbstractUpdateRequest,GridNearAtomicUpdateResponse>
GridNearAtomicUpdateRequest
to
GridNearAtomicAbstractUpdateRequest
GridNearAtomicUpdateRequest
to
GridNearAtomicAbstractUpdateRequest
Update Anonymous class
{ @SuppressWarnings("ThrowableResultOfMethodCallIgnored") @Override public void apply( GridNearAtomicUpdateRequest req, GridNearAtomicUpdateResponse res){ if (ctx.config().getAtomicWriteOrderMode() == CLOCK) { assert req.writeSynchronizationMode() != FULL_ASYNC : req; sendNearUpdateReply(res.nodeId(),res); return; } assert req.hasPrimary() : req; if (req.writeSynchronizationMode() != FULL_ASYNC) sendNearUpdateReply(res.nodeId(),res); else { if (!F.isEmpty(res.remapKeys())) remapToNewPrimary(req); else if (res.error() != null) { U.error(log,"Failed to process write update request in FULL_ASYNC mode for keys: " + res.failedKeys(),res.error()); } } } }
to
{ @SuppressWarnings("ThrowableResultOfMethodCallIgnored") @Override public void apply( GridNearAtomicAbstractUpdateRequest req, GridNearAtomicUpdateResponse res){ if (ctx.config().getAtomicWriteOrderMode() == CLOCK) { assert req.writeSynchronizationMode() != FULL_ASYNC : req; sendNearUpdateReply(res.nodeId(),res); return; } assert req.hasPrimary() : req; if (req.writeSynchronizationMode() != FULL_ASYNC) sendNearUpdateReply(res.nodeId(),res); else { if (!F.isEmpty(res.remapKeys())) remapToNewPrimary(req); else if (res.error() != null) { U.error(log,"Failed to process write update request in FULL_ASYNC mode for keys: " + res.failedKeys(),res.error()); } } } }
Cascading Type Change (Different)
List<KeyCacheObject>
to
KeyCacheObject
GridNearAtomicUpdateRequest
to
GridNearAtomicFullUpdateRequest