|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use MapReduceTask | |
---|---|
org.infinispan.distexec.mapreduce |
Uses of MapReduceTask in org.infinispan.distexec.mapreduce |
---|
Methods in org.infinispan.distexec.mapreduce that return MapReduceTask | |
---|---|
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)
See timeout(TimeUnit) . |
|
--> |