| Added Methods |
void execute(String)
|
Executes this task and stores results in the provided results cache. |
void execute(Cache<KOut, VOut>)
|
Executes this task and stores results in the provided results cache. |
(Map<KOut, VOut>) executeHelper(String)
|
|
String getIntermediateCacheName()
|
|
void setMaxCollectorSize(int)
|
Limits Mapper's Collector size to a given value. |
(MapReduceTask<KIn, VIn, KOut, VOut>) usingIntermediateCache(String)
|
Allows this MapReduceTask to use specific intermediate custom defined cache for storage of
intermediate > key/values pairs. |
(MapReduceTask<KIn, VIn, KOut, VOut>) usingSharedIntermediateCache(String)
|
Allows this MapReduceTask to use a specific shared intermediate cache for storage of
intermediate > key/values pairs. |
(MapReduceTask<KIn, VIn, KOut, VOut>) usingSharedIntermediateCache(String, String)
|
Allows this MapReduceTask to use a specific shared intermediate cache for storage of
intermediate > key/values pairs. |
| Changed Methods |
void executeMapPhaseWithLocalReduction(Map<KOut, VOut>)
|
Change in return type from (Map<KOut, VOut>) to void.
Change in signature from void to (Map<KOut, VOut>).
|
|
Map<KOut, VOut> executeReducePhase(String, Set<KOut>, boolean)
|
Change in signature from (Set<KOut>, boolean) to (String, Set<KOut>, boolean).
|
|
void executeTaskInit(String)
|
Change in exceptions thrown from no exceptions to java.lang.Exception.
|
|
Map<KOut, VOut> execute()
|
Change in exceptions thrown from CacheException to org.infinispan.commons.CacheException.
|
Executes this task across Infinispan cluster nodes. |