Uses of Class
org.apache.flink.connector.testframe.environment.TestEnvironment.Endpoint

Packages that use TestEnvironment.Endpoint

Package	Description
org.apache.flink.connector.testframe.container
org.apache.flink.connector.testframe.environment
org.apache.flink.connector.testframe.utils

Uses of TestEnvironment.Endpoint in org.apache.flink.connector.testframe.container

Methods in org.apache.flink.connector.testframe.container that return TestEnvironment.Endpoint

Modifier and Type	Method	Description
TestEnvironment.Endpoint	FlinkContainerTestEnvironment.getRestEndpoint()

Uses of TestEnvironment.Endpoint in org.apache.flink.connector.testframe.environment

Methods in org.apache.flink.connector.testframe.environment that return TestEnvironment.Endpoint

Modifier and Type	Method	Description
TestEnvironment.Endpoint	MiniClusterTestEnvironment.getRestEndpoint()
TestEnvironment.Endpoint	TestEnvironment.getRestEndpoint()	Get endpoint of the test environment for connecting via REST API.

Uses of TestEnvironment.Endpoint in org.apache.flink.connector.testframe.utils

Methods in org.apache.flink.connector.testframe.utils with parameters of type TestEnvironment.Endpoint

Modifier and Type	Method	Description
Double	MetricQuerier.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	MetricQuerier.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	MetricQuerier.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	MetricQuerier.getMetrics(TestEnvironment.Endpoint endpoint, org.apache.flink.api.common.JobID jobId, org.apache.flink.runtime.jobgraph.JobVertexID vertexId, String filters)