com.bigdata.service.mapred
Class MapService

java.lang.Object
  com.bigdata.service.mapred.AbstractJobAndTaskService<MapJobMetadata,AbstractMapTask>
      com.bigdata.service.mapred.MapService

All Implemented Interfaces:

IServiceShutdown, IJobAndTaskService<MapJobMetadata,AbstractMapTask>, IMapService, Remote

Direct Known Subclasses:

MapServer.AdministrableMapService, MapService.EmbeddedMapService

public abstract class MapService
extends AbstractJobAndTaskService<MapJobMetadata,AbstractMapTask>
implements IMapService, IServiceShutdown

A service for IMapTask processing. Those tasks are distributed by the Master.

Version:

$Id: MapService.java 2265 2009-10-26 12:51:06Z thompsonbry $

Author:

Bryan Thompson

Nested Class Summary

protected static class	MapService.EmbeddedMapService A local (in process) MapService.
static class	MapService.Options Options for the MapService.

Nested classes/interfaces inherited from class com.bigdata.service.mapred.AbstractJobAndTaskService

AbstractJobAndTaskService.AbstractTaskWorker<M,T extends ITask>

Field Summary

static org.apache.log4j.Logger

log

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

cancelService, ERR_JOB_EXISTS, ERR_NO_JOB_IDENTIFIER, ERR_NO_SUCH_JOB, heartbeatMonitor, heartbeatPeriod, heartbeatTimeout, jobs, taskService, threadPoolSize, timeoutService

Constructor Summary

MapService(Properties properties)

Method Summary

protected AbstractJobAndTaskService.AbstractTaskWorker<MapJobMetadata,AbstractMapTask>

newTaskWorker(JobState<MapJobMetadata> jobState, AbstractMapTask task) Returns instances of MapTaskWorker.

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

cancel, cancelJob, destroy, drain, getBigdataClient, heartbeat, isOpen, newJobState, shutdown, shutdownNow, startJob, submit

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.bigdata.service.mapred.IJobAndTaskService

cancel, cancelJob, drain, getServiceUUID, heartbeat, startJob, submit

Methods inherited from interface com.bigdata.service.IServiceShutdown

isOpen, shutdown, shutdownNow

Field Detail

log

public static final transient org.apache.log4j.Logger log

Constructor Detail

MapService

public MapService(Properties properties)

Parameters:

properties - See MapService.Options.

Method Detail

newTaskWorker

protected AbstractJobAndTaskService.AbstractTaskWorker<MapJobMetadata,AbstractMapTask> newTaskWorker(JobState<MapJobMetadata> jobState,
                                                                                                     AbstractMapTask task)

Returns instances of MapTaskWorker.

Specified by:

newTaskWorker in class AbstractJobAndTaskService<MapJobMetadata,AbstractMapTask>

Parameters:

jobState - The job state maintained by this service.

task - The task to be executed.

Returns:

The worker that will execute a given task.