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

Packages that use Mapper

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 Mapper in org.infinispan.cdi

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

Modifier and Type	Method and Description
<KIn,VIn,KOut,VOut> void	CDIMapReduceTaskLifecycle.onPostExecute(Mapper<KIn,VIn,KOut,VOut> mapper)
<KIn,VIn,KOut,VOut> void	CDIMapReduceTaskLifecycle.onPreExecute(Mapper<KIn,VIn,KOut,VOut> mapper, Cache<KIn,VIn> inputCache)

Uses of Mapper in org.infinispan.commands

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

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.

Uses of Mapper in org.infinispan.commands.read

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

Modifier and Type	Method and Description
Mapper<KIn,VIn,KOut,VOut>	MapCombineCommand.getMapper()

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

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

Uses of Mapper in org.infinispan.demo.mapreduce

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

Modifier and Type	Class and Description
class	WordCountMapper
class	WordCountMapperEmitPerValue

Uses of Mapper in org.infinispan.distexec.mapreduce

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

Modifier and Type	Field and Description
protected Mapper<KIn,VIn,KOut,VOut>	MapReduceTask.mapper

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

Modifier and Type	Method and Description
protected Mapper<KIn,VIn,KOut,VOut>	MapReduceTask.clone(Mapper<KIn,VIn,KOut,VOut> mapper)

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

Modifier and Type	Method and Description
protected Mapper<KIn,VIn,KOut,VOut>	MapReduceTask.clone(Mapper<KIn,VIn,KOut,VOut> mapper)
MapReduceTask<KIn,VIn,KOut,VOut>	MapReduceTask.mappedWith(Mapper<KIn,VIn,KOut,VOut> mapper) Specifies Mapper to use for this MapReduceTask

Constructors in org.infinispan.distexec.mapreduce with parameters of type Mapper

Constructor and Description
MapReduceCacheLoaderTask(Mapper mapper, Collector collector)

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

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

Modifier and Type	Method and Description
<KIn,VIn,KOut,VOut> void	DefaultMapReduceTaskLifecycle.onPostExecute(Mapper<KIn,VIn,KOut,VOut> mapper)
<KIn,VIn,KOut,VOut> void	MapReduceTaskLifecycleService.onPostExecute(Mapper<KIn,VIn,KOut,VOut> mapper)
<KIn,VIn,KOut,VOut> void	MapReduceTaskLifecycle.onPostExecute(Mapper<KIn,VIn,KOut,VOut> mapper)
<KIn,VIn,KOut,VOut> void	DefaultMapReduceTaskLifecycle.onPreExecute(Mapper<KIn,VIn,KOut,VOut> mapper, Cache<KIn,VIn> inputCache)
<KIn,VIn,KOut,VOut> void	MapReduceTaskLifecycleService.onPreExecute(Mapper<KIn,VIn,KOut,VOut> mapper, Cache<KIn,VIn> inputCache)
<KIn,VIn,KOut,VOut> void	MapReduceTaskLifecycle.onPreExecute(Mapper<KIn,VIn,KOut,VOut> mapper, Cache<KIn,VIn> inputCache)

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

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

Modifier and Type	Class and Description
class	IndexingMapper

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

Modifier and Type	Method and Description
<KIn,VIn,KOut,VOut> void	MapReduceInitializer.onPostExecute(Mapper<KIn,VIn,KOut,VOut> mapper)
<KIn,VIn,KOut,VOut> void	MapReduceInitializer.onPreExecute(Mapper<KIn,VIn,KOut,VOut> mapper, Cache<KIn,VIn> inputCache)