org.gridgain.grid.kernal.processors.streamer

Class GridStreamerMetricsAdapter

java.lang.Object

org.gridgain.grid.kernal.processors.streamer.GridStreamerMetricsAdapter

All Implemented Interfaces:

GridStreamerMetrics

public class GridStreamerMetricsAdapter
extends Object
implements GridStreamerMetrics

Streamer metrics adapter.

Constructor Summary

Constructors

Constructor and Description
GridStreamerMetricsAdapter() Empty constructor.
GridStreamerMetricsAdapter(GridStreamerMetrics metrics)

Method Summary

Methods

Modifier and Type	Method and Description
int	currentActiveSessions() Gets number of current active sessions.
int	executorServiceCapacity() Gets maximum number of threads in executor service.
int	failuresCount() Gets number of failures.
int	maximumActiveSessions() Gets maximum number of active sessions since last reset.
int	pipelineAverageExecutionNodes() Gets average number of unique nodes participated in pipeline execution.
long	pipelineAverageExecutionTime() Gets pipeline average execution time, i.e.
int	pipelineMaximumExecutionNodes() Gets maximum number of unique nodes participated in pipeline execution.
long	pipelineMaximumExecutionTime() Gets pipeline maximum execution time, i.e.
int	pipelineMinimumExecutionNodes() Gets minimum number of unique nodes participated in pipeline execution.
long	pipelineMinimumExecutionTime() Gets pipeline minimum execution time, i.e.
int	queryAverageExecutionNodes() Gets average number of unique nodes participated in query execution.
long	queryAverageExecutionTime() Gets query average execution time.
int	queryMaximumExecutionNodes() Gets maximum number of unique nodes participated in query execution.
long	queryMaximumExecutionTime() Gets query maximum execution time.
int	queryMinimumExecutionNodes() Gets minimum number of unique nodes participated in query execution.
long	queryMinimumExecutionTime() Gets query minimum execution time.
int	stageActiveExecutionCount() Gets number of stages currently being executed in streamer pool.
Collection<GridStreamerStageMetrics>	stageMetrics() Gets metrics for all stages.
GridStreamerStageMetrics	stageMetrics(String stageName) Gets current stage metrics, if stage with given name is not configured then IllegalArgumentException will be thrown.
long	stageTotalExecutionCount() Gets total number of stages executed since last reset.
int	stageWaitingExecutionCount() Gets number of event batches currently waiting to be executed.
String	toString()
Collection<GridStreamerWindowMetrics>	windowMetrics() Gets metrics for all windows.
GridStreamerWindowMetrics	windowMetrics(String winName) Gets current window metrics, if window with given name is not configured then IllegalArgumentException will be thrown.

Methods inherited from class java.lang.Object

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

Constructor Detail

GridStreamerMetricsAdapter

public GridStreamerMetricsAdapter()

Empty constructor.

GridStreamerMetricsAdapter

public GridStreamerMetricsAdapter(GridStreamerMetrics metrics)

Parameters:

metrics - Metrics.

Method Detail

stageActiveExecutionCount

public int stageActiveExecutionCount()

Gets number of stages currently being executed in streamer pool.

Specified by:

stageActiveExecutionCount in interface GridStreamerMetrics

Returns:

Number of stages. Cannot be more than pool thread count.

stageWaitingExecutionCount

public int stageWaitingExecutionCount()

Gets number of event batches currently waiting to be executed.

Specified by:

stageWaitingExecutionCount in interface GridStreamerMetrics

Returns:

Number of event batches waiting to be processed.

stageTotalExecutionCount

public long stageTotalExecutionCount()

Gets total number of stages executed since last reset.

Specified by:

stageTotalExecutionCount in interface GridStreamerMetrics

Returns:

Total number of stages executed since last reset.

pipelineMaximumExecutionTime

public long pipelineMaximumExecutionTime()

Gets pipeline maximum execution time, i.e. time between execution start and time when last stage in pipeline returned empty map. If pipeline execution was split to different nodes, metrics for each split will be recorded independently.

Specified by:

pipelineMaximumExecutionTime in interface GridStreamerMetrics

Returns:

Pipeline maximum execution time.

pipelineMinimumExecutionTime

public long pipelineMinimumExecutionTime()

Gets pipeline minimum execution time, i.e. time between execution start and time when last stage in pipeline returned empty map. If pipeline execution was split to different nodes, metrics for each split will be recorded independently.

Specified by:

pipelineMinimumExecutionTime in interface GridStreamerMetrics

Returns:

Pipeline minimum execution time.

pipelineAverageExecutionTime

public long pipelineAverageExecutionTime()

Gets pipeline average execution time, i.e. time between execution start and time when last stage in pipeline returned empty map. If pipeline execution was split, metrics for each split will be recorded independently.

Specified by:

pipelineAverageExecutionTime in interface GridStreamerMetrics

Returns:

Pipeline average execution time.

pipelineMaximumExecutionNodes

public int pipelineMaximumExecutionNodes()

Gets maximum number of unique nodes participated in pipeline execution. If pipeline execution was split, metrics for each split will be recorded independently.

