public interface DistributedCallable<K,V,T>
extends java.util.concurrent.Callable<T>
Callable
Modifier and Type | Method and Description |
---|---|
void |
setEnvironment(Cache<K,V> cache,
java.util.Set<K> inputKeys)
Invoked by execution environment after DistributedCallable has been migrated for execution to
a specific Infinispan node.
|
void setEnvironment(Cache<K,V> cache, java.util.Set<K> inputKeys)
cache
- cache whose keys are used as input data for this DistributedCallable taskinputKeys
- keys used as input for this DistributedCallable task