org.gridgain.grid.kernal.processors.streamer

Class GridStreamerStageMetricsHolder

java.lang.Object

org.gridgain.grid.kernal.processors.streamer.GridStreamerStageMetricsHolder

All Implemented Interfaces:

GridStreamerStageMetrics

public class GridStreamerStageMetricsHolder
extends Object
implements GridStreamerStageMetrics

Streamer stage metrics holder.

Constructor Summary

Constructors

Constructor and Description
GridStreamerStageMetricsHolder(String name)

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.
void	onExecutionFinished(long execTime) Execution finished callback.
void	onExecutionStarted(long waitTime) Execution started callback.
void	onFailure() Failure callback.
long	totalExecutionCount() Gets total stage execution count since last reset.

Methods inherited from class java.lang.Object

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

Constructor Detail

GridStreamerStageMetricsHolder

public GridStreamerStageMetricsHolder(String name)

Parameters:

name - Stage name.

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.

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.

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.

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.

onExecutionStarted

public void onExecutionStarted(long waitTime)

Execution started callback.

Parameters:

waitTime - Wait time.

onExecutionFinished

public void onExecutionFinished(long execTime)

Execution finished callback.

Parameters:

execTime - Stage execution time.

onFailure

public void onFailure()

Failure callback.