Package com.streambase.sb.monitor
Class ModuleInfo.QueueInfo
- java.lang.Object
-
- com.streambase.sb.monitor.ModuleInfo.QueueInfo
-
- All Implemented Interfaces:
Cloneable
- Enclosing class:
- ModuleInfo
public static class ModuleInfo.QueueInfo extends Object implements Cloneable
Information about a Queue between modules or containers.
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Object
clone()
boolean
equals(Object obj)
int
getBatchLatency()
Return a moving average of the time (microseconds) for a batch of tuples to traverse the queueint
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 tuplesint
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.long
getQueueLatencyDelta()
Returns the number of tuples dequeued from this queue since the previous Snapshot.long
getTotalQueueLatency()
Return the total amount of time, in microseconds, tuples spent on this queue before before being dequeued.int
getTotalTuplesDequeued()
Return the total number of tuples dequeued from this queue.long
getTuplesDequeuedDelta()
Returns the number of tuples dequeued from this queue since the previous Snapshot.int
hashCode()
String
toString()
-
-
-
Method Detail
-
getMaxQueueLength
public int getMaxQueueLength()
Return the maximum numbers of tuples that this queue has ever seen.- Returns:
- maximum number of tuples that this queue can contain
-
getCurrentQueueLength
public int getCurrentQueueLength()
Return the approximate number of tuples currently in this queue. This number is approximate since there can be multiple threads accessing the queue at the same time.- Returns:
- the approximate number of tuples currently in the queue
-
getBatchProcessingTime
public int getBatchProcessingTime()
Return the a moving average of the amount of time (microseconds) that it takes to process a batch of tuples.- Returns:
- amount of time (microseconds) that it takes to process a batch of tuples
- Since:
- 6.3.10
-
getBatchLatency
public int getBatchLatency()
Return a moving average of the time (microseconds) for a batch of tuples to traverse the queue- Returns:
- amount of time (microseconds) for a batch of tuples to traverse the queue
- Since:
- 6.3.10
-
getBatchSize
public long getBatchSize()
Return a moving average of the size of a batch of tuples- Returns:
- Return a moving average of the size of a batch of tuples
- Since:
- 6.6.13
-
getTotalTuplesDequeued
public int getTotalTuplesDequeued()
Return the total number of tuples dequeued from this queue.- Returns:
- Total number of tuples dequeued.
- Since:
- 11.0.0
-
getTotalQueueLatency
public long getTotalQueueLatency()
Return the total amount of time, in microseconds, tuples spent on this queue before before being dequeued.- Returns:
- Total microseconds of tuple queued time.
- Since:
- 11.0.0
-
getTuplesDequeuedDelta
public long getTuplesDequeuedDelta()
Returns the number of tuples dequeued from this queue since the previous Snapshot.- Returns:
- number of output tuples dequeued.
- Since:
- 11.0.0
-
getQueueLatencyDelta
public long getQueueLatencyDelta()
Returns the number of tuples dequeued from this queue since the previous Snapshot.- Returns:
- number of output tuples dequeued.
- Since:
- 11.0.0
-
getName
public String getName()
Return the name of this queue. For queues between modules the name will be the name of the stream that is being enqueued into. For queues between containers the name will be the name of the container connection.- Returns:
- the name of this queue
-
-