public static class DirectRunner.DirectPipelineResult extends java.lang.Object implements PipelineResult
Pipeline
with the DirectRunner
.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.
|
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 MetricResults metrics()
PipelineResult
metrics
in interface PipelineResult
public PipelineResult.State waitUntilFinish()
If the pipeline terminates abnormally by throwing an Exception
, this will rethrow
the original Exception
. Future calls to getState()
will return PipelineResult.State.FAILED
.
waitUntilFinish
in interface PipelineResult
public PipelineResult.State cancel()
PipelineResult
cancel
in interface PipelineResult
public PipelineResult.State waitUntilFinish(Duration duration)
If the pipeline terminates abnormally by throwing an Exception
, this will rethrow
the original Exception
. Future calls to getState()
will return PipelineResult.State.FAILED
.
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.