Package org.apache.flink.client.deployment.application.executors

Class EmbeddedExecutor

java.lang.Object

org.apache.flink.client.deployment.application.executors.EmbeddedExecutor

All Implemented Interfaces:

org.apache.flink.core.execution.PipelineExecutor

@Internal
public class EmbeddedExecutor
extends Object
implements org.apache.flink.core.execution.PipelineExecutor

A base class for executors that invoke directly methods of the Dispatcher and do not go through the REST API.

Field Summary

Fields

Modifier and Type	Field	Description
static String	NAME

Constructor Summary

Constructors

Constructor	Description
EmbeddedExecutor(Collection<org.apache.flink.api.common.JobID> submittedJobIds, org.apache.flink.runtime.dispatcher.DispatcherGateway dispatcherGateway, org.apache.flink.configuration.Configuration configuration, EmbeddedJobClientCreator jobClientCreator)	Creates a EmbeddedExecutor.

Method Summary

Modifier and Type	Method	Description
CompletableFuture<org.apache.flink.core.execution.JobClient>	execute(org.apache.flink.api.dag.Pipeline pipeline, org.apache.flink.configuration.Configuration configuration, ClassLoader userCodeClassloader)

Methods inherited from class java.lang.Object

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

Field Detail

NAME

public static final String NAME

See Also:

Constant Field Values

Constructor Detail

EmbeddedExecutor

public EmbeddedExecutor(Collection<org.apache.flink.api.common.JobID> submittedJobIds,
                        org.apache.flink.runtime.dispatcher.DispatcherGateway dispatcherGateway,
                        org.apache.flink.configuration.Configuration configuration,
                        EmbeddedJobClientCreator jobClientCreator)

Creates a EmbeddedExecutor.

Parameters:

submittedJobIds - a list that is going to be filled with the job ids of the new jobs that will be submitted. This is essentially used to return the submitted job ids to the caller.

dispatcherGateway - the dispatcher of the cluster which is going to be used to submit jobs.

configuration - the flink application configuration

jobClientCreator - the job client creator

Method Detail

execute

public CompletableFuture<org.apache.flink.core.execution.JobClient> execute(org.apache.flink.api.dag.Pipeline pipeline,
                                                                            org.apache.flink.configuration.Configuration configuration,
                                                                            ClassLoader userCodeClassloader)
                                                                     throws Exception

Specified by:

execute in interface org.apache.flink.core.execution.PipelineExecutor

Throws:

Exception