public final class MapReduceTaskLifecycleService
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
private java.util.List<MapReduceTaskLifecycle> |
lifecycles |
private static org.infinispan.util.logging.Log |
log |
private static MapReduceTaskLifecycleService |
service |
Modifier | Constructor and Description |
---|---|
private |
MapReduceTaskLifecycleService() |
Modifier and Type | Method and Description |
---|---|
static MapReduceTaskLifecycleService |
getInstance() |
<KIn,VIn,KOut,VOut> |
onPostExecute(Mapper<KIn,VIn,KOut,VOut> mapper) |
<KOut,VOut> |
onPostExecute(Reducer<KOut,VOut> reducer) |
<KIn,VIn,KOut,VOut> |
onPreExecute(Mapper<KIn,VIn,KOut,VOut> mapper,
Cache<KIn,VIn> inputCache) |
<KOut,VOut> |
onPreExecute(Reducer<KOut,VOut> reducer,
Cache<?,?> inputCache) |
private static final org.infinispan.util.logging.Log log
private static MapReduceTaskLifecycleService service
private java.util.List<MapReduceTaskLifecycle> lifecycles
public static MapReduceTaskLifecycleService getInstance()
public <KIn,VIn,KOut,VOut> void onPreExecute(Mapper<KIn,VIn,KOut,VOut> mapper, Cache<KIn,VIn> inputCache)
public <KIn,VIn,KOut,VOut> void onPostExecute(Mapper<KIn,VIn,KOut,VOut> mapper)
public <KOut,VOut> void onPreExecute(Reducer<KOut,VOut> reducer, Cache<?,?> inputCache)
public <KOut,VOut> void onPostExecute(Reducer<KOut,VOut> reducer)