Methods in org.infinispan.distexec.mapreduce that return 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 |