Package org.apache.beam.runners.jobsubmission

Interface PortablePipelineResult

All Superinterfaces:

PipelineResult

All Known Implementing Classes:

FlinkPortableRunnerResult

public interface PortablePipelineResult
extends PipelineResult

Result of a portable PortablePipelineRunner.run(RunnerApi.Pipeline, JobInfo).

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.beam.sdk.PipelineResult

PipelineResult.State

Method Summary

Modifier and Type	Method	Description
org.apache.beam.model.jobmanagement.v1.JobApi.MetricResults	portableMetrics()	Returns the object to access monitoring infos from the pipeline.

Methods inherited from interface org.apache.beam.sdk.PipelineResult

cancel, getState, metrics, waitUntilFinish, waitUntilFinish

Method Details

portableMetrics

org.apache.beam.model.jobmanagement.v1.JobApi.MetricResults portableMetrics()
                                                                     throws UnsupportedOperationException

Returns the object to access monitoring infos from the pipeline.

Throws:

UnsupportedOperationException - if the runner doesn't support retrieving metrics.