org.gridgain.grid.kernal.processors.streamer

Class GridStreamerMBeanAdapter

java.lang.Object

org.gridgain.grid.kernal.processors.streamer.GridStreamerMBeanAdapter

All Implemented Interfaces:

GridStreamerMBean

public class GridStreamerMBeanAdapter
extends Object
implements GridStreamerMBean

Streamer MBean implementation.

Constructor Summary

Constructors

Constructor and Description
GridStreamerMBeanAdapter(GridStreamerImpl streamer)

Method Summary

Methods

Modifier and Type	Method and Description
int	getBatchFutureMapSize() Gets size of batch futures map.
int	getCurrentActiveSessions() Gets number of current active sessions.
int	getFailuresCount() Gets number of failures since last reset.
int	getMaximumActiveSessions() Gets maximum number of active sessions since last reset.
String	getName() Gets streamer name.
int	getPipelineAverageExecutionNodes() Gets average number of unique nodes participated in pipeline execution.
long	getPipelineAverageExecutionTime() Gets pipeline average execution time, i.e.
int	getPipelineMaximumExecutionNodes() Gets maximum number of unique nodes participated in pipeline execution.
long	getPipelineMaximumExecutionTime() Gets pipeline maximum execution time, i.e.
int	getPipelineMinimumExecutionNodes() Gets minimum number of unique nodes participated in pipeline execution.
long	getPipelineMinimumExecutionTime() Gets pipeline minimum execution time, i.e.
int	getStageActiveExecutionCount() Gets number of stages currently being executed in streamer pool.
int	getStageFutureMapSize() Gets size of stage futures map.
long	getStageTotalExecutionCount() Gets total number of stages executed since last reset.
int	getStageWaitingExecutionCount() Gets number of event batches currently waiting to be executed.
boolean	isAtLeastOnce() Gets atLeastOnce configuration flag.

Methods inherited from class java.lang.Object

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

Constructor Detail

GridStreamerMBeanAdapter

public GridStreamerMBeanAdapter(GridStreamerImpl streamer)

Parameters:

streamer - Streamer.

Method Detail

getName

@Nullable
public String getName()

Gets streamer name.

Specified by:

getName in interface GridStreamerMBean

Returns:

Streamer name.

isAtLeastOnce

public boolean isAtLeastOnce()

Gets atLeastOnce configuration flag.

Specified by:

isAtLeastOnce in interface GridStreamerMBean

Returns:

True if atLeastOnce is configured.

getStageFutureMapSize

public int getStageFutureMapSize()

Gets size of stage futures map. This map is maintained only when atLeastOnce configuration flag is set to true.

Specified by:

getStageFutureMapSize in interface GridStreamerMBean

Returns:

Stage future map size.

getBatchFutureMapSize

public int getBatchFutureMapSize()

Gets size of batch futures map.

Specified by:

getBatchFutureMapSize in interface GridStreamerMBean

Returns:

Batch future map size.

getStageActiveExecutionCount

public int getStageActiveExecutionCount()

Gets number of stages currently being executed in streamer pool.

Specified by:

getStageActiveExecutionCount in interface GridStreamerMBean

Returns:

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

getStageWaitingExecutionCount

public int getStageWaitingExecutionCount()

Gets number of event batches currently waiting to be executed.

Specified by:

getStageWaitingExecutionCount in interface GridStreamerMBean

Returns:

Number of event batches waiting to be processed.

getStageTotalExecutionCount

public long getStageTotalExecutionCount()

Gets total number of stages executed since last reset.

Specified by:

getStageTotalExecutionCount in interface GridStreamerMBean

Returns:

Total number of stages executed since last reset.

getPipelineMaximumExecutionTime

public long getPipelineMaximumExecutionTime()

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:

getPipelineMaximumExecutionTime in interface GridStreamerMBean

Returns:

Pipeline maximum execution time.

getPipelineMinimumExecutionTime

public long getPipelineMinimumExecutionTime()

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:

getPipelineMinimumExecutionTime in interface GridStreamerMBean

Returns:

Pipeline minimum execution time.

getPipelineAverageExecutionTime

public long getPipelineAverageExecutionTime()

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:

getPipelineAverageExecutionTime in interface GridStreamerMBean

Returns:

Pipeline average execution time.

getPipelineMaximumExecutionNodes

public int getPipelineMaximumExecutionNodes()

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:

getPipelineMaximumExecutionNodes in interface GridStreamerMBean

Returns:

Maximum number of unique nodes in pipeline execution.

getPipelineMinimumExecutionNodes

public int getPipelineMinimumExecutionNodes()

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:

getPipelineMinimumExecutionNodes in interface GridStreamerMBean

Returns:

Minimum number of unique nodes in pipeline execution.

getPipelineAverageExecutionNodes

public int getPipelineAverageExecutionNodes()

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:

getPipelineAverageExecutionNodes in interface GridStreamerMBean

Returns:

Average number of unique nodes in pipeline execution.

getCurrentActiveSessions

public int getCurrentActiveSessions()

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:

getCurrentActiveSessions in interface GridStreamerMBean

Returns:

Number of current active sessions.

getMaximumActiveSessions

public int getMaximumActiveSessions()

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:

getMaximumActiveSessions in interface GridStreamerMBean

Returns:

Maximum active sessions since last reset.

getFailuresCount

public int getFailuresCount()

Gets number of failures since last reset. 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:

getFailuresCount in interface GridStreamerMBean

Returns:

Failures count.