org.gridgain.grid.kernal.processors.streamer

Class GridStreamerStageMetricsAdapter

java.lang.Object

org.gridgain.grid.kernal.processors.streamer.GridStreamerStageMetricsAdapter

All Implemented Interfaces:

GridStreamerStageMetrics

public class GridStreamerStageMetricsAdapter
extends Object
implements GridStreamerStageMetrics

Streamer stage metrics adapter.

Constructor Summary

Constructors

Constructor and Description
GridStreamerStageMetricsAdapter() Empty constructor.
GridStreamerStageMetricsAdapter(GridStreamerStageMetrics metrics)

Method Summary

Methods

Modifier and Type	Method and Description
long	averageExecutionTime() Gets stage average execution time.
long	averageWaitingTime() Stage average waiting time.
boolean	executing() Gets flag indicating if stage is being currently executed by at least one thread on current node.
int	failuresCount() Gets stage failure count.
long	maximumExecutionTime() Gets stage maximum execution time.
long	maximumWaitingTime() Gets stage maximum waiting time.
long	minimumExecutionTime() Gets stage minimum execution time.
long	minimumWaitingTime() Gets stage minimum waiting time.
String	name() Gets stage name.
String	toString()
long	totalExecutionCount() Gets total stage execution count since last reset.

Methods inherited from class java.lang.Object

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

Constructor Detail

GridStreamerStageMetricsAdapter

public GridStreamerStageMetricsAdapter()

Empty constructor.

GridStreamerStageMetricsAdapter

public GridStreamerStageMetricsAdapter(GridStreamerStageMetrics metrics)

Parameters:

metrics - Metrics.

Method Detail

name

public String name()

Gets stage name.

Specified by:

name in interface GridStreamerStageMetrics

Returns:

Stage name.

minimumExecutionTime

public long minimumExecutionTime()

Gets stage minimum execution time.

Specified by:

minimumExecutionTime in interface GridStreamerStageMetrics

Returns:

Stage minimum execution time.

maximumExecutionTime

public long maximumExecutionTime()

Gets stage maximum execution time.

Specified by:

maximumExecutionTime in interface GridStreamerStageMetrics

Returns:

Stage maximum execution time.

averageExecutionTime

public long averageExecutionTime()

Gets stage average execution time.

Specified by:

averageExecutionTime in interface GridStreamerStageMetrics

Returns:

Stage average execution time.

totalExecutionCount

public long totalExecutionCount()

Gets total stage execution count since last reset.

Specified by:

totalExecutionCount in interface GridStreamerStageMetrics

Returns:

Number of times this stage was executed.

minimumWaitingTime

public long minimumWaitingTime()

Gets stage minimum waiting time.

Specified by:

minimumWaitingTime in interface GridStreamerStageMetrics

Returns:

Stage minimum waiting time.

maximumWaitingTime

public long maximumWaitingTime()

Gets stage maximum waiting time.

Specified by:

maximumWaitingTime in interface GridStreamerStageMetrics

Returns:

Stage maximum waiting time.

averageWaitingTime

public long averageWaitingTime()

Stage average waiting time.

Specified by:

averageWaitingTime in interface GridStreamerStageMetrics

Returns:

Stage average waiting time.

failuresCount

public int failuresCount()

Gets stage failure count.

Specified by:

failuresCount in interface GridStreamerStageMetrics

Returns:

Stage failure count.

executing

public boolean executing()

Gets flag indicating if stage is being currently executed by at least one thread on current node.

Specified by:

executing in interface GridStreamerStageMetrics

Returns:

True if stage is executing now.

toString

public String toString()

Overrides:

toString in class Object