@MXBeanDescription(value="MBean that provides access to streamer description and metrics.") public interface StreamerMBean
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. time between execution start and time when last stage in pipeline
returned empty map.
|
int |
getPipelineMaximumExecutionNodes()
Gets maximum number of unique nodes participated in pipeline execution.
|
long |
getPipelineMaximumExecutionTime()
Gets pipeline maximum execution time, i.e. time between execution start and time when last stage in pipeline
returned empty map.
|
int |
getPipelineMinimumExecutionNodes()
Gets minimum number of unique nodes participated in pipeline execution.
|
long |
getPipelineMinimumExecutionTime()
Gets pipeline minimum execution time, i.e. time between execution start and time when last stage in pipeline
returned empty map.
|
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. |
@MXBeanDescription(value="Streamer name.") @Nullable String getName()
@MXBeanDescription(value="True if atLeastOnce is configured.") boolean isAtLeastOnce()
atLeastOnce
configuration flag.True
if atLeastOnce
is configured.@MXBeanDescription(value="Stage future map size.") int getStageFutureMapSize()
atLeastOnce
configuration
flag is set to true.@MXBeanDescription(value="Batch future map size.") int getBatchFutureMapSize()
@MXBeanDescription(value="Number of stages currently being executed in streamer pool.") int getStageActiveExecutionCount()
@MXBeanDescription(value="Number of event batches currently waiting to be executed.") int getStageWaitingExecutionCount()
@MXBeanDescription(value="Total number of stages executed since last reset.") long getStageTotalExecutionCount()
@MXBeanDescription(value="Pipeline maximum execution time.") long getPipelineMaximumExecutionTime()
@MXBeanDescription(value="Pipeline minimum execution time.") long getPipelineMinimumExecutionTime()
@MXBeanDescription(value="Pipeline average execution time.") long getPipelineAverageExecutionTime()
@MXBeanDescription(value="Maximum number of unique nodes participated in pipeline execution.") int getPipelineMaximumExecutionNodes()
@MXBeanDescription(value="Minimum number of unique nodes participated in pipeline execution.") int getPipelineMinimumExecutionNodes()
@MXBeanDescription(value="Average number of unique nodes participated in pipeline execution.") int getPipelineAverageExecutionNodes()
@MXBeanDescription(value="Number of current active sessions.") int getCurrentActiveSessions()
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.@MXBeanDescription(value="Maximum number of active sessions since last reset.") int getMaximumActiveSessions()
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.@MXBeanDescription(value="Number of failures since last reset.") int getFailuresCount()
atLeastOnce
flag is set to steamer configuration,
then only root node failures will be counted. Otherwise each node will count failures independently.
Follow @ApacheIgnite
Apache Ignite Fabric : ver. 1.0.0-RC1 Release Date : February 16 2015