|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.infinispan.distexec.AbstractDistributedTask<K,V,T,R>
public class AbstractDistributedTask<K,V,T,R>
AbstractDistributedTask class provides settings for various distributed task characteristics such as fail-over and cancellation policies etc etc
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 |
---|
public AbstractDistributedTask(Cache<K,V> cache)
Method Detail |
---|
public String getCacheName()
public Map<DistributedCallable<K,V,T>,Address> executionMap(K... input) throws Exception
input
- input keys for this task
Exception
public void setFailOverPolicy()
public void setExecutionNodeSplittingPolicy()
public void setCancelationPolicy()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |