public class FlinkRunnerResult extends java.lang.Object implements PipelineResult
Pipeline
with Flink. This has methods to query
to job runtime and the final values of the accumulators.PipelineResult.State
Modifier and Type | Method and Description |
---|---|
PipelineResult.State |
cancel()
Cancels the pipeline execution.
|
PipelineResult.State |
getState()
Retrieves the current state of the pipeline execution.
|
MetricResults |
metrics()
Returns the object to access metrics from the pipeline.
|
java.lang.String |
toString() |
PipelineResult.State |
waitUntilFinish()
Waits until the pipeline finishes and returns the final status.
|
PipelineResult.State |
waitUntilFinish(Duration duration)
Waits until the pipeline finishes and returns the final status.
|
public PipelineResult.State getState()
PipelineResult
getState
in interface PipelineResult
PipelineResult.State
representing the state of this pipeline.public java.lang.String toString()
toString
in class java.lang.Object
public PipelineResult.State cancel()
PipelineResult
cancel
in interface PipelineResult
public PipelineResult.State waitUntilFinish()
PipelineResult
waitUntilFinish
in interface PipelineResult
public PipelineResult.State waitUntilFinish(Duration duration)
PipelineResult
waitUntilFinish
in interface PipelineResult
duration
- The time to wait for the pipeline to finish. Provide a value less than 1 ms for
an infinite wait.public MetricResults metrics()
PipelineResult
metrics
in interface PipelineResult