Package org.apache.flink.client

Class FlinkPipelineTranslationUtil

java.lang.Object

org.apache.flink.client.FlinkPipelineTranslationUtil

public final class FlinkPipelineTranslationUtil
extends Object

Utility for transforming FlinkPipelines into a JobGraph. This uses reflection or service discovery to find the right FlinkPipelineTranslator for a given subclass of Pipeline.

Constructor Summary

Constructors

Constructor	Description
FlinkPipelineTranslationUtil()

Method Summary

Modifier and Type	Method	Description
static org.apache.flink.runtime.jobgraph.JobGraph	getJobGraph(ClassLoader userClassloader, org.apache.flink.api.dag.Pipeline pipeline, org.apache.flink.configuration.Configuration optimizerConfiguration, int defaultParallelism)	Transmogrifies the given Pipeline to a JobGraph.
static org.apache.flink.runtime.jobgraph.JobGraph	getJobGraphUnderUserClassLoader(ClassLoader userClassloader, org.apache.flink.api.dag.Pipeline pipeline, org.apache.flink.configuration.Configuration configuration, int defaultParallelism)	Transmogrifies the given Pipeline under the userClassloader to a JobGraph.
static String	translateToJSONExecutionPlan(ClassLoader userClassloader, org.apache.flink.api.dag.Pipeline pipeline)	Extracts the execution plan (as JSON) from the given Pipeline.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

FlinkPipelineTranslationUtil

public FlinkPipelineTranslationUtil()

Method Detail

getJobGraph

public static org.apache.flink.runtime.jobgraph.JobGraph getJobGraph(ClassLoader userClassloader,
                                                                     org.apache.flink.api.dag.Pipeline pipeline,
                                                                     org.apache.flink.configuration.Configuration optimizerConfiguration,
                                                                     int defaultParallelism)

Transmogrifies the given Pipeline to a JobGraph.

getJobGraphUnderUserClassLoader

public static org.apache.flink.runtime.jobgraph.JobGraph getJobGraphUnderUserClassLoader(ClassLoader userClassloader,
                                                                                         org.apache.flink.api.dag.Pipeline pipeline,
                                                                                         org.apache.flink.configuration.Configuration configuration,
                                                                                         int defaultParallelism)

Transmogrifies the given Pipeline under the userClassloader to a JobGraph.

translateToJSONExecutionPlan

public static String translateToJSONExecutionPlan(ClassLoader userClassloader,
                                                  org.apache.flink.api.dag.Pipeline pipeline)

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