public class MetricQuerier extends Object
Constructor and Description |
---|
MetricQuerier(Configuration configuration) |
Modifier and Type | Method and Description |
---|---|
Double |
getAggregatedMetricsByRestAPI(TestEnvironment.Endpoint endpoint,
JobID jobId,
String sourceOrSinkName,
String metricName,
String filter) |
static JobDetailsInfo |
getJobDetails(RestClient client,
TestEnvironment.Endpoint endpoint,
JobID jobId) |
AggregatedMetricsResponseBody |
getMetricList(TestEnvironment.Endpoint endpoint,
JobID jobId,
JobVertexID vertexId) |
AggregatedMetricsResponseBody |
getMetrics(TestEnvironment.Endpoint endpoint,
JobID jobId,
JobVertexID vertexId,
String filters) |
public MetricQuerier(Configuration configuration) throws ConfigurationException
ConfigurationException
public static JobDetailsInfo getJobDetails(RestClient client, TestEnvironment.Endpoint endpoint, JobID jobId) throws Exception
Exception
public AggregatedMetricsResponseBody getMetricList(TestEnvironment.Endpoint endpoint, JobID jobId, JobVertexID vertexId) throws Exception
Exception
public AggregatedMetricsResponseBody getMetrics(TestEnvironment.Endpoint endpoint, JobID jobId, JobVertexID vertexId, String filters) throws Exception
Exception
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.