Specified by:

pipelineMaximumExecutionNodes in interface GridStreamerMetrics

Returns:

Maximum number of unique nodes in pipeline execution.

pipelineMinimumExecutionNodes

public int pipelineMinimumExecutionNodes()

Gets minimum number of unique nodes participated in pipeline execution. If pipeline execution was split, metrics for each split will be recorded independently.

Specified by:

pipelineMinimumExecutionNodes in interface GridStreamerMetrics

Returns:

Minimum number of unique nodes in pipeline execution.

pipelineAverageExecutionNodes

public int pipelineAverageExecutionNodes()

Gets average number of unique nodes participated in pipeline execution. If pipeline execution was split, metrics for each split will be recorded independently.

Specified by:

pipelineAverageExecutionNodes in interface GridStreamerMetrics

Returns:

Average number of unique nodes in pipeline execution.

queryMaximumExecutionTime

public long queryMaximumExecutionTime()

Gets query maximum execution time. If query execution was split to different nodes, metrics for each split will be recorded independently.

Specified by:

queryMaximumExecutionTime in interface GridStreamerMetrics

Returns:

Query maximum execution time.

queryMinimumExecutionTime

public long queryMinimumExecutionTime()

Gets query minimum execution time. If query execution was split to different nodes, metrics for each split will be recorded independently.

Specified by:

queryMinimumExecutionTime in interface GridStreamerMetrics

Returns:

Query minimum execution time.

queryAverageExecutionTime

public long queryAverageExecutionTime()

Gets query average execution time. If query execution was split to different nodes, metrics for each split will be recorded independently.

Specified by:

queryAverageExecutionTime in interface GridStreamerMetrics

Returns:

Query average execution time.

queryMaximumExecutionNodes

public int queryMaximumExecutionNodes()

Gets maximum number of unique nodes participated in query execution. If query execution was split, metrics for each split will be recorded independently.

Specified by:

queryMaximumExecutionNodes in interface GridStreamerMetrics

Returns:

Maximum number of unique nodes in query execution.

queryMinimumExecutionNodes

public int queryMinimumExecutionNodes()

Gets minimum number of unique nodes participated in query execution. If query execution was split, metrics for each split will be recorded independently.

Specified by:

queryMinimumExecutionNodes in interface GridStreamerMetrics

Returns:

Minimum number of unique nodes in query execution.

queryAverageExecutionNodes

public int queryAverageExecutionNodes()

Gets average number of unique nodes participated in query execution. If query execution was split, metrics for each split will be recorded independently.

Specified by:

queryAverageExecutionNodes in interface GridStreamerMetrics

Returns:

Average number of unique nodes in query execution.

currentActiveSessions

public int currentActiveSessions()

Gets number of current active sessions. Since event execution sessions are tracked only when atLeastOnce configuration property is set to true, this metric will be collected only in this case. When atLeastOnce is set to false, this metric will always be zero.

Specified by:

currentActiveSessions in interface GridStreamerMetrics

Returns:

Number of current active sessions.

maximumActiveSessions

public int maximumActiveSessions()

Gets maximum number of active sessions since last reset. Since event execution sessions are tracked only when atLeastOnce configuration property is set to true, this metric will be collected only in this case. When atLeastOnce is set to false, this metric will always be zero.

Specified by:

maximumActiveSessions in interface GridStreamerMetrics

Returns:

Maximum active sessions since last reset.

failuresCount

public int failuresCount()

Gets number of failures. If atLeastOnce flag is set to steamer configuration, then only root node failures will be counted. Otherwise each node will count failures independently.

Specified by:

failuresCount in interface GridStreamerMetrics

Returns:

Failures count.

executorServiceCapacity

public int executorServiceCapacity()

Gets maximum number of threads in executor service.

Specified by:

executorServiceCapacity in interface GridStreamerMetrics

Returns:

Maximum number of threads in executor service.

stageMetrics

public GridStreamerStageMetrics stageMetrics(String stageName)

Gets current stage metrics, if stage with given name is not configured then IllegalArgumentException will be thrown.

Specified by:

stageMetrics in interface GridStreamerMetrics

Parameters:

stageName - Stage name.

Returns:

Stage metrics.

stageMetrics

public Collection<GridStreamerStageMetrics> stageMetrics()

Gets metrics for all stages. Stage metrics order is the same as stage order in configuration.

Specified by:

stageMetrics in interface GridStreamerMetrics

Returns:

Stage metrics collection.

windowMetrics

public GridStreamerWindowMetrics windowMetrics(String winName)

Gets current window metrics, if window with given name is not configured then IllegalArgumentException will be thrown.

Specified by:

windowMetrics in interface GridStreamerMetrics

Parameters:

winName - Window name.

Returns:

Window metrics.

windowMetrics

public Collection<GridStreamerWindowMetrics> windowMetrics()

Gets metrics for all windows.

Specified by:

windowMetrics in interface GridStreamerMetrics

Returns:

Collection of window metrics.

toString

public String toString()

Overrides:

toString in class Object