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.distexec.mapreduce |
Map/Reduce APIs
|
org.infinispan.distexec.mapreduce.spi |
Modifier and Type | Method and Description |
---|---|
<KOut,VOut> |
DelegatingMapReduceTaskLifecycle.onPostExecute(Reducer<KOut,VOut> reducer) |
<KOut,VOut> |
DelegatingMapReduceTaskLifecycle.onPreExecute(Reducer<KOut,VOut> reducer,
Cache<?,?> cache) |
Modifier and Type | Method and Description |
---|---|
<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> |
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> |
CommandsFactoryImpl.buildReduceCommand(String taskId,
String destintationCache,
Reducer<KOut,VOut> r,
Collection<KOut> keys) |
<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.
|
Modifier and Type | Method and Description |
---|---|
Reducer<KOut,VOut> |
MapCombineCommand.getCombiner() |
Reducer<KOut,VOut> |
ReduceCommand.getReducer() |
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) |
Modifier and Type | Field and Description |
---|---|
protected Reducer<KOut,VOut> |
MapReduceTask.combiner
Deprecated.
|
protected Reducer<KOut,VOut> |
MapReduceTask.reducer
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
protected Reducer<KOut,VOut> |
MapReduceTask.clone(Reducer<KOut,VOut> reducer)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
protected Reducer<KOut,VOut> |
MapReduceTask.clone(Reducer<KOut,VOut> reducer)
Deprecated.
|
MapReduceTask<KIn,VIn,KOut,VOut> |
MapReduceTask.combinedWith(Reducer<KOut,VOut> combiner)
Deprecated.
Specifies Combiner to use for this MapReduceTask
|
MapReduceTask<KIn,VIn,KOut,VOut> |
MapReduceTask.reducedWith(Reducer<KOut,VOut> reducer)
Deprecated.
Specifies Reducer to use for this MapReduceTask
|
Modifier and Type | Method and Description |
---|---|
<KOut,VOut> |
DefaultMapReduceTaskLifecycle.onPostExecute(Reducer<KOut,VOut> reducer) |
<KOut,VOut> |
MapReduceTaskLifecycle.onPostExecute(Reducer<KOut,VOut> reducer) |
<KOut,VOut> |
MapReduceTaskLifecycleService.onPostExecute(Reducer<KOut,VOut> reducer) |
<KOut,VOut> |
DefaultMapReduceTaskLifecycle.onPreExecute(Reducer<KOut,VOut> reducer,
Cache<?,?> inputCache) |
<KOut,VOut> |
MapReduceTaskLifecycle.onPreExecute(Reducer<KOut,VOut> reducer,
Cache<?,?> inputCache) |
<KOut,VOut> |
MapReduceTaskLifecycleService.onPreExecute(Reducer<KOut,VOut> reducer,
Cache<?,?> inputCache) |
Copyright © 2024 JBoss, a division of Red Hat. All rights reserved.