Package | Description |
---|---|
org.apache.flink.connector.testframe.environment | |
org.apache.flink.connector.testframe.utils | |
org.apache.flink.tests.util.flink |
Modifier and Type | Method and Description |
---|---|
TestEnvironment.Endpoint |
TestEnvironment.getRestEndpoint()
Get endpoint of the test environment for connecting via REST API.
|
TestEnvironment.Endpoint |
MiniClusterTestEnvironment.getRestEndpoint() |
Modifier and Type | Method and Description |
---|---|
Double |
MetricQuerier.getAggregatedMetricsByRestAPI(TestEnvironment.Endpoint endpoint,
JobID jobId,
String sourceOrSinkName,
String metricName,
String filter) |
static JobDetailsInfo |
MetricQuerier.getJobDetails(RestClient client,
TestEnvironment.Endpoint endpoint,
JobID jobId) |
AggregatedMetricsResponseBody |
MetricQuerier.getMetricList(TestEnvironment.Endpoint endpoint,
JobID jobId,
JobVertexID vertexId) |
AggregatedMetricsResponseBody |
MetricQuerier.getMetrics(TestEnvironment.Endpoint endpoint,
JobID jobId,
JobVertexID vertexId,
String filters) |
Modifier and Type | Method and Description |
---|---|
TestEnvironment.Endpoint |
FlinkContainerTestEnvironment.getRestEndpoint() |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.