Package org.apache.flink.connector.testframe.utils

Class MetricQuerier

java.lang.Object

org.apache.flink.connector.testframe.utils.MetricQuerier

public class MetricQuerier
extends Object

The querier used to get job metrics by rest API.

Constructor Summary

Constructors

Constructor	Description
MetricQuerier(Configuration configuration)

Method Summary

Modifier and Type	Method	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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MetricQuerier

public MetricQuerier(Configuration configuration)
              throws ConfigurationException

Throws:

ConfigurationException

Method Detail

getJobDetails

public static JobDetailsInfo getJobDetails(RestClient client,
                                           TestEnvironment.Endpoint endpoint,
                                           JobID jobId)
                                    throws Exception

Throws:

Exception

getMetricList

public AggregatedMetricsResponseBody getMetricList(TestEnvironment.Endpoint endpoint,
                                                   JobID jobId,
                                                   JobVertexID vertexId)
                                            throws Exception

Throws:

Exception

getMetrics

public AggregatedMetricsResponseBody getMetrics(TestEnvironment.Endpoint endpoint,
                                                JobID jobId,
                                                JobVertexID vertexId,
                                                String filters)
                                         throws Exception

Throws:

Exception

getAggregatedMetricsByRestAPI

public Double getAggregatedMetricsByRestAPI(TestEnvironment.Endpoint endpoint,
                                            JobID jobId,
                                            String sourceOrSinkName,
                                            String metricName,
                                            String filter)
                                     throws Exception

Throws:

Exception