org.infinispan.distexec.mapreduce.spi
Class DefaultMapReduceTaskLifecycle

java.lang.Object
  org.infinispan.distexec.mapreduce.spi.DefaultMapReduceTaskLifecycle

All Implemented Interfaces:

MapReduceTaskLifecycle

public class DefaultMapReduceTaskLifecycle
extends Object
implements MapReduceTaskLifecycle

Constructor Summary

DefaultMapReduceTaskLifecycle()

Method Summary

<KIn,VIn,KOut,VOut> void	onPostExecute(Mapper<KIn,VIn,KOut,VOut> mapper)
<KOut,VOut> void	onPostExecute(Reducer<KOut,VOut> reducer)
<KIn,VIn,KOut,VOut> void	onPreExecute(Mapper<KIn,VIn,KOut,VOut> mapper, Cache<KIn,VIn> inputCache)
<KOut,VOut> void	onPreExecute(Reducer<KOut,VOut> reducer, Cache<?,?> inputCache)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DefaultMapReduceTaskLifecycle

public DefaultMapReduceTaskLifecycle()

Method Detail

onPreExecute

public <KIn,VIn,KOut,VOut> void onPreExecute(Mapper<KIn,VIn,KOut,VOut> mapper,
                                             Cache<KIn,VIn> inputCache)

Specified by:

onPreExecute in interface MapReduceTaskLifecycle

onPostExecute

public <KIn,VIn,KOut,VOut> void onPostExecute(Mapper<KIn,VIn,KOut,VOut> mapper)

Specified by:

onPostExecute in interface MapReduceTaskLifecycle

onPreExecute

public <KOut,VOut> void onPreExecute(Reducer<KOut,VOut> reducer,
                                     Cache<?,?> inputCache)

Specified by:

onPreExecute in interface MapReduceTaskLifecycle

onPostExecute

public <KOut,VOut> void onPostExecute(Reducer<KOut,VOut> reducer)

Specified by:

onPostExecute in interface MapReduceTaskLifecycle