You can start a transaction in the stream receiver to make it atomic. On Fri, Jun 29, 2018, 1:02 PM breischl <[email protected]> wrote:
> 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/ > > Disclaimer The information contained in this communication from the sender is confidential. It is intended solely for use by the recipient and others authorized to receive it. If you are not the recipient, you are hereby notified that any disclosure, copying, distribution or taking action in relation of the contents of this information is strictly prohibited and may be unlawful. This email has been scanned for viruses and malware, and may have been automatically archived by Mimecast Ltd, an innovator in Software as a Service (SaaS) for business. Providing a safer and more useful place for your human generated data. Specializing in; Security, archiving and compliance. To find out more visit the Mimecast website.
