com.bigdata.service.ndx.pipeline

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

java.lang.Object

com.bigdata.service.ndx.pipeline.AbstractSubtask<HS,M,E,L>

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

All Implemented Interfaces:

Callable<HS>

public abstract class MockSubtask<H extends MockMasterStats<L,HS>,O,E extends KVO<O>,L,S extends MockSubtask,HS extends MockSubtaskStats,M extends MockMaster<H,O,E,S,L,HS>>
extends AbstractSubtask<HS,M,E,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.AbstractSubtask

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

Constructor Summary

Constructors

Constructor and Description
MockSubtask(M master, L locator, BlockingBuffer<E[]> buffer)

Method Summary

Methods

Modifier and Type	Method and Description
protected void	notifyClientOfRedirect(L locator, Throwable cause) NOP.

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

awaitPending, call, cancelRemoteTask, handleChunk, handleRedirect, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

MockSubtask

public MockSubtask(M master,
           L locator,
           BlockingBuffer<E[]> buffer)

Parameters:

master -

locator -

buffer -

Method Detail

notifyClientOfRedirect

protected void notifyClientOfRedirect(L locator,
                          Throwable cause)

NOP.

Specified by:

notifyClientOfRedirect in class AbstractSubtask<HS extends MockSubtaskStats,M extends MockMaster<H,O,E,S,L,HS>,E extends KVO<O>,L>

Parameters:

locator - The locator.

cause - The cause.