Package org.apache.beam.runners.flink

Class FlinkPortableRunnerResult

java.lang.Object

org.apache.beam.runners.flink.FlinkRunnerResult

org.apache.beam.runners.flink.FlinkPortableRunnerResult

All Implemented Interfaces:

PortablePipelineResult, PipelineResult

public class FlinkPortableRunnerResult
extends FlinkRunnerResult
implements PortablePipelineResult

Result of executing a portable Pipeline with Flink.

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 class org.apache.beam.runners.flink.FlinkRunnerResult

cancel, getState, metrics, toString, waitUntilFinish, waitUntilFinish

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

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

cancel, getState, metrics, waitUntilFinish, waitUntilFinish

Method Details

portableMetrics

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

Description copied from interface: PortablePipelineResult

Returns the object to access monitoring infos from the pipeline.

Specified by:

portableMetrics in interface PortablePipelineResult

Throws:

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