org.apache.paimon.benchmark.metric

Class FlinkRestClient

java.lang.Object

org.apache.paimon.benchmark.metric.FlinkRestClient

public class FlinkRestClient
extends Object

A HTTP client to request BPS metric to JobMaster REST API.

Constructor Summary

Constructors

Constructor and Description
FlinkRestClient(String jmAddress, int jmPort)

Method Summary

Modifier and Type	Method and Description
void	cancelJob(String jobId)
void	close()
Long	getDataFreshness(String jobId)
double	getNumRecordsPerSecond(String jobId, String vertexId)
double	getSourceMetric(String jobId, String vertexId, String metric)
String	getSourceVertexId(String jobId)
double	getTotalNumRecords(String jobId, String vertexId)
boolean	isJobRunning(String jobId)
void	stopJobWithSavepoint(String jobId, String savepointPath)
long	waitUntilJobFinished(String jobId)
void	waitUntilNumberOfRows(String jobId, long numberOfRows)

Methods inherited from class java.lang.Object

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

Constructor Detail

FlinkRestClient

public FlinkRestClient(String jmAddress,
                       int jmPort)

Method Detail

cancelJob

public void cancelJob(String jobId)

stopJobWithSavepoint

public void stopJobWithSavepoint(String jobId,
                                 String savepointPath)

isJobRunning

public boolean isJobRunning(String jobId)

waitUntilNumberOfRows

public void waitUntilNumberOfRows(String jobId,
                                  long numberOfRows)
                           throws InterruptedException

Throws:

InterruptedException

waitUntilJobFinished

public long waitUntilJobFinished(String jobId)
                          throws InterruptedException

Throws:

InterruptedException

getSourceVertexId

public String getSourceVertexId(String jobId)

getDataFreshness

@Nullable
public Long getDataFreshness(String jobId)

getNumRecordsPerSecond

public double getNumRecordsPerSecond(String jobId,
                                     String vertexId)

getTotalNumRecords

public double getTotalNumRecords(String jobId,
                                 String vertexId)

getSourceMetric

public double getSourceMetric(String jobId,
                              String vertexId,
                              String metric)

close

public void close()