|
Infinispan Distribution 5.2.6.Final-redhat-2 | |||||||||
PREV NEXT | FRAMES NO FRAMES |
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 | ||
---|---|---|
|
CDIMapReduceTaskLifecycle.onPostExecute(Reducer<KOut,VOut> reducer)
|
|
|
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 | ||
---|---|---|
|
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. |
|
|
CommandsFactoryImpl.buildMapCombineCommand(String taskId,
Mapper<KIn,VIn,KOut,VOut> m,
Reducer<KOut,VOut> r,
Collection<KIn> keys)
|
|
|
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. |
|
|
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 | ||
---|---|---|
|
MapReduceTaskLifecycleService.onPostExecute(Reducer<KOut,VOut> reducer)
|
|
|
DefaultMapReduceTaskLifecycle.onPostExecute(Reducer<KOut,VOut> reducer)
|
|
|
MapReduceTaskLifecycle.onPostExecute(Reducer<KOut,VOut> reducer)
|
|
|
MapReduceTaskLifecycleService.onPreExecute(Reducer<KOut,VOut> reducer,
Cache<?,?> inputCache)
|
|
|
DefaultMapReduceTaskLifecycle.onPreExecute(Reducer<KOut,VOut> reducer,
Cache<?,?> inputCache)
|
|
|
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 | ||
---|---|---|
|
MapReduceInitializer.onPostExecute(Reducer<KOut,VOut> reducer)
|
|
|
MapReduceInitializer.onPreExecute(Reducer<KOut,VOut> reducer,
Cache<?,?> inputCache)
|
|
Infinispan Distribution 5.2.6.Final-redhat-2 | |||||||||
PREV NEXT | FRAMES NO FRAMES |