Class Snapshot


  • public class Snapshot
    extends Object
    Stores a snapshot of information from a StreamBase application. Snapshot objects are created by the StreamBaseMonitor class, and consumed by MonitorListeners. New snapshots are produced at regular intervals, depending on the period specified in the StreamBase Server's conf file.
    See Also:
    StreamBaseMonitor, MonitorListener
    • Method Detail

      • terminate

        public void terminate()
        Ask the StreamBaseMonitor to terminate at the end of the current snapshot.
        See Also:
        StreamBaseMonitor.terminate()
      • containerNames

        public Set<String> containerNames()
        Return a list of the names of the current containers
        Returns:
        list of the names of the current containers
      • getSystemInfo

        public SystemInfo getSystemInfo()
        The SystemInfo object for this snapshot.
        Returns:
        the SystemInfo object
      • getOperatorInfo

        public OperatorInfo getOperatorInfo​(String name)
        Returns information about the specified operator.
        Parameters:
        name - the operator name
        Returns:
        the requested OperatorInfo object
      • getDecisionTableInfo

        public DecisionTableInfo getDecisionTableInfo​(String name)
        Returns information about the specified decision table.
        Parameters:
        name - the decision table name
        Returns:
        the requested DecisionTableInfo object
      • getThreadInfo

        public ThreadInfo getThreadInfo​(String name)
        Returns information about the specified thread.
        Parameters:
        name - the thread name
        Returns:
        the requested ThreadInfo object
      • getModuleInfo

        public ModuleInfo getModuleInfo​(String name)
        Returns information about the specified module.
        Parameters:
        name - the module name
        Returns:
        the requested ModuleInfo object
      • getStreamInfo

        public StreamInfo getStreamInfo​(String name)
        Returns information about the specified stream.
        Parameters:
        name - the stream name
        Returns:
        the requested StreamInfo object
      • getTimestamp

        public Timestamp getTimestamp()
        Return the time when this snapshot was taken. It is the timestamp of the first tuple of this snapshot.
        Returns:
        timestamp of whhen this snapshot was taken
      • reset

        protected void reset()
        Reset snapshot