I'm using @AffinityKeyMapped to ensure that all items of a particular field
(the "parent" in my case) are processed on the same node. When I want to
process an entree, I'm essentially
doingignite.compute().affinityRun("my-cache", key, () ->
this::processEntry);where processEntry does:cache.invoke(key, (entry, args)
-> {  if( entry.exists() ){ modify(entry); } else { create(entry); }  return
true;});Is this generally a valid way to deal with atomically updating
entrees within a partitioned cache?Thanks,- Matt



--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Reply via email to