Package 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
    Description
    org.apache.flink.api.common.JobExecutionResult
    execute(String jobName)
     

  • Method Details