public static class ModuleInfo.QueueInfo extends Object implements Cloneable
Modifier and Type | Field and Description |
---|---|
(package private) long |
batchLatency |
(package private) long |
batchProcessingTime |
(package private) long |
batchSize |
(package private) long |
currentQueueLength |
(package private) long |
maxQueueLength |
(package private) String |
queueName |
Modifier and Type | Method and Description |
---|---|
(package private) void |
clear() |
Object |
clone() |
boolean |
equals(Object obj) |
int |
getBatchLatency()
Return a moving average of the time (microseconds) for a batch of tuples to traverse the queue
|
int |
getBatchProcessingTime()
Return the a moving average of the amount of time (microseconds) that it takes
to process a batch of tuples.
|
long |
getBatchSize()
Return a moving average of the size of a batch of tuples
|
int |
getCurrentQueueLength()
Return the approximate number of tuples currently in this queue.
|
int |
getMaxQueueLength()
Return the maximum numbers of tuples that this queue
has ever seen.
|
String |
getName()
Return the name of this queue.
|
int |
hashCode() |
String |
toString() |
final String queueName
long maxQueueLength
long currentQueueLength
long batchProcessingTime
long batchLatency
long batchSize
QueueInfo(String queueName)
public int getMaxQueueLength()
public int getCurrentQueueLength()
public int getBatchProcessingTime()
public int getBatchLatency()
public long getBatchSize()
public String getName()
void clear()
Copyright © 2015–2018 Cloud Software Group, Inc.. All rights reserved.