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:

  • Field Details

    • isActive

      boolean isActive
      Is active?

  • Constructor Details

    • ModuleInfo

      ModuleInfo(String name)
      Constructor
      Parameters:
      name - Module name

  • Method Details

    • extractInfo

      void extractInfo(com.streambase.sb.monitor.StatTuplev3 st)
      extract module info from the StatTuple, setting member data as appropriate
      Parameters:
      st - Statistics tuple

    • 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)

    • extractInfo

      void extractInfo(StatTuple st)
      extract module info from the StatTuple, setting member data as appropriate
      Parameters:
      st - Statistics tuple

    • 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

    • saveForNextCycle

      void saveForNextCycle()
      Save module information

    • 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

    • prettyPrint

      void prettyPrint()
      Pretty-print a module info object to the standard output.

    • clear

      void clear()
      Clear (reset) module info