Class LoadMetricsServer

public class LoadMetricsServer extends HttpForwardingMetricsServer
A metrics server that records and reports metrics for a set of running topologies.
  • Field Details


      public static final long DEFAULT_REPORT_INTERVAL
      See Also:

      public static final long DEFAULT_WINDOW_INTERVAL
      See Also:
  • Method Details

    • addCommandLineOptions

      public static void addCommandLineOptions(org.apache.commons.cli.Options options)
      Add Command line options for configuring the output of this.
      options - command line options to update
    • monitorFor

      public void monitorFor(double execTimeMins, Nimbus.Iface client, Collection<String> topoNames) throws Exception
      Monitor the list of topologies for the given time frame.
      execTimeMins - how long to monitor for
      client - the client to use when monitoring
      topoNames - the names of the topologies to monitor
      Exception - on any error
    • handle

      public void handle(IMetricsConsumer.TaskInfo taskInfo, Collection<IMetricsConsumer.DataPoint> dataPoints, String topologyId)
      Specified by:
      handle in class HttpForwardingMetricsServer