public class MetricReporter extends Object
Constructor and Description |
---|
MetricReporter(FlinkRestClient flinkRestClient,
CpuMetricReceiver cpuMetricReceiver,
java.time.Duration monitorDelay,
java.time.Duration monitorInterval,
long monitorRowNumber) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
JobBenchmarkMetric |
reportMetric(String name,
String jobId) |
public MetricReporter(FlinkRestClient flinkRestClient, CpuMetricReceiver cpuMetricReceiver, java.time.Duration monitorDelay, java.time.Duration monitorInterval, long monitorRowNumber)
public JobBenchmarkMetric reportMetric(String name, String jobId) throws InterruptedException
InterruptedException
public void close()
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.