Infinispan Distribution 5.2.6.Final-redhat-2

org.infinispan.query.impl.massindex
Class MapReduceInitializer

java.lang.Object
  extended by org.infinispan.query.impl.massindex.MapReduceInitializer
All Implemented Interfaces:
MapReduceTaskLifecycle

public class MapReduceInitializer
extends Object
implements MapReduceTaskLifecycle

Initializes the custom Map Reduce tasks we use to rebuild indexes

Author:
Sanne Grinovero (C) 2012 Red Hat Inc.

Constructor Summary
MapReduceInitializer()
           
 
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

MapReduceInitializer

public MapReduceInitializer()
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

Infinispan Distribution 5.2.6.Final-redhat-2

Copyright © 2013 JBoss, a division of Red Hat. All Rights Reserved.