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() 
 -