public class FlinkRestClient extends Object
Constructor and Description |
---|
FlinkRestClient(String jmAddress,
int jmPort) |
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) |
public FlinkRestClient(String jmAddress, int jmPort)
public void cancelJob(String jobId)
public boolean isJobRunning(String jobId)
public void waitUntilNumberOfRows(String jobId, long numberOfRows) throws InterruptedException
InterruptedException
public long waitUntilJobFinished(String jobId) throws InterruptedException
InterruptedException
public void close()
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.