Package | Description |
---|---|
com.bigdata.service.ndx.pipeline |
Modifier and Type | Class and Description |
---|---|
class |
AbstractMasterTask<H extends AbstractMasterStats<L,? extends AbstractSubtaskStats>,E,S extends AbstractSubtask,L>
Abstract base class for a master task which consumes chunks of elements
written onto a
BlockingBuffer and distributes those chunks to
subtasks according to some abstraction which is not defined by this class. |
class |
AbstractSubtask<HS extends AbstractSubtaskStats,M extends AbstractMasterTask<? extends AbstractMasterStats<L,HS>,E,? extends AbstractSubtask,L>,E,L>
Abstract implementation of a subtask for the
AbstractMasterTask
handles the protocol for startup and termination of the subtask. |
Modifier and Type | Class and Description |
---|---|
class |
AbstractPendingSetMasterStats<L,HS extends AbstractSubtaskStats>
Extended to report the moving average of the pending set size for the master
and the sinks and to report the maximum pending set size for the sinks.
|
class |
AbstractRunnableMasterStats<L,HS extends AbstractSubtaskStats>
Statistics for the consumer, including several moving averages based on
sampled data.
|
class |
IndexAsyncWriteStats<L,HS extends IndexPartitionWriteStats>
Statistics for asynchronous index writes.
|
class |
MockMasterStats<L,HS extends MockSubtaskStats>
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.
|
Modifier and Type | Field and Description |
---|---|
H |
AbstractMasterTask.stats
Statistics for this (and perhaps other) masters.
|
Copyright © 2006–2019 SYSTAP, LLC DBA Blazegraph. All rights reserved.