ignite-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Alexey Kukushkin <kukushkinale...@gmail.com>
Subject Re: How to do 'stream processing' and more questions of a Ignite newbie
Date Mon, 25 Dec 2017 09:29:18 GMT
Cache#invoke(key, entryProcessor) executes the "entryProcessor" on a node
where the "key" is stored. This is called "colocated processing" that
allows you to offload processing from client to server nodes and avoid
transferring the "key" and result over the network (although now we have to
transfer the computation over the network).

In your example (1) and (2) is executed on the client and (3) is executed
on a server node where "accPoint" is stored.

If you want everything executed on the server node then just put all the
code inside the entryProcessor.

View raw message