com.bigdata.service.mapred.jini
Class Master.MapReduceServiceDiscoveryManager

java.lang.Object
  com.bigdata.service.mapred.jini.Master.MapReduceServiceDiscoveryManager

Enclosing class:

Master

public static class Master.MapReduceServiceDiscoveryManager
extends Object

Manages discovery of map/reduce services. An instance of this class can be reused to run multiple map/reduce jobs.

Version:

$Id$

Author:

Bryan Thompson

Constructor Summary

Master.MapReduceServiceDiscoveryManager(JiniClient client)

Method Summary

IMapService[]	getMapServices() Return an array of all discovered map services.
IReduceService[]	getReduceServices() Return an array of all discovered reduce services.
void	terminate() End discovery, discard caches.

Methods inherited from class java.lang.Object

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

Constructor Detail

Master.MapReduceServiceDiscoveryManager

public Master.MapReduceServiceDiscoveryManager(JiniClient client)

TODO:

refactor discovery and lookup per DataServicesClient and LoadBalancerClient.

Method Detail

terminate

public void terminate()

End discovery, discard caches.

getMapServices

public IMapService[] getMapServices()

Return an array of all discovered map services.

getReduceServices

public IReduceService[] getReduceServices()

Return an array of all discovered reduce services.