Igniters,
jira: https://issues.apache.org/jira/browse/IGNITE-5037
<https://issues.apache.org/jira/browse/IGNITE-5037>
How do you look to solve this ticket by adding two methods to the public
IgniteCompute API?
@IgniteAsyncSupported
public void affinityRun(@NotNull Collection<String> cacheNames,
Collection<Object> keys, IgniteRunnable job)
throws IgniteException;
@IgniteAsyncSupported
public <R> R affinityCall(@NotNull Collection<String> cacheNames,
Collection<Object> keys, IgniteCallable<R> job)
throws IgniteException;
There is also a question of how to act when changing the topology during the
execution of the job.
1) complete with an exception;
2) stop execution and wait until the topology is rebuilt and continue execution;
I think the second way, do you think?
--
Best Regards,
Max K.
