org.infinispan.distexec.mapreduce.spi

Interface MapReduceTaskLifecycle

All Known Implementing Classes:

CDIMapReduceTaskLifecycle, DefaultMapReduceTaskLifecycle, MapReduceInitializer

public interface MapReduceTaskLifecycle

Method Summary

Methods

Modifier and Type	Method and Description
<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)

Method Detail

onPreExecute

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

onPostExecute

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

onPreExecute

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

onPostExecute

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