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 and Description
FlinkPipelineTranslationUtil()

Method Summary

Modifier and Type	Method and Description
static JobGraph	getJobGraph(Pipeline pipeline, Configuration optimizerConfiguration, int defaultParallelism) Transmogrifies the given Pipeline to a JobGraph.
static JobGraph	getJobGraphUnderUserClassLoader(ClassLoader userClassloader, Pipeline pipeline, Configuration configuration, int defaultParallelism) Transmogrifies the given Pipeline under the userClassloader to a JobGraph.
static String	translateToJSONExecutionPlan(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 JobGraph getJobGraph(Pipeline pipeline,
                                   Configuration optimizerConfiguration,
                                   int defaultParallelism)

Transmogrifies the given Pipeline to a JobGraph.

getJobGraphUnderUserClassLoader

public static JobGraph getJobGraphUnderUserClassLoader(ClassLoader userClassloader,
                                                       Pipeline pipeline,
                                                       Configuration configuration,
                                                       int defaultParallelism)

Transmogrifies the given Pipeline under the userClassloader to a JobGraph.

translateToJSONExecutionPlan

public static String translateToJSONExecutionPlan(Pipeline pipeline)

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