com.bigdata.service.ndx

Class IndexSyncRPCCounters

java.lang.Object

com.bigdata.util.concurrent.TaskCounters

com.bigdata.service.ndx.IndexSyncRPCCounters

public class IndexSyncRPCCounters
extends TaskCounters

Counters used for sync RPC on scale-out indices.

Version:

$Id$

Author:

Bryan Thompson

Field Summary

Fields

Modifier and Type	Field and Description
long	elementsOut The #of elements in a synchronous RPC request.
long	keyArrayRequestCount #of key-array requests issued (batch read or write operations).
long	keyRangeRequestCount #of key-range requests issued (generally these are range counts).
long	pointRequestCount #Of point requests issued (a single key).
long	readOnlyRequestCount #of read-only requests.
long	redirectCount The #of redirects (StaleLocatorExceptions) that were handled.
long	requestCount The #of requests which have been submitted.

Fields inherited from class com.bigdata.util.concurrent.TaskCounters

checkpointNanoTime, interArrivalNanoTime, lastArrivalNanoTime, queueWaitingNanoTime, queuingNanoTime, serviceNanoTime, taskCompleteCount, taskFailCount, taskSubmitCount, taskSuccessCount

Constructor Summary

Constructors

Constructor and Description
IndexSyncRPCCounters()

Method Summary

Methods

Modifier and Type	Method and Description
double	getAverageElementsPerRequest() The average #of elements (tuples) per request.
double	getAverageNanosPerRequest() The average #of nanoseconds per request.
CounterSet	getCounters() Note: The elapsed time counters (TaskCounters.queueWaitingNanoTime, TaskCounters.serviceNanoTime, and TaskCounters.queuingNanoTime) are reported as cumulative milliseconds by this method.

Methods inherited from class com.bigdata.util.concurrent.TaskCounters

toString

Methods inherited from class java.lang.Object

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

Field Detail

redirectCount

public long redirectCount

The #of redirects (StaleLocatorExceptions) that were handled.

requestCount

public long requestCount

The #of requests which have been submitted. This counter is incremented when the task is actually dispatched via RMI to the data service so it will not reflect tasks which are in the client's queue.

elementsOut

public long elementsOut

The #of elements in a synchronous RPC request. Single point requests are reported as ONE (1) element out. Key-range requests are NOT reported under this counter (they correspond to iterators and range counts). Key-array requests report the #of tuples in the request (they correspond to batch read and write operations).

pointRequestCount

public long pointRequestCount

#Of point requests issued (a single key).

keyRangeRequestCount

public long keyRangeRequestCount

#of key-range requests issued (generally these are range counts).

keyArrayRequestCount

public long keyArrayRequestCount

#of key-array requests issued (batch read or write operations).

readOnlyRequestCount

public long readOnlyRequestCount

#of read-only requests.

Constructor Detail

IndexSyncRPCCounters

public IndexSyncRPCCounters()

Method Detail

getAverageNanosPerRequest

public double getAverageNanosPerRequest()

The average #of nanoseconds per request.

getAverageElementsPerRequest

public double getAverageElementsPerRequest()

The average #of elements (tuples) per request. Because elementsOut and requestCount are incremented when the request is submitted, this reflects both the completed requests and any requests which might be outstanding.

getCounters

public CounterSet getCounters()

Description copied from class: TaskCounters

Note: The elapsed time counters (TaskCounters.queueWaitingNanoTime, TaskCounters.serviceNanoTime, and TaskCounters.queuingNanoTime) are reported as cumulative milliseconds by this method. These data are turned into moving averages by the ThreadPoolExecutorStatisticsTask.

Overrides:

getCounters in class TaskCounters