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

Modifier and Type	Method and Description
boolean	canTranslate(Pipeline pipeline)
JobGraph	translateToJobGraph(Pipeline pipeline, Configuration optimizerConfiguration, int defaultParallelism) Creates a JobGraph from the given Pipeline and attaches the given jar files and classpaths to the JobGraph.
String	translateToJSONExecutionPlan(Pipeline pipeline) Extracts the execution plan (as JSON) from the given Pipeline.

Method Detail

translateToJobGraph

JobGraph translateToJobGraph(Pipeline pipeline,
                             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(Pipeline pipeline)

Extracts the execution plan (as JSON) from the given Pipeline.

canTranslate

boolean canTranslate(Pipeline pipeline)