Package com.streambase.sb.monitor

Class ModuleInfo

java.lang.Object

com.streambase.sb.monitor.ModuleInfo

All Implemented Interfaces:

Cloneable

public class ModuleInfo
extends Object
implements Cloneable

Represents information about a parallel module in a StreamBase Server. Instances of this class should be retrieved from a Snapshot.

See Also:

• Snapshot

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ModuleInfo.QueueInfo	Information about a Queue between modules or containers.

Method Summary

Modifier and Type	Method	Description
Object	clone()
protected void	extractQueueInfo(String name, com.streambase.sb.monitor.StatTuplev3 st)	extract queue info from the StatTuple.
String	getName()	Returns the name of the thread.
int	getNumTasks()	Return the number of tasks on the task queue
Stream<ModuleInfo.QueueInfo>	queueInfoStream()
Collection<ModuleInfo.QueueInfo>	queues()	Return a Collection of QueueInfo's which contains information about each queue

Methods inherited from class java.lang.Object

equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

extractQueueInfo

protected void extractQueueInfo(String name,
 com.streambase.sb.monitor.StatTuplev3 st)

extract queue info from the StatTuple. It's used only by Stats v3.

Parameters:

name - queue name

st - statistics (v3)

queues

public Collection<ModuleInfo.QueueInfo> queues()

Return a Collection of QueueInfo's which contains information about each queue

Returns:

a Collection of QueueInfos

queueInfoStream

public Stream<ModuleInfo.QueueInfo> queueInfoStream()

Returns:

The queue info stream

clone

public Object clone()

Overrides:

clone in class Object

getName

public String getName()

Returns the name of the thread.

Returns:

the name of the thread

getNumTasks

public int getNumTasks()

Return the number of tasks on the task queue

Returns:

number of tasks on the task queue