Thanks for the pointers stephendarlington, ptupitsyn. Looks like I can run a mapper that does a local SQL query to get the set of keys for the tenant (that resides on the local server node), and then do Compute.affinityRun or Cache.invokeAll.
For Cache.invokeAll, it takes a dictionary of keys to EntryProcessor so that is easy to understand. For Compute.affinityRun, I am not sure how to work with it for my scenario: * It takes an affinity key to find the partition's server to run the IgniteRunnable but I don't see an interface to pass in the specific keys? Am I expected to pass the key set as part of IgniteRunnable object? * Suppose the cache use user_id as the affinity key then it is possible that 2 user_id will map to the same partition. How do I avoid duplicate processing/scanning? -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/
