com.bigdata.util.concurrent

Interface IQueueCounters.IWriteServiceExecutorCounters

All Superinterfaces:

ICounterHierarchy, IQueueCounters, IQueueCounters.IThreadPoolExecutorTaskCounters

Enclosing interface:

IQueueCounters

public static interface IQueueCounters.IWriteServiceExecutorCounters
extends IQueueCounters.IThreadPoolExecutorTaskCounters

Additional counters available for the WriteServiceExecutor.

Version:

$Id$

Author:

Bryan Thompson

Nested Class Summary

Nested classes/interfaces inherited from interface com.bigdata.util.concurrent.IQueueCounters

IQueueCounters.ITaskCounters, IQueueCounters.IThreadPoolExecutorCounters, IQueueCounters.IThreadPoolExecutorTaskCounters, IQueueCounters.IWriteServiceExecutorCounters

Field Summary

Fields

Modifier and Type	Field and Description
static String	AbortCount The #of aborts (only reported services which do commit processing).
static String	AverageActiveCountWithLocksHeld The #of tasks that are currently running with locks held (moving average) (this is only reported for the WriteExecutorService as that is the only service where tasks must acquire locks in order to execute).
static String	AverageByteCountPerCommit Moving average of the #of bytes written since the previous commit (zero unless the service is unisolated).
static String	AverageCommitGroupSize Moving average of the #of tasks that participate in commit group.
static String	AverageCommitServiceTime Moving average in milliseconds of the time servicing the group commit (zero unless the service is unisolated).
static String	AverageCommitWaitingTime Moving average in milliseconds of the time that the task that initiates the group commit waits for other tasks to join the commit group (zero unless the service is unisolated).
static String	AverageLockWaitingTime Moving average in milliseconds of the time that a task is waiting for resource locks (zero unless the task is unisolated).
static String	AverageReadyCount The #of tasks that are waiting to run on the internal lock used by the WriteExecutorService to coordinate the start and end of tasks and the group commit.
static String	CommitCount The #of commits (only reported services which do commit processing).
static String	MaxCommitGroupSize The maximum #of tasks in any commit group.
static String	MaxCommitServiceTime The maximum observed value in milliseconds of the time servicing the group commit (zero unless the service is unisolated).
static String	MaxCommitWaitingTime The maximum observed value in milliseconds of the time that the task that initiates the group commit waits for other tasks to join the commit group (zero unless the service is unisolated).
static String	MaxRunning The maximum #of tasks that are concurrently executing without regard to whether or not the tasks have acquired their locks.
static String	OverflowCount The #of synchronous overflow events (only reported services which do commit processing).
static String	RejectedExecutionCount The #of tasks whose execution was rejected, typically because the queue was at capacity.

Fields inherited from interface com.bigdata.util.concurrent.IQueueCounters.IThreadPoolExecutorTaskCounters

AverageArrivalRate, AverageCheckpointTime, AverageQueueWaitingTime, AverageQueuingTime, AverageServiceRate, AverageServiceTime, TaskFailCount, TaskSubmitCount, TaskSuccessCount

Fields inherited from interface com.bigdata.util.concurrent.IQueueCounters

AverageQueueSize

Fields inherited from interface com.bigdata.counters.ICounterHierarchy

CPU, Info, LogicalDisk, Memory, Memory_GarbageCollectors, Memory_Memory_Pools, PhysicalDisk, ps

Field Detail

AverageActiveCountWithLocksHeld

static final String AverageActiveCountWithLocksHeld

The #of tasks that are currently running with locks held (moving average) (this is only reported for the WriteExecutorService as that is the only service where tasks must acquire locks in order to execute).

See Also:

Constant Field Values

AverageReadyCount

static final String AverageReadyCount

The #of tasks that are waiting to run on the internal lock used by the WriteExecutorService to coordinate the start and end of tasks and the group commit. This counter indicates how much potential concurrency is being wasted by the WriteExecutorService.

See Also:

Constant Field Values

AverageLockWaitingTime

static final String AverageLockWaitingTime

Moving average in milliseconds of the time that a task is waiting for resource locks (zero unless the task is unisolated).

See Also:

Constant Field Values

AverageCommitWaitingTime

static final String AverageCommitWaitingTime

Moving average in milliseconds of the time that the task that initiates the group commit waits for other tasks to join the commit group (zero unless the service is unisolated).

See Also:

Constant Field Values

AverageCommitServiceTime

static final String AverageCommitServiceTime

Moving average in milliseconds of the time servicing the group commit (zero unless the service is unisolated).

See Also:

Constant Field Values

AverageByteCountPerCommit

static final String AverageByteCountPerCommit

Moving average of the #of bytes written since the previous commit (zero unless the service is unisolated).

Note: This DOES NOT imply that this many bytes were written in the commit itself. Indices are checkpointed after each task. All writes on the journal should have already occurred before the group commit. The commit protocol itself involves writing a very few bytes and then syncing the disk.

See Also:

Constant Field Values

CommitCount

static final String CommitCount

The #of commits (only reported services which do commit processing).

See Also:

Constant Field Values

AbortCount

static final String AbortCount

The #of aborts (only reported services which do commit processing).

See Also:

Constant Field Values

OverflowCount

static final String OverflowCount

The #of synchronous overflow events (only reported services which do commit processing). A synchronous overflow event is when the index partitions on the live journal are re-defined onto a new live journal. Asynchronous overflow processing then proceeds in the background handling index partition builds, splits, joins, moves, etc.

See Also:

Constant Field Values

RejectedExecutionCount

static final String RejectedExecutionCount

The #of tasks whose execution was rejected, typically because the queue was at capacity.

See Also:

RejectedExecutionHandler, Constant Field Values

MaxCommitWaitingTime

static final String MaxCommitWaitingTime

The maximum observed value in milliseconds of the time that the task that initiates the group commit waits for other tasks to join the commit group (zero unless the service is unisolated).

See Also:

Constant Field Values

MaxCommitServiceTime

static final String MaxCommitServiceTime

The maximum observed value in milliseconds of the time servicing the group commit (zero unless the service is unisolated).

See Also:

Constant Field Values

AverageCommitGroupSize

static final String AverageCommitGroupSize

Moving average of the #of tasks that participate in commit group. (The size of the most recent commit group is sampled and turned into a moving average.)

See Also:

Constant Field Values

MaxCommitGroupSize

static final String MaxCommitGroupSize

The maximum #of tasks in any commit group.

See Also:

Constant Field Values

MaxRunning

static final String MaxRunning

The maximum #of tasks that are concurrently executing without regard to whether or not the tasks have acquired their locks.

Note: Since this does not reflect tasks executing concurrently with locks held it is not a measure of the true concurrency of tasks executing on the service.

See Also:

Constant Field Values