com.bigdata.service.ndx.pipeline

Class MockMaster<H extends MockMasterStats<L,HS>,O,E extends KVO<O>,S extends MockSubtask,L,HS extends MockSubtaskStats>

java.lang.Object

com.bigdata.util.concurrent.AbstractHaltableProcess

com.bigdata.service.ndx.pipeline.AbstractMasterTask<H,E,S,L>

com.bigdata.service.ndx.pipeline.MockMaster<H,O,E,S,L,HS>

All Implemented Interfaces:

IMasterTask<E,H>, Callable<H>

public abstract class MockMaster<H extends MockMasterStats<L,HS>,O,E extends KVO<O>,S extends MockSubtask,L,HS extends MockSubtaskStats>
extends AbstractMasterTask<H,E,S,L>

Class exists solely to make it easier to write the unit tests by aligning the various generic types across the master, the subtask, and their statistics objects.

Version:

$Id$

Author:

Bryan Thompson

Field Summary

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

buffer, log, sinkIdleTimeoutNanos, sinkPollTimeoutNanos, src, stats

Constructor Summary

Constructors

Constructor and Description
MockMaster(H stats, BlockingBuffer<E[]> buffer, long sinkIdleTimeout, long sinkPollTimeout)

Method Summary

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

addToOutputBuffer, call, getBuffer, getRedirectQueueSize, getSink, getStats, handleChunk, mapOperationOverSubtasks, moveSinkToFinishedQueueAtomically, newSubtask, newSubtaskBuffer, nothingPending, notifySubtaskDone, redirectChunk, submitSubtask, willShutdown

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, toString, wait, wait, wait

Constructor Detail

MockMaster

public MockMaster(H stats,
          BlockingBuffer<E[]> buffer,
          long sinkIdleTimeout,
          long sinkPollTimeout)