org.apache.beam.runners.fnexecution.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 and 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 Detail

portableMetrics

@Experimental(value=METRICS)
org.apache.beam.model.jobmanagement.v1.JobApi.MetricResults portableMetrics()
                                                                                                  throws java.lang.UnsupportedOperationException

Returns the object to access monitoring infos from the pipeline.

Throws:

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