com.bigdata.service.mapred
Class ReduceService

java.lang.Object
  com.bigdata.service.mapred.AbstractJobAndTaskService<ReduceJobMetadata,AbstractReduceTask>
      com.bigdata.service.mapred.ReduceService

All Implemented Interfaces:

IServiceShutdown, IJobAndTaskService<ReduceJobMetadata,AbstractReduceTask>, IReduceService, Remote

Direct Known Subclasses:

ReduceServer.AdministrableReduceService, ReduceService.EmbeddedReduceService

public abstract class ReduceService
extends AbstractJobAndTaskService<ReduceJobMetadata,AbstractReduceTask>
implements IServiceShutdown, IReduceService

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

Version:

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

Author:

Bryan Thompson

Nested Class Summary

protected static class	ReduceService.EmbeddedReduceService A local (in process) ReduceService.
static class	ReduceService.Options Options for the ReduceService.
protected static class	ReduceService.ReduceTaskWorker A worker for a reduce task.

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

ReduceService(Properties properties)

Method Summary

protected AbstractJobAndTaskService.AbstractTaskWorker<ReduceJobMetadata,AbstractReduceTask>

newTaskWorker(JobState<ReduceJobMetadata> jobState, AbstractReduceTask task) Returns instances of ReduceService.ReduceTaskWorker.

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.IServiceShutdown

isOpen, shutdown, shutdownNow

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

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

Field Detail

log

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

Constructor Detail

ReduceService

public ReduceService(Properties properties)

Parameters:

properties - See ReduceService.Options.

Method Detail

newTaskWorker

protected AbstractJobAndTaskService.AbstractTaskWorker<ReduceJobMetadata,AbstractReduceTask> newTaskWorker(JobState<ReduceJobMetadata> jobState,
                                                                                                           AbstractReduceTask task)

Returns instances of ReduceService.ReduceTaskWorker.

Specified by:

newTaskWorker in class AbstractJobAndTaskService<ReduceJobMetadata,AbstractReduceTask>

Parameters:

jobState - The job state maintained by this service.

task - The task to be executed.

Returns:

The worker that will execute a given task.