org.apache.paimon.benchmark.metric

Class MetricReporter

java.lang.Object

org.apache.paimon.benchmark.metric.MetricReporter

public class MetricReporter
extends Object

A reporter to aggregate metrics and report summary results.

Constructor Summary

Constructors

Constructor and Description
MetricReporter(FlinkRestClient flinkRestClient, CpuMetricReceiver cpuMetricReceiver, java.time.Duration monitorDelay, java.time.Duration monitorInterval, long monitorRowNumber)

Method Summary

Modifier and Type	Method and Description
void	close()
JobBenchmarkMetric	reportMetric(String name, String jobId)

Methods inherited from class java.lang.Object

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

Constructor Detail

MetricReporter

public MetricReporter(FlinkRestClient flinkRestClient,
                      CpuMetricReceiver cpuMetricReceiver,
                      java.time.Duration monitorDelay,
                      java.time.Duration monitorInterval,
                      long monitorRowNumber)

Method Detail

reportMetric

public JobBenchmarkMetric reportMetric(String name,
                                       String jobId)
                                throws InterruptedException

Throws:

InterruptedException

close

public void close()