public interface StreamerMetrics
Modifier and Type | Method and Description |
---|---|
int |
currentActiveSessions()
Gets number of current active sessions.
|
int |
executorServiceCapacity()
Gets maximum number of threads in executor service.
|
int |
failuresCount()
Gets number of failures.
|
int |
maximumActiveSessions()
Gets maximum number of active sessions since last reset.
|
int |
pipelineAverageExecutionNodes()
Gets average number of unique nodes participated in pipeline execution.
|
long |
pipelineAverageExecutionTime()
Gets pipeline average execution time, i.e. time between execution start and time when last stage in pipeline
returned empty map.
|
int |
pipelineMaximumExecutionNodes()
Gets maximum number of unique nodes participated in pipeline execution.
|
long |
pipelineMaximumExecutionTime()
Gets pipeline maximum execution time, i.e. time between execution start and time when last stage in pipeline
returned empty map.
|
int |
pipelineMinimumExecutionNodes()
Gets minimum number of unique nodes participated in pipeline execution.
|
long |
pipelineMinimumExecutionTime()
Gets pipeline minimum execution time, i.e. time between execution start and time when last stage in pipeline
returned empty map.
|
int |
queryAverageExecutionNodes()
Gets average number of unique nodes participated in query execution.
|
long |
queryAverageExecutionTime()
Gets query average execution time.
|
int |
queryMaximumExecutionNodes()
Gets maximum number of unique nodes participated in query execution.
|
long |
queryMaximumExecutionTime()
Gets query maximum execution time.
|
int |
queryMinimumExecutionNodes()
Gets minimum number of unique nodes participated in query execution.
|
long |
queryMinimumExecutionTime()
Gets query minimum execution time.
|
int |
stageActiveExecutionCount()
Gets number of stages currently being executed in streamer pool.
|
Collection<StreamerStageMetrics> |
stageMetrics()
Gets metrics for all stages.
|
StreamerStageMetrics |
stageMetrics(String stageName)
Gets current stage metrics, if stage with given name is not configured
then
IllegalArgumentException will be thrown. |
long |
stageTotalExecutionCount()
Gets total number of stages executed since last reset.
|
int |
stageWaitingExecutionCount()
Gets number of event batches currently waiting to be executed.
|
Collection<StreamerWindowMetrics> |
windowMetrics()
Gets metrics for all windows.
|
StreamerWindowMetrics |
windowMetrics(String winName)
Gets current window metrics, if window with given name is not configured
then
IllegalArgumentException will be thrown. |
int stageActiveExecutionCount()
int stageWaitingExecutionCount()
long stageTotalExecutionCount()
long pipelineMaximumExecutionTime()
long pipelineMinimumExecutionTime()
long pipelineAverageExecutionTime()
int pipelineMaximumExecutionNodes()
int pipelineMinimumExecutionNodes()
int pipelineAverageExecutionNodes()
long queryMaximumExecutionTime()
long queryMinimumExecutionTime()
long queryAverageExecutionTime()
int queryMaximumExecutionNodes()
int queryMinimumExecutionNodes()
int queryAverageExecutionNodes()
int currentActiveSessions()
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.int maximumActiveSessions()
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.int failuresCount()
atLeastOnce
flag is set to steamer configuration, then only root node
failures will be counted. Otherwise each node will count failures independently.int executorServiceCapacity()
StreamerStageMetrics stageMetrics(String stageName)
IllegalArgumentException
will be thrown.stageName
- Stage name.Collection<StreamerStageMetrics> stageMetrics()
StreamerWindowMetrics windowMetrics(String winName)
IllegalArgumentException
will be thrown.winName
- Window name.Collection<StreamerWindowMetrics> windowMetrics()
Follow @ApacheIgnite
Apache Ignite Fabric : ver. 1.0.0-RC3 Release Date : March 24 2015