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(org.apache.flink.configuration.Configuration configuration)

Method Summary

Modifier and Type	Method	Description
Double	getAggregatedMetricsByRestAPI(TestEnvironment.Endpoint endpoint, org.apache.flink.api.common.JobID jobId, String sourceOrSinkName, String metricName, String filter)
static org.apache.flink.runtime.rest.messages.job.JobDetailsInfo	getJobDetails(org.apache.flink.runtime.rest.RestClient client, TestEnvironment.Endpoint endpoint, org.apache.flink.api.common.JobID jobId)
org.apache.flink.runtime.rest.messages.job.metrics.AggregatedMetricsResponseBody	getMetricList(TestEnvironment.Endpoint endpoint, org.apache.flink.api.common.JobID jobId, org.apache.flink.runtime.jobgraph.JobVertexID vertexId)
org.apache.flink.runtime.rest.messages.job.metrics.AggregatedMetricsResponseBody	getMetrics(TestEnvironment.Endpoint endpoint, org.apache.flink.api.common.JobID jobId, org.apache.flink.runtime.jobgraph.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(org.apache.flink.configuration.Configuration configuration)
              throws org.apache.flink.util.ConfigurationException

Throws:

org.apache.flink.util.ConfigurationException

Method Detail

getJobDetails

public static org.apache.flink.runtime.rest.messages.job.JobDetailsInfo getJobDetails(org.apache.flink.runtime.rest.RestClient client,
                                                                                      TestEnvironment.Endpoint endpoint,
                                                                                      org.apache.flink.api.common.JobID jobId)
                                                                               throws Exception

Throws:

Exception

getMetricList

public org.apache.flink.runtime.rest.messages.job.metrics.AggregatedMetricsResponseBody getMetricList(TestEnvironment.Endpoint endpoint,
                                                                                                      org.apache.flink.api.common.JobID jobId,
                                                                                                      org.apache.flink.runtime.jobgraph.JobVertexID vertexId)
                                                                                               throws Exception

Throws:

Exception

getMetrics

public org.apache.flink.runtime.rest.messages.job.metrics.AggregatedMetricsResponseBody getMetrics(TestEnvironment.Endpoint endpoint,
                                                                                                   org.apache.flink.api.common.JobID jobId,
                                                                                                   org.apache.flink.runtime.jobgraph.JobVertexID vertexId,
                                                                                                   String filters)
                                                                                            throws Exception

Throws:

Exception

getAggregatedMetricsByRestAPI

public Double getAggregatedMetricsByRestAPI(TestEnvironment.Endpoint endpoint,
                                            org.apache.flink.api.common.JobID jobId,
                                            String sourceOrSinkName,
                                            String metricName,
                                            String filter)
                                     throws Exception

Throws:

Exception