Interface FlinkStreamingPortablePipelineTranslator.PTransformTranslator<T>

Enclosing class:
FlinkStreamingPortablePipelineTranslator

public static interface FlinkStreamingPortablePipelineTranslator.PTransformTranslator<T>
  • Method Summary

    Modifier and Type
    Method
    Description
    void
    translate(String id, org.apache.beam.model.pipeline.v1.RunnerApi.Pipeline pipeline, T t)
     
  • Method Details

    • translate

      void translate(String id, org.apache.beam.model.pipeline.v1.RunnerApi.Pipeline pipeline, T t)