org.apache.beam.runners.flink

Interface FlinkPortablePipelineTranslator.Executor

All Known Implementing Classes:

FlinkBatchPortablePipelineTranslator.BatchTranslationContext, FlinkStreamingPortablePipelineTranslator.StreamingTranslationContext

Enclosing interface:

FlinkPortablePipelineTranslator<T extends FlinkPortablePipelineTranslator.TranslationContext>

public static interface FlinkPortablePipelineTranslator.Executor

A handle used to execute a translated pipeline.

Method Summary

Modifier and Type	Method and Description
org.apache.flink.api.common.JobExecutionResult	execute(java.lang.String jobName)

Method Detail

execute

org.apache.flink.api.common.JobExecutionResult execute(java.lang.String jobName)
                                                throws java.lang.Exception

Throws:

java.lang.Exception