Package com.bigdata.service.mapred

This package contains the map/reduce service, including the master and clients.

See:
Description

Interface Summary

IHashFunction	Interface for a hash function to be applied to the keys generated by an IMapTask.
IJobAndTaskService<M extends IJobMetadata,T extends ITask>	A interface for a service using a job and task model.
IJobMetadata	Interface for job metadata provided to an IJobAndTaskService.
IMapReduceJob	Interface for a map/reduce job.
IMapService	Interface for a map service.
IMapSource	Interface responsible for identifying input sources for map tasks.
IMapTask	Interface for a map task to be executed on a map/reduce client.
IReduceService	Interface for a reduce service.
IReduceTask	Interface for a reduce task to be executed on a map/reduce client.
ITask	A task to be run by an IJobAndTaskService.

Class Summary

AbstractFileInputMapTask	Abstract base class for IMapTasks accepting a filename as the "key" and the file contents as the "value".
AbstractJobAndTaskService<M extends IJobMetadata,T extends ITask>	Abstract base class for services implementing IJobAndTaskService.
AbstractJobAndTaskService.AbstractTaskWorker<M,T extends ITask>	Abstract base class for task workers running in the MapService or the ReduceService.
AbstractJobAndTaskService.Options	Options for AbstractJobAndTaskService.AbstractJobAndTaskService(Properties)
AbstractMapTask	Abstract base class for IMapTasks.
AbstractMaster	Abstract base class implementing the master for running map/reduce jobs.
AbstractReduceTask	Abstract base class for reduce tasks.
DefaultHashFunction	This is default implementation of IHashFunction - it is based on Arrays.hashCode(byte[]).
EmbeddedMaster	A master running with embedded map and reduce services that may be used for testing either the master and services or the execution of a specific job.
FileSystemMapSource	Processes files in a named directory of a (network) file system.
JobState<M>	Job state that is relevant to this service.
MapJobMetadata	Metadata for the map operation of a map/reduce job.
MapReduceJob	A map reduce job.
MapService	A service for IMapTask processing.
MapService.EmbeddedMapService	A local (in process) MapService.
MapService.Options	Options for the MapService.
Outcome	Outcome for a task.
ReduceJobMetadata	Metadata for the reduce operation of a map/reduce job.
ReduceService	A service for IReduceTask processing.
ReduceService.EmbeddedReduceService	A local (in process) ReduceService.
ReduceService.Options	Options for the ReduceService.
ReduceService.ReduceTaskWorker	A worker for a reduce task.
RemoteTaskRunner<M extends IJobMetadata,T extends ITask>	Abstract base class for running the tasks of a specific job against a set of IJobAndTaskServices.
RemoteTaskRunner.RetryTask<T extends ITask>	Wraps up an ITask and a retry counter.

Enum Summary

Status

The status associated with a completed task.

Package com.bigdata.service.mapred Description

This package contains the map/reduce service, including the master and clients.