com.bigdata.service.ndx.pipeline

Class IndexPartitionWriteTask<H extends IndexAsyncWriteStats<L,HS>,O,E extends KVO<O>,L extends PartitionLocator,S extends IndexPartitionWriteTask,HS extends IndexPartitionWriteStats,M extends IndexWriteTask<H,O,E,S,L,HS,T,R,A>,T extends IKeyArrayIndexProcedure,R,A>

java.lang.Object

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

com.bigdata.service.ndx.pipeline.IndexPartitionWriteTask<H,O,E,L,S,HS,M,T,R,A>

All Implemented Interfaces:

Callable<HS>

public class IndexPartitionWriteTask<H extends IndexAsyncWriteStats<L,HS>,O,E extends KVO<O>,L extends PartitionLocator,S extends IndexPartitionWriteTask,HS extends IndexPartitionWriteStats,M extends IndexWriteTask<H,O,E,S,L,HS,T,R,A>,T extends IKeyArrayIndexProcedure,R,A>
extends AbstractSubtask<HS,M,E,L>

Class drains a BlockingBuffer writing on a specific index partition.

Version:

$Id$

Author:

Bryan Thompson

Field Summary

Fields

Modifier and Type	Field and Description
IDataService	dataService The data service on which the index partition resides.
int	partitionId The index partition identifier.
long	timestamp The timestamp associated with the index view.

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

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

Constructor Summary

Constructors

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

Method Summary

Methods

Modifier and Type	Method and Description
protected boolean	handleChunk(E[] sourceChunk) Process a chunk from the buffer.
protected void	notifyClientOfRedirect(L locator, Throwable cause) Notifies the client that the locator is stale.
String	toString()

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

awaitPending, call, cancelRemoteTask, handleRedirect

Methods inherited from class java.lang.Object

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

Field Detail

dataService

public final IDataService dataService

The data service on which the index partition resides.

timestamp

public final long timestamp

The timestamp associated with the index view.

partitionId

public final int partitionId

The index partition identifier.

Constructor Detail

IndexPartitionWriteTask

public IndexPartitionWriteTask(M master,
                       L locator,
                       IDataService dataService,
                       BlockingBuffer<E[]> buffer)

Method Detail

toString

public String toString()

Overrides:

toString in class AbstractSubtask<HS extends IndexPartitionWriteStats,M extends IndexWriteTask<H,O,E,S,L,HS,T,R,A>,E extends KVO<O>,L extends PartitionLocator>

handleChunk

protected boolean handleChunk(E[] sourceChunk)
                       throws ExecutionException,
                              InterruptedException,
                              IOException

Process a chunk from the buffer. Maps the chunk across the sinks for the index partitions on which the element in that chunk must be written.

Specified by:

handleChunk in class AbstractSubtask<HS extends IndexPartitionWriteStats,M extends IndexWriteTask<H,O,E,S,L,HS,T,R,A>,E extends KVO<O>,L extends PartitionLocator>

Parameters:

sourceChunk - A chunk (in sorted order).

Returns:

true iff a StaleLocatorException was handled, in which case the task should exit immediately.

Throws:

IOException - RMI error.

ExecutionException

InterruptedException

notifyClientOfRedirect

protected void notifyClientOfRedirect(L locator,
                          Throwable cause)

Notifies the client that the locator is stale.

Specified by:

notifyClientOfRedirect in class AbstractSubtask<HS extends IndexPartitionWriteStats,M extends IndexWriteTask<H,O,E,S,L,HS,T,R,A>,E extends KVO<O>,L extends PartitionLocator>

Parameters:

locator - The locator.

cause - The cause.