com.bigdata.service.mapred.jini
Class Master

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

public class Master
extends AbstractMaster

The master for running parallel map/reduce jobs distributed across a cluster.

TODO:

command line utility that can read an XML job description and run it. The utility should have a command line option to test against embedded map, reduce and data services and to limit the #of inputs to process (just one switch should be enough).

Nested Class Summary

static class

Master.MapReduceServiceDiscoveryManager Manages discovery of map/reduce services.

Field Summary

Fields inherited from class com.bigdata.service.mapred.AbstractMaster

log, mapServices, percent, reduceServices

Constructor Summary

Master(MapReduceJob job, JiniClient client, Master.MapReduceServiceDiscoveryManager serviceDiscoveryManager)

Method Summary

Methods inherited from class com.bigdata.service.mapred.AbstractMaster

getMapElapsedTime, getMapFailedCount, getMapPercentSuccess, getMapRetryCount, getMapSuccessCount, getMapTaskCount, getReduceElapsedTime, getReduceFailedCount, getReducePercentSuccess, getReduceRetryCount, getReduceSuccessCount, getReduceTaskCount, map, reduce, run, setUp, setUpDataStores, status, tearDown, terminate

Methods inherited from class java.lang.Object

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

Constructor Detail

Master

public Master(MapReduceJob job,
              JiniClient client,
              Master.MapReduceServiceDiscoveryManager serviceDiscoveryManager)