public interface FlinkPortablePipelineTranslator<T extends FlinkPortablePipelineTranslator.TranslationContext>
Pipeline translators will generally provide a mechanism to produce the translation contexts that they use for pipeline translation. Post translation, the translation context should contain a pipeline plan that has not yet been executed.
|Modifier and Type||Interface and Description|
The context used for pipeline translation.
void translate(T context, org.apache.beam.model.pipeline.v1.RunnerApi.Pipeline pipeline)