Infinispan Distribution 5.2.6.Final-redhat-2

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

Packages that use Reducer
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.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
<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
<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.
<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)
           
<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.
<KOut,VOut>
ReduceCommand<KOut,VOut>
CommandsFactoryImpl.buildReduceCommand(String taskId, String destintationCache, Reducer<KOut,VOut> r, Collection<KOut> keys)
           
 

Uses of Reducer in org.infinispan.commands.read
 

Methods in org.infinispan.commands.read that return Reducer
 Reducer<KOut,VOut> MapCombineCommand.getCombiner()
           
 Reducer<KOut,VOut> ReduceCommand.getReducer()
           
 

Constructors in org.infinispan.commands.read with parameters of type Reducer
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.distexec.mapreduce
 

Fields in org.infinispan.distexec.mapreduce declared as Reducer
protected  Reducer<KOut,VOut> MapReduceTask.combiner
           
protected  Reducer<KOut,VOut> MapReduceTask.reducer
           
 

Methods in org.infinispan.distexec.mapreduce that return Reducer
protected  Reducer<KOut,VOut> MapReduceTask.clone(Reducer<KOut,VOut> reducer)
           
 

Methods in org.infinispan.distexec.mapreduce with parameters of type Reducer
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
<KOut,VOut>
void
MapReduceTaskLifecycleService.onPostExecute(Reducer<KOut,VOut> reducer)
           
<KOut,VOut>
void
DefaultMapReduceTaskLifecycle.onPostExecute(Reducer<KOut,VOut> reducer)
           
<KOut,VOut>
void
MapReduceTaskLifecycle.onPostExecute(Reducer<KOut,VOut> reducer)
           
<KOut,VOut>
void
MapReduceTaskLifecycleService.onPreExecute(Reducer<KOut,VOut> reducer, Cache<?,?> inputCache)
           
<KOut,VOut>
void
DefaultMapReduceTaskLifecycle.onPreExecute(Reducer<KOut,VOut> reducer, Cache<?,?> inputCache)
           
<KOut,VOut>
void
MapReduceTaskLifecycle.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
 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
<KOut,VOut>
void
MapReduceInitializer.onPostExecute(Reducer<KOut,VOut> reducer)
           
<KOut,VOut>
void
MapReduceInitializer.onPreExecute(Reducer<KOut,VOut> reducer, Cache<?,?> inputCache)
           
 


Infinispan Distribution 5.2.6.Final-redhat-2

Copyright © 2013 JBoss, a division of Red Hat. All Rights Reserved.