Package org.infinispan.distexec
Interface DistributedCallable<K,V,T>
-
- All Superinterfaces:
Callable<T>
- All Known Implementing Classes:
ClusterEventCallable
,ClusterListenerRemoveCallable
,ClusterListenerReplicateCallable
,MigrationTask
,MultiClusterEventCallable
public interface DistributedCallable<K,V,T> extends Callable<T>
A task that returns a result and may throw an exception capable of being executed in another JVM.- Since:
- 5.0
- Author:
- Manik Surtani, Vladimir Blagojevic
- See Also:
Callable
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
setEnvironment(Cache<K,V> cache, Set<K> inputKeys)
Invoked by execution environment after DistributedCallable has been migrated for execution to a specific Infinispan node.
-
-
-
Method Detail
-
setEnvironment
void setEnvironment(Cache<K,V> cache, Set<K> inputKeys)
Invoked by execution environment after DistributedCallable has been migrated for execution to a specific Infinispan node.- Parameters:
cache
- cache whose keys are used as input data for this DistributedCallable taskinputKeys
- keys used as input for this DistributedCallable task
-
-