public class LoadMetricsServer extends HttpForwardingMetricsServer
A metrics server that records and reports metrics for a set of running topologies.
| Modifier and Type | Class and Description |
|---|---|
static class |
LoadMetricsServer.Measurements |
| Modifier and Type | Field and Description |
|---|---|
static long |
DEFAULT_REPORT_INTERVAL |
static long |
DEFAULT_WINDOW_INTERVAL |
| Modifier and Type | Method and Description |
|---|---|
static void |
addCommandLineOptions(org.apache.commons.cli.Options options)
Add Command line options for configuring the output of this.
|
void |
handle(IMetricsConsumer.TaskInfo taskInfo,
Collection<IMetricsConsumer.DataPoint> dataPoints,
String topologyId) |
void |
monitorFor(double execTimeMins,
Nimbus.Iface client,
Collection<String> topoNames)
Monitor the list of topologies for the given time frame.
|
getPort, getUrl, serve, servepublic static final long DEFAULT_REPORT_INTERVAL
public static final long DEFAULT_WINDOW_INTERVAL
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 updatepublic 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 forclient - the client to use when monitoringtopoNames - the names of the topologies to monitorException - on any errorpublic void handle(IMetricsConsumer.TaskInfo taskInfo, Collection<IMetricsConsumer.DataPoint> dataPoints, String topologyId)
handle in class HttpForwardingMetricsServerCopyright © 2021 The Apache Software Foundation. All rights reserved.