Uses of Interface
org.infinispan.distexec.mapreduce.Reducer

Packages that use Reducer

Package	Description
org.infinispan.cdi	This is the Infinispan CDI module.
org.infinispan.commands	Commands that operate on the cache, either locally or remotely.
org.infinispan.commands.read
org.infinispan.demo.mapreduce
org.infinispan.distexec.mapreduce
org.infinispan.distexec.mapreduce.spi
org.infinispan.query.impl.massindex

Uses of Reducer in org.infinispan.cdi

Methods in org.infinispan.cdi with parameters of type Reducer

Modifier and Type	Method and Description
<KOut,VOut> void	CDIMapReduceTaskLifecycle.onPostExecute(Reducer<KOut,VOut> reducer)
<KOut,VOut> void	CDIMapReduceTaskLifecycle.onPreExecute(Reducer<KOut,VOut> reducer, Cache<?,?> cache)

Uses of Reducer in org.infinispan.commands

Methods in org.infinispan.commands with parameters of type Reducer

Modifier and Type	Method and Description
<KIn,VIn,KOut,VOut> MapCombineCommand<KIn,VIn,KOut,VOut>	CommandsFactoryImpl.buildMapCombineCommand(String taskId, Mapper<KIn,VIn,KOut,VOut> m, Reducer<KOut,VOut> r, Collection<KIn> keys)
<KIn,VIn,KOut,VOut> MapCombineCommand<KIn,VIn,KOut,VOut>	CommandsFactory.buildMapCombineCommand(String taskId, Mapper<KIn,VIn,KOut,VOut> m, Reducer<KOut,VOut> r, Collection<KIn> keys) Builds a MapCombineCommand used for migration and map phase execution of MapReduce tasks.
<KOut,VOut> ReduceCommand<KOut,VOut>	CommandsFactoryImpl.buildReduceCommand(String taskId, String destintationCache, Reducer<KOut,VOut> r, Collection<KOut> keys)
<KOut,VOut> ReduceCommand<KOut,VOut>	CommandsFactory.buildReduceCommand(String taskId, String destinationCache, Reducer<KOut,VOut> r, Collection<KOut> keys) Builds a ReduceCommand used for migration and reduce phase execution of MapReduce tasks.

Uses of Reducer in org.infinispan.commands.read

Methods in org.infinispan.commands.read that return Reducer

Modifier and Type	Method and Description
Reducer<KOut,VOut>	MapCombineCommand.getCombiner()
Reducer<KOut,VOut>	ReduceCommand.getReducer()

Constructors in org.infinispan.commands.read with parameters of type Reducer

Constructor and Description
MapCombineCommand(String taskId, Mapper<KIn,VIn,KOut,VOut> mapper, Reducer<KOut,VOut> combiner, String cacheName, Collection<KIn> inputKeys)
ReduceCommand(String taskId, Reducer<KOut,VOut> reducer, String cacheName, Collection<KOut> inputKeys)

Uses of Reducer in org.infinispan.demo.mapreduce

Classes in org.infinispan.demo.mapreduce that implement Reducer

Modifier and Type	Class and Description
class	WordCountReducer

Uses of Reducer in org.infinispan.distexec.mapreduce

Fields in org.infinispan.distexec.mapreduce declared as Reducer

Modifier and Type	Field and Description
protected Reducer<KOut,VOut>	MapReduceTask.combiner
protected Reducer<KOut,VOut>	MapReduceTask.reducer

Methods in org.infinispan.distexec.mapreduce that return Reducer

Modifier and Type	Method and Description
protected Reducer<KOut,VOut>	MapReduceTask.clone(Reducer<KOut,VOut> reducer)

Methods in org.infinispan.distexec.mapreduce with parameters of type Reducer

Modifier and Type	Method and Description
protected Reducer<KOut,VOut>	MapReduceTask.clone(Reducer<KOut,VOut> reducer)
MapReduceTask<KIn,VIn,KOut,VOut>	MapReduceTask.combinedWith(Reducer<KOut,VOut> combiner) Specifies Combiner to use for this MapReduceTask
MapReduceTask<KIn,VIn,KOut,VOut>	MapReduceTask.reducedWith(Reducer<KOut,VOut> reducer) Specifies Reducer to use for this MapReduceTask

Uses of Reducer in org.infinispan.distexec.mapreduce.spi

Methods in org.infinispan.distexec.mapreduce.spi with parameters of type Reducer

Modifier and Type	Method and Description
<KOut,VOut> void	MapReduceTaskLifecycleService.onPostExecute(Reducer<KOut,VOut> reducer)
<KOut,VOut> void	MapReduceTaskLifecycle.onPostExecute(Reducer<KOut,VOut> reducer)
<KOut,VOut> void	DefaultMapReduceTaskLifecycle.onPostExecute(Reducer<KOut,VOut> reducer)
<KOut,VOut> void	MapReduceTaskLifecycleService.onPreExecute(Reducer<KOut,VOut> reducer, Cache<?,?> inputCache)
<KOut,VOut> void	MapReduceTaskLifecycle.onPreExecute(Reducer<KOut,VOut> reducer, Cache<?,?> inputCache)
<KOut,VOut> void	DefaultMapReduceTaskLifecycle.onPreExecute(Reducer<KOut,VOut> reducer, Cache<?,?> inputCache)

Uses of Reducer in org.infinispan.query.impl.massindex

Classes in org.infinispan.query.impl.massindex that implement Reducer

Modifier and Type	Class and Description
class	IndexingReducer This Reduce doesn't really index the entries but forwards them to the appropriate index master; the backend knows how to deal with sharding and this way we avoid unnecessary round trips.

Methods in org.infinispan.query.impl.massindex with parameters of type Reducer

Modifier and Type	Method and Description
<KOut,VOut> void	MapReduceInitializer.onPostExecute(Reducer<KOut,VOut> reducer)
<KOut,VOut> void	MapReduceInitializer.onPreExecute(Reducer<KOut,VOut> reducer, Cache<?,?> inputCache)