Package org.apache.flink.client

Interface FlinkPipelineTranslator

  • All Known Implementing Classes:
    PlanTranslator, StreamGraphTranslator
    public interface FlinkPipelineTranslator
    This can be used to turn a Pipeline into a JobGraph. There will be implementations for the different pipeline APIs that Flink supports.

    • Method Summary

      All Methods Instance Methods Abstract Methods 
      Modifier and Type Method Description
      boolean canTranslate​(org.apache.flink.api.dag.Pipeline pipeline)  
      org.apache.flink.runtime.jobgraph.JobGraph translateToJobGraph​(org.apache.flink.api.dag.Pipeline pipeline, org.apache.flink.configuration.Configuration optimizerConfiguration, int defaultParallelism)
      Creates a JobGraph from the given Pipeline and attaches the given jar files and classpaths to the JobGraph.
      String translateToJSONExecutionPlan​(org.apache.flink.api.dag.Pipeline pipeline)
      Extracts the execution plan (as JSON) from the given Pipeline.

    • Method Detail

      • translateToJobGraph

        org.apache.flink.runtime.jobgraph.JobGraph translateToJobGraph​(org.apache.flink.api.dag.Pipeline pipeline,
                                                               org.apache.flink.configuration.Configuration optimizerConfiguration,
                                                               int defaultParallelism)
        Creates a JobGraph from the given Pipeline and attaches the given jar files and classpaths to the JobGraph.

      • translateToJSONExecutionPlan

        String translateToJSONExecutionPlan​(org.apache.flink.api.dag.Pipeline pipeline)
        Extracts the execution plan (as JSON) from the given Pipeline.

      • canTranslate

        boolean canTranslate​(org.apache.flink.api.dag.Pipeline pipeline)