com.bigdata.service.jini.master
Class ResourceBufferTask.M<E extends Serializable>

java.lang.Object
  com.bigdata.util.concurrent.AbstractHaltableProcess
      com.bigdata.service.ndx.pipeline.AbstractMasterTask<H,E,S,L>
          com.bigdata.service.ndx.pipeline.AbstractPendingSetMasterTask<H,E,S,L>
              com.bigdata.service.jini.master.ResourceBufferTask<ResourceBufferStatistics<ClientLocator,ResourceBufferSubtaskStatistics>,E,ResourceBufferSubtask,ClientLocator,ResourceBufferSubtaskStatistics>
                  com.bigdata.service.jini.master.ResourceBufferTask.M<E>

All Implemented Interfaces:

INotifyOutcome<E,ClientLocator>, IMasterTask<E,ResourceBufferStatistics<ClientLocator,ResourceBufferSubtaskStatistics>>, Remote, Callable<ResourceBufferStatistics<ClientLocator,ResourceBufferSubtaskStatistics>>

Enclosing class:

ResourceBufferTask<H extends ResourceBufferStatistics<L,HS>,E extends Serializable,S extends ResourceBufferSubtask,L extends ClientLocator,HS extends ResourceBufferSubtaskStatistics>

public static class ResourceBufferTask.M<E extends Serializable>
extends ResourceBufferTask<ResourceBufferStatistics<ClientLocator,ResourceBufferSubtaskStatistics>,E,ResourceBufferSubtask,ClientLocator,ResourceBufferSubtaskStatistics>

Concrete master hides most of the generic types leaving you with only those that are meaningful to parameterize.

Version:

$Id$

Author:

Bryan Thompson

Nested Class Summary

Nested classes/interfaces inherited from class com.bigdata.service.jini.master.ResourceBufferTask

ResourceBufferTask.M<E extends Serializable>

Field Summary

Fields inherited from class com.bigdata.service.jini.master.ResourceBufferTask

sinkChunkSize, sinkChunkTimeoutNanos, sinkQueueCapacity, taskMaster

Fields inherited from class com.bigdata.service.ndx.pipeline.AbstractPendingSetMasterTask

log, masterProxy

Fields inherited from class com.bigdata.service.ndx.pipeline.AbstractMasterTask

buffer, sinkIdleTimeoutNanos, sinkPollTimeoutNanos, src, stats

Constructor Summary

ResourceBufferTask.M(MappedTaskMaster taskMaster, long sinkIdleTimeoutNanos, long sinkPollTimeoutNanos, int sinkQueueCapacity, int sinkChunkSize, long sinkChunkTimeoutNanos, ResourceBufferStatistics<ClientLocator,ResourceBufferSubtaskStatistics> stats, BlockingBuffer<E[]> buffer)

Method Summary

Methods inherited from class com.bigdata.service.jini.master.ResourceBufferTask

getPendingMap, handleChunk, newPendingMap, newSubtask, newSubtaskBuffer, submitSubtask, toString, willShutdown

Methods inherited from class com.bigdata.service.ndx.pipeline.AbstractPendingSetMasterTask

addPending, didFail, didSucceed, error, getFederation, getPendingSetSize, nothingPending, removePending, success

Methods inherited from class com.bigdata.service.ndx.pipeline.AbstractMasterTask

addToOutputBuffer, call, getBuffer, getRedirectQueueSize, getSink, getStats, mapOperationOverSubtasks, moveSinkToFinishedQueueAtomically, notifySubtaskDone, redirectChunk

Methods inherited from class com.bigdata.util.concurrent.AbstractHaltableProcess

halt, halted

Methods inherited from class java.lang.Object

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

Constructor Detail

ResourceBufferTask.M

public ResourceBufferTask.M(MappedTaskMaster taskMaster,
                            long sinkIdleTimeoutNanos,
                            long sinkPollTimeoutNanos,
                            int sinkQueueCapacity,
                            int sinkChunkSize,
                            long sinkChunkTimeoutNanos,
                            ResourceBufferStatistics<ClientLocator,ResourceBufferSubtaskStatistics> stats,
                            BlockingBuffer<E[]> buffer)