public class DelegatingMapReduceTaskLifecycle extends Object implements org.infinispan.distexec.mapreduce.spi.MapReduceTaskLifecycle
Constructor and Description |
---|
DelegatingMapReduceTaskLifecycle() |
Modifier and Type | Method and Description |
---|---|
<KIn,VIn,KOut,VOut> |
onPostExecute(org.infinispan.distexec.mapreduce.Mapper<KIn,VIn,KOut,VOut> mapper) |
<KOut,VOut> |
onPostExecute(org.infinispan.distexec.mapreduce.Reducer<KOut,VOut> reducer) |
<KIn,VIn,KOut,VOut> |
onPreExecute(org.infinispan.distexec.mapreduce.Mapper<KIn,VIn,KOut,VOut> mapper,
org.infinispan.Cache<KIn,VIn> inputCache) |
<KOut,VOut> |
onPreExecute(org.infinispan.distexec.mapreduce.Reducer<KOut,VOut> reducer,
org.infinispan.Cache<?,?> cache) |
public <KIn,VIn,KOut,VOut> void onPreExecute(org.infinispan.distexec.mapreduce.Mapper<KIn,VIn,KOut,VOut> mapper, org.infinispan.Cache<KIn,VIn> inputCache)
onPreExecute
in interface org.infinispan.distexec.mapreduce.spi.MapReduceTaskLifecycle
public <KIn,VIn,KOut,VOut> void onPostExecute(org.infinispan.distexec.mapreduce.Mapper<KIn,VIn,KOut,VOut> mapper)
onPostExecute
in interface org.infinispan.distexec.mapreduce.spi.MapReduceTaskLifecycle
public <KOut,VOut> void onPreExecute(org.infinispan.distexec.mapreduce.Reducer<KOut,VOut> reducer, org.infinispan.Cache<?,?> cache)
onPreExecute
in interface org.infinispan.distexec.mapreduce.spi.MapReduceTaskLifecycle
public <KOut,VOut> void onPostExecute(org.infinispan.distexec.mapreduce.Reducer<KOut,VOut> reducer)
onPostExecute
in interface org.infinispan.distexec.mapreduce.spi.MapReduceTaskLifecycle
Copyright © 2017 JBoss, a division of Red Hat. All rights reserved.