public class VisorStreamerStageMetrics extends Object implements Serializable
StreamerStageMetrics.| Constructor and Description |
|---|
VisorStreamerStageMetrics() |
| Modifier and Type | Method and Description |
|---|---|
long |
avgExecutionTime() |
void |
avgExecutionTime(long avgExecTm) |
long |
avgWaitingTime() |
void |
avgWaitingTime(long avgWaitingTm) |
long |
executed() |
void |
executed(long executed) |
boolean |
executing() |
void |
executing(boolean executing) |
int |
failures() |
void |
failures(int failures) |
int |
failuresFrequency() |
void |
failuresFrequency(int failuresFreq) |
static VisorStreamerStageMetrics |
from(StreamerStageMetrics m)
Create data transfer object for given metrics.
|
long |
maxExecutionTime() |
void |
maxExecutionTime(long maxExecTm) |
long |
maxWaitingTime() |
void |
maxWaitingTime(long maxWaitingTm) |
long |
minExecutionTime() |
void |
minExecutionTime(long minExecTm) |
long |
minWaitingTime() |
void |
minWaitingTime(long minWaitingTm) |
String |
name() |
void |
name(String name) |
static Collection<VisorStreamerStageMetrics> |
stages(IgniteStreamer streamer)
Create data transfer objects for all stages.
|
long |
throughput() |
void |
throughput(long throughput) |
String |
toString() |
public static VisorStreamerStageMetrics from(StreamerStageMetrics m)
public static Collection<VisorStreamerStageMetrics> stages(IgniteStreamer streamer)
public String name()
public void name(String name)
name - New stage name.public long minExecutionTime()
public void minExecutionTime(long minExecTm)
minExecTm - New minimum execution time.public long avgExecutionTime()
public void avgExecutionTime(long avgExecTm)
avgExecTm - New average execution time.public long maxExecutionTime()
public void maxExecutionTime(long maxExecTm)
maxExecTm - New maximum execution time.public long minWaitingTime()
public void minWaitingTime(long minWaitingTm)
minWaitingTm - New minimum waiting time.public long avgWaitingTime()
public void avgWaitingTime(long avgWaitingTm)
avgWaitingTm - New average waiting time.public long maxWaitingTime()
public void maxWaitingTime(long maxWaitingTm)
maxWaitingTm - New maximum waiting time.public long executed()
public void executed(long executed)
executed - New executed count.public int failures()
public void failures(int failures)
failures - New failures count.public boolean executing()
public void executing(boolean executing)
executing - New if executing.public long throughput()
public void throughput(long throughput)
throughput - New throughput.public int failuresFrequency()
public void failuresFrequency(int failuresFreq)
failuresFreq - New failures frequency.
Follow @ApacheIgnite
Ignite Fabric : ver. 1.0.0-RC3 Release Date : March 24 2015