public class ApexRunnerResult extends java.lang.Object implements PipelineResult
Pipeline
with Apex in embedded mode.PipelineResult.State
Constructor and Description |
---|
ApexRunnerResult(com.datatorrent.api.DAG dag,
org.apache.apex.api.Launcher.AppHandle apexApp) |
Modifier and Type | Method and Description |
---|---|
PipelineResult.State |
cancel()
Cancels the pipeline execution.
|
protected void |
cleanupOnCancelOrFinish()
Opportunity for a subclass to perform cleanup, such as removing temporary files.
|
com.datatorrent.api.DAG |
getApexDAG()
Return the DAG executed by the pipeline.
|
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 ApexRunnerResult(com.datatorrent.api.DAG dag, org.apache.apex.api.Launcher.AppHandle apexApp)
public PipelineResult.State getState()
PipelineResult
getState
in interface PipelineResult
PipelineResult.State
representing the state of this pipeline.public PipelineResult.State cancel() throws java.io.IOException
PipelineResult
cancel
in interface PipelineResult
java.io.IOException
- if there is a problem executing the cancel request.@Nullable public PipelineResult.State waitUntilFinish(@Nullable 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 PipelineResult.State waitUntilFinish()
PipelineResult
waitUntilFinish
in interface PipelineResult
public MetricResults metrics()
PipelineResult
metrics
in interface PipelineResult
public com.datatorrent.api.DAG getApexDAG()
protected void cleanupOnCancelOrFinish()