StreamTransformer does an invoke() pretty much exactly like what I'm doing, so that would not seem to change anything.
https://github.com/apache/ignite/blob/master/modules/core/src/main/java/org/apache/ignite/stream/StreamTransformer.java#L50-L53 I may try using a put(), but since I need to compare the existing cache value, I'd need to get(), compare, then put(). I thought that may open up a potential race condition, if two different updates happen close to each other they could each do get(), then each do put(), but potentially in the wrong order. Unless there's some locking I don't understand there? -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/
