org.infinispan.distexec
Class AbstractDistributedTask<K,V,T,R>

java.lang.Object
  extended by org.infinispan.distexec.AbstractDistributedTask<K,V,T,R>
Direct Known Subclasses:
MapReduceTask

public class AbstractDistributedTask<K,V,T,R>
extends Object

AbstractDistributedTask class provides settings for various distributed task characteristics such as fail-over and cancellation policies etc etc

Since:
5.0
Author:
Manik Surtani, Vladimir Blagojevic

Constructor Summary
AbstractDistributedTask(Cache<K,V> cache)
           
 
Method Summary
 Map<DistributedCallable<K,V,T>,Address> executionMap(K... input)
          Maps DistributedCallables to Infinispan nodes.
 String getCacheName()
          Invoked by execution environment before DistributedTask map phase is invoked.
 void setCancelationPolicy()
          FIXME Comment this
 void setExecutionNodeSplittingPolicy()
          FIXME Comment this
 void setFailOverPolicy()
          FIXME Comment this
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

AbstractDistributedTask

public AbstractDistributedTask(Cache<K,V> cache)
Method Detail

getCacheName

public String getCacheName()
Invoked by execution environment before DistributedTask map phase is invoked. getCacheName specifies cache used as input data for DistributedTask.

Returns:
collection of keys used as an input

executionMap

public Map<DistributedCallable<K,V,T>,Address> executionMap(K... input)
                                                     throws Exception
Maps DistributedCallables to Infinispan nodes. DistributedCallables are going to be migrated for execution to nodes according to a returned execution map.

Parameters:
input - input keys for this task
Returns:
map of DistributedCallables to be executed in Infinispan cloud where each DistributedCallable is mapped to a particular node for execution
Throws:
Exception

setFailOverPolicy

public void setFailOverPolicy()
FIXME Comment this


setExecutionNodeSplittingPolicy

public void setExecutionNodeSplittingPolicy()
FIXME Comment this


setCancelationPolicy

public void setCancelationPolicy()
FIXME Comment this



Copyright © 2011 JBoss, a division of Red Hat. All Rights Reserved.