Package org.apache.beam.runners.flink

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)