Package org.apache.beam.runners.flink
Interface FlinkPortablePipelineTranslator.TranslationContext
- All Known Implementing Classes:
FlinkBatchPortablePipelineTranslator.BatchTranslationContext
,FlinkStreamingPortablePipelineTranslator.StreamingTranslationContext
- Enclosing interface:
FlinkPortablePipelineTranslator<T extends FlinkPortablePipelineTranslator.TranslationContext>
public static interface FlinkPortablePipelineTranslator.TranslationContext
The context used for pipeline translation.
-
Method Summary
-
Method Details
-
getJobInfo
JobInfo getJobInfo() -
getPipelineOptions
FlinkPipelineOptions getPipelineOptions()
-