Uses of Interface
org.apache.flink.api.dag.Pipeline

Packages that use Pipeline

Package	Description
org.apache.flink.api.common
org.apache.flink.client
org.apache.flink.client.deployment.application.executors
org.apache.flink.client.deployment.executors
org.apache.flink.client.program
org.apache.flink.core.execution
org.apache.flink.streaming.api.graph
org.apache.flink.table.delegation
org.apache.flink.table.executor.python
org.apache.flink.table.planner.delegation

Uses of Pipeline in org.apache.flink.api.common

Classes in org.apache.flink.api.common that implement Pipeline

Modifier and Type	Class and Description
class	Plan This class represents Flink programs, in the form of dataflow plans.

Uses of Pipeline in org.apache.flink.client

Methods in org.apache.flink.client with parameters of type Pipeline

Modifier and Type	Method and Description
boolean	PlanTranslator.canTranslate(Pipeline pipeline)
boolean	StreamGraphTranslator.canTranslate(Pipeline pipeline)
boolean	FlinkPipelineTranslator.canTranslate(Pipeline pipeline)
static JobGraph	FlinkPipelineTranslationUtil.getJobGraph(ClassLoader userClassloader, Pipeline pipeline, Configuration optimizerConfiguration, int defaultParallelism) Transmogrifies the given Pipeline to a JobGraph.
static JobGraph	FlinkPipelineTranslationUtil.getJobGraphUnderUserClassLoader(ClassLoader userClassloader, Pipeline pipeline, Configuration configuration, int defaultParallelism) Transmogrifies the given Pipeline under the userClassloader to a JobGraph.
JobGraph	PlanTranslator.translateToJobGraph(Pipeline pipeline, Configuration optimizerConfiguration, int defaultParallelism)
JobGraph	StreamGraphTranslator.translateToJobGraph(Pipeline pipeline, Configuration optimizerConfiguration, int defaultParallelism)
JobGraph	FlinkPipelineTranslator.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.
static String	FlinkPipelineTranslationUtil.translateToJSONExecutionPlan(ClassLoader userClassloader, Pipeline pipeline) Extracts the execution plan (as JSON) from the given Pipeline.
String	PlanTranslator.translateToJSONExecutionPlan(Pipeline pipeline)
String	StreamGraphTranslator.translateToJSONExecutionPlan(Pipeline pipeline)
String	FlinkPipelineTranslator.translateToJSONExecutionPlan(Pipeline pipeline) Extracts the execution plan (as JSON) from the given Pipeline.

Uses of Pipeline in org.apache.flink.client.deployment.application.executors

Methods in org.apache.flink.client.deployment.application.executors with parameters of type Pipeline

Modifier and Type	Method and Description
CompletableFuture<JobClient>	EmbeddedExecutor.execute(Pipeline pipeline, Configuration configuration, ClassLoader userCodeClassloader)

Uses of Pipeline in org.apache.flink.client.deployment.executors

Methods in org.apache.flink.client.deployment.executors with parameters of type Pipeline

Modifier and Type	Method and Description
CompletableFuture<JobClient>	AbstractJobClusterExecutor.execute(Pipeline pipeline, Configuration configuration, ClassLoader userCodeClassloader) Deprecated.
CompletableFuture<JobClient>	AbstractSessionClusterExecutor.execute(Pipeline pipeline, Configuration configuration, ClassLoader userCodeClassloader)
CompletableFuture<JobClient>	LocalExecutor.execute(Pipeline pipeline, Configuration configuration, ClassLoader userCodeClassloader)
static JobGraph	PipelineExecutorUtils.getJobGraph(Pipeline pipeline, Configuration configuration, ClassLoader userClassloader) Creates the JobGraph corresponding to the provided Pipeline.

Uses of Pipeline in org.apache.flink.client.program

Methods in org.apache.flink.client.program that return Pipeline

Modifier and Type	Method and Description
Pipeline	StreamPlanEnvironment.getPipeline()
Pipeline	OptimizerPlanEnvironment.getPipeline()
static Pipeline	PackagedProgramUtils.getPipelineFromProgram(PackagedProgram program, Configuration configuration, int parallelism, boolean suppressOutput)

Uses of Pipeline in org.apache.flink.core.execution

Methods in org.apache.flink.core.execution with parameters of type Pipeline

Modifier and Type	Method and Description
CompletableFuture<JobClient>	PipelineExecutor.execute(Pipeline pipeline, Configuration configuration, ClassLoader userCodeClassloader) Executes a Pipeline based on the provided configuration and returns a JobClient which allows to interact with the job being executed, e.g.

Uses of Pipeline in org.apache.flink.streaming.api.graph

Classes in org.apache.flink.streaming.api.graph that implement Pipeline

Modifier and Type	Class and Description
class	StreamGraph Class representing the streaming topology.

Uses of Pipeline in org.apache.flink.table.delegation

Methods in org.apache.flink.table.delegation that return Pipeline

Modifier and Type	Method and Description
Pipeline	Executor.createPipeline(List<Transformation<?>> transformations, ReadableConfig tableConfiguration, String defaultJobName) Translates the given transformations to a Pipeline.

Methods in org.apache.flink.table.delegation with parameters of type Pipeline

Modifier and Type	Method and Description
JobExecutionResult	Executor.execute(Pipeline pipeline) Executes the given pipeline.
JobClient	Executor.executeAsync(Pipeline pipeline) Executes the given pipeline asynchronously.

Uses of Pipeline in org.apache.flink.table.executor.python

Methods in org.apache.flink.table.executor.python that return Pipeline

Modifier and Type	Method and Description
Pipeline	ChainingOptimizingExecutor.createPipeline(List<Transformation<?>> transformations, ReadableConfig configuration, String defaultJobName)

Methods in org.apache.flink.table.executor.python with parameters of type Pipeline

Modifier and Type	Method and Description
JobExecutionResult	ChainingOptimizingExecutor.execute(Pipeline pipeline)
JobClient	ChainingOptimizingExecutor.executeAsync(Pipeline pipeline)

Uses of Pipeline in org.apache.flink.table.planner.delegation

Methods in org.apache.flink.table.planner.delegation that return Pipeline

Modifier and Type	Method and Description
Pipeline	DefaultExecutor.createPipeline(List<Transformation<?>> transformations, ReadableConfig tableConfiguration, String defaultJobName)

Methods in org.apache.flink.table.planner.delegation with parameters of type Pipeline

Modifier and Type	Method and Description
JobExecutionResult	DefaultExecutor.execute(Pipeline pipeline)
JobClient	DefaultExecutor.executeAsync(Pipeline pipeline)