Hi,
I am currently using Infinispan
Distributed Execution Framework for my Master thesis project and I am
wondering if it is possible that a DistributedCallable receives some
custom parameters from the framework upon a failover, besides Cache
instance and Set of keys passed in the setEnvironment method. As a
simplified example, a DistributedCallable wants to know whether it
was restarted or freshly started. If this is not possible, does it
make sense to add a new method to the DistributedTaskFailoverPolicy
which will return a user supplied parameters Map and then read it
from the setEnvironment method in the DistributedCallable? Here are
the signatures of the methods I was thinking off:
In the DistributedTaskFailoverPolicy
class:
Map<Object, Object>
getEnvironmentParameters()
In the DistributedCallable class:
setEnvironment(Cache<K, V> cache,
Set<K> inputKeys, Map<Object, Object> params)
I was free to try to implement this and
did not take to much time, so now I am wondering if there was already
a way to do something like this in the Infinispan DEF.
Thank you in advance for your comments
and suggestions.
Strahinja Lazetic