Package | Description |
---|---|
org.infinispan.distexec.mapreduce |
Map/Reduce APIs
|
Modifier and Type | Method and Description |
---|---|
MapReduceTask<KIn,VIn,KOut,VOut> |
MapReduceTask.combinedWith(Reducer<KOut,VOut> combiner)
Specifies Combiner to use for this MapReduceTask
|
MapReduceTask<KIn,VIn,KOut,VOut> |
MapReduceTask.mappedWith(Mapper<KIn,VIn,KOut,VOut> mapper)
Specifies Mapper to use for this MapReduceTask
|
MapReduceTask<KIn,VIn,KOut,VOut> |
MapReduceTask.onKeys(KIn... input)
Rather than use all available keys as input
onKeys allows users to specify a
subset of keys as input to this task |
MapReduceTask<KIn,VIn,KOut,VOut> |
MapReduceTask.reducedWith(Reducer<KOut,VOut> reducer)
Specifies Reducer to use for this MapReduceTask
|
MapReduceTask<KIn,VIn,KOut,VOut> |
MapReduceTask.timeout(long timeout,
TimeUnit unit)
|
MapReduceTask<KIn,VIn,KOut,VOut> |
MapReduceTask.usingIntermediateCache(String cacheConfigurationName)
Allows this MapReduceTask to use specific intermediate custom defined cache for storage of
intermediate
|
MapReduceTask<KIn,VIn,KOut,VOut> |
MapReduceTask.usingSharedIntermediateCache(String cacheName)
Allows this MapReduceTask to use a specific shared intermediate cache for storage of
intermediate
|
MapReduceTask<KIn,VIn,KOut,VOut> |
MapReduceTask.usingSharedIntermediateCache(String cacheName,
String cacheConfigurationName)
Allows this MapReduceTask to use a specific shared intermediate cache for storage of
intermediate
|
Copyright © 2015 JBoss, a division of Red Hat. All rights reserved.