com.bigdata.service.jini.master
Class 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>

java.lang.Object
  com.bigdata.service.ndx.pipeline.AbstractSubtask<HS,M,E,L>
      com.bigdata.service.ndx.pipeline.AbstractPendingSetSubtask<HS,M,E,L>
          com.bigdata.service.jini.master.ResourceBufferSubtask<H,O,E,L,S,HS,M,T,A>

All Implemented Interfaces:

Callable<HS>

public class 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>
extends AbstractPendingSetSubtask<HS,M,E,L>

Version:

$Id$

Author:

Bryan Thompson

Field Summary

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

clientTask

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

buffer, lastChunkAvailableNanos, lastChunkNanos, locator, log, master, src, stats

Constructor Summary

ResourceBufferSubtask(M master, L locator, IAsynchronousClientTask<?,E> clientTask, BlockingBuffer<E[]> buffer)

Method Summary

protected Set<E>	getPendingSet() Return the pending set.
protected Set<E>	newPendingSet()

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

addPending, awaitPending, cancelRemoteTask, getPendingSetSize, handleChunk, notifyClientOfRedirect, removePending

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

call, handleRedirect, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

ResourceBufferSubtask

public ResourceBufferSubtask(M master,
                             L locator,
                             IAsynchronousClientTask<?,E> clientTask,
                             BlockingBuffer<E[]> buffer)

Method Detail

getPendingSet

protected Set<E> getPendingSet()

Description copied from class: AbstractPendingSetSubtask

Return the pending set.

Specified by:

getPendingSet in class AbstractPendingSetSubtask<HS extends ResourceBufferSubtaskStatistics,M extends ResourceBufferTask<H,E,S,L,HS>,E extends Serializable,L extends ClientLocator>

newPendingSet

protected Set<E> newPendingSet()