com.bigdata.service.ndx.pipeline

Class IndexWriteTask.M<T extends IKeyArrayIndexProcedure,O,R,A>

java.lang.Object

com.bigdata.util.concurrent.AbstractHaltableProcess

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

com.bigdata.service.ndx.pipeline.IndexWriteTask<IndexAsyncWriteStats<PartitionLocator,IndexPartitionWriteStats>,O,KVO<O>,IndexPartitionWriteTask,PartitionLocator,IndexPartitionWriteStats,T,R,A>

com.bigdata.service.ndx.pipeline.IndexWriteTask.M<T,O,R,A>

Type Parameters:

T - The generic type of the CTOR for the procedure used to write on the index.

O - The generic type for unserialized value objects.

R - The type of the result from applying the index procedure to a single Split of data.

A - The type of the aggregated result.

All Implemented Interfaces:

IMasterTask<KVO<O>,IndexAsyncWriteStats<PartitionLocator,IndexPartitionWriteStats>>, Callable<IndexAsyncWriteStats<PartitionLocator,IndexPartitionWriteStats>>

Enclosing class:

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

public static class IndexWriteTask.M<T extends IKeyArrayIndexProcedure,O,R,A>
extends IndexWriteTask<IndexAsyncWriteStats<PartitionLocator,IndexPartitionWriteStats>,O,KVO<O>,IndexPartitionWriteTask,PartitionLocator,IndexPartitionWriteStats,T,R,A>

Concrete master hides most of the generic types leaving you with only those that are meaningfully parameterize for applications using the streaming write API.

Version:

$Id$

Author:

Bryan Thompson

Nested Class Summary

Nested classes/interfaces inherited from class com.bigdata.service.ndx.pipeline.IndexWriteTask

IndexWriteTask.M<T extends IKeyArrayIndexProcedure,O,R,A>

Field Summary

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

ctor, duplicateRemover, ndx, resultHandler, sinkChunkSize, sinkChunkTimeoutNanos, sinkQueueCapacity

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

buffer, log, sinkIdleTimeoutNanos, sinkPollTimeoutNanos, src, stats

Constructor Summary

Constructors

Constructor and Description
IndexWriteTask.M(IScaleOutClientIndex ndx, long sinkIdleTimeoutNanos, long sinkPollTimeoutNanos, int sinkQueueCapacity, int sinkChunkSize, long sinkChunkTimeoutNanos, IDuplicateRemover<O> duplicateRemover, AbstractKeyArrayIndexProcedureConstructor<T> ctor, IResultHandler<R,A> resultHandler, IndexAsyncWriteStats<PartitionLocator,IndexPartitionWriteStats> stats, BlockingBuffer<KVO<O>[]> buffer)

Method Summary

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

handleChunk, newSubtask, newSubtaskBuffer, submitSubtask, toString

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

addToOutputBuffer, call, getBuffer, getRedirectQueueSize, getSink, getStats, mapOperationOverSubtasks, moveSinkToFinishedQueueAtomically, nothingPending, notifySubtaskDone, redirectChunk, 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, wait, wait, wait

Constructor Detail

IndexWriteTask.M

public IndexWriteTask.M(IScaleOutClientIndex ndx,
                long sinkIdleTimeoutNanos,
                long sinkPollTimeoutNanos,
                int sinkQueueCapacity,
                int sinkChunkSize,
                long sinkChunkTimeoutNanos,
                IDuplicateRemover<O> duplicateRemover,
                AbstractKeyArrayIndexProcedureConstructor<T> ctor,
                IResultHandler<R,A> resultHandler,
                IndexAsyncWriteStats<PartitionLocator,IndexPartitionWriteStats> stats,
                BlockingBuffer<KVO<O>[]> buffer)