org.gridgain.grid.kernal.processors.streamer

Class GridStreamerStageMBeanAdapter

java.lang.Object

org.gridgain.grid.kernal.processors.streamer.GridStreamerStageMBeanAdapter

All Implemented Interfaces:

GridStreamerStageMBean

public class GridStreamerStageMBeanAdapter
extends Object
implements GridStreamerStageMBean

Streamer stage MBean adapter.

Constructor Summary

Constructors

Constructor and Description
GridStreamerStageMBeanAdapter(String stageName, String stageClsName, GridStreamerImpl streamer)

Method Summary

Methods

Modifier and Type	Method and Description
long	getAverageExecutionTime() Gets stage average execution time.
long	getAverageWaitingTime() Stage average waiting time.
int	getFailuresCount() Gets stage failure count.
long	getMaximumExecutionTime() Gets stage maximum execution time.
long	getMaximumWaitingTime() Gets stage maximum waiting time.
long	getMinimumExecutionTime() Gets stage minimum execution time.
long	getMinimumWaitingTime() Gets stage minimum waiting time.
String	getName() Gets stage name.
String	getStageClassName() Gets stage class name.
long	getTotalExecutionCount() Gets total stage execution count since last reset.
boolean	isExecuting() Gets flag indicating if stage is being currently executed by at least one thread on current node.

Methods inherited from class java.lang.Object

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

Constructor Detail

GridStreamerStageMBeanAdapter

public GridStreamerStageMBeanAdapter(String stageName,
                             String stageClsName,
                             GridStreamerImpl streamer)

Parameters:

stageName - Stage name.

stageClsName - Stage class name.

streamer - Streamer implementation.

Method Detail

getName

public String getName()

Gets stage name.

Specified by:

getName in interface GridStreamerStageMBean

Returns:

Stage name.

getStageClassName

public String getStageClassName()

Gets stage class name.

Specified by:

getStageClassName in interface GridStreamerStageMBean

Returns:

Stage class name.

getMinimumExecutionTime

public long getMinimumExecutionTime()

Gets stage minimum execution time.

Specified by:

getMinimumExecutionTime in interface GridStreamerStageMBean

Returns:

Stage minimum execution time.

getMaximumExecutionTime

public long getMaximumExecutionTime()

Gets stage maximum execution time.

Specified by:

getMaximumExecutionTime in interface GridStreamerStageMBean

Returns:

Stage maximum execution time.

getAverageExecutionTime

public long getAverageExecutionTime()

Gets stage average execution time.

Specified by:

getAverageExecutionTime in interface GridStreamerStageMBean

Returns:

Stage average execution time.

getMinimumWaitingTime

public long getMinimumWaitingTime()

Gets stage minimum waiting time.

Specified by:

getMinimumWaitingTime in interface GridStreamerStageMBean

Returns:

Stage minimum waiting time.

getMaximumWaitingTime

public long getMaximumWaitingTime()

Gets stage maximum waiting time.

Specified by:

getMaximumWaitingTime in interface GridStreamerStageMBean

Returns:

Stage maximum waiting time.

getAverageWaitingTime

public long getAverageWaitingTime()

Stage average waiting time.

Specified by:

getAverageWaitingTime in interface GridStreamerStageMBean

Returns:

Stage average waiting time.

getTotalExecutionCount

public long getTotalExecutionCount()

Gets total stage execution count since last reset.

Specified by:

getTotalExecutionCount in interface GridStreamerStageMBean

Returns:

Number of times this stage was executed.

getFailuresCount

public int getFailuresCount()

Gets stage failure count.

Specified by:

getFailuresCount in interface GridStreamerStageMBean

Returns:

Stage failure count.

isExecuting

public boolean isExecuting()

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

Specified by:

isExecuting in interface GridStreamerStageMBean

Returns:

True if stage is executing now.