Package com.bigdata.service.jini.master

Interface Summary

IAsynchronousClientTask<U,V>	Interface for remote Callables which process chunks of resources as assigned by the MappedTaskMaster.
IHashFunction<V>	A hash function.
INotifyOutcome<V,L>	Interface used by client tasks to notify the master about the outcome of each resource tasked to that client.
IResourceScannerFactory<V>	Factory for AbstractResourceScanner implementations.
MappedTaskMaster.ConfigurationOptions	Configuration options for the MappedTaskMaster.
TaskMaster.ConfigurationOptions	Configuration options for the TaskMaster and derived classes.

Class Summary

AbstractAsynchronousClientTask<U,V,L>	Abstract base class for IAsynchronousClientTask.
AbstractClientTask<S extends TaskMaster.JobState,U,V extends Serializable>	An abstract base class which may be used for client tasks run by the master on one or more data services.
AbstractResourceScanner<V>	Abstract base class for the scanner for a mapped master job.
AggregatorTask<T extends IKeyArrayIndexProcedure,O,R,A>	A task which aggregates writes destined for a specific scale-out index.
ClientLocator	A locator for a client task.
DefaultHashFunction<V>	Uses Object.hashCode().
DiscoverServices	Class discovers and returns services matching a ServicesTemplate.
FileSystemScanner	Adds all files accepted by the filter to the Queue.
MappedTaskMaster<S extends MappedTaskMaster.JobState,T extends AbstractAsynchronousClientTask<U,V,L>,L extends ClientLocator,U,V extends Serializable>	Extends the TaskMaster to assign chunks of resources for processing to the client tasks.
MappedTaskMaster.JobState	The job description for an MappedTaskMaster.
ResourceBufferStatistics<L,HS extends ResourceBufferSubtaskStatistics>	Statistics for passing resources to be processed to the distributed clients.
ResourceBufferSubtask<H extends ResourceBufferStatistics<L,HS>,O,E extends Serializable,L extends ClientLocator,S extends ResourceBufferSubtask,HS extends ResourceBufferSubtaskStatistics,M extends ResourceBufferTask<H,E,S,L,HS>,T extends IKeyArrayIndexProcedure,A>
ResourceBufferSubtaskStatistics	Statistics reported for each client.
ResourceBufferTask<H extends ResourceBufferStatistics<L,HS>,E extends Serializable,S extends ResourceBufferSubtask,L extends ClientLocator,HS extends ResourceBufferSubtaskStatistics>	Task drains a BlockingBuffer containing resources (really, resource identifiers) to be processed by the clients and uses hash partitioning to assign the resources to client tasks for processing.
ResourceBufferTask.M<E extends Serializable>	Concrete master hides most of the generic types leaving you with only those that are meaningful to parameterize.
ServiceMap	An ordered mapping of indices in [0:N-1] onto the services on which the task with the corresponding index will be executed.
ServicesTemplate	A template for matching some number and type of services.
TaskMaster<S extends TaskMaster.JobState,T extends Callable<U>,U>	Utility class that can be used to execute a distributed job.
TaskMaster.DiscoveredServices	Class used to return the discovered services.
TaskMaster.JobState	State describing the job to be executed.