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

类 EmbeddedExecutor

java.lang.Object

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

所有已实现的接口:

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.

字段概要

字段

限定符和类型	字段和说明
static String	NAME

构造器概要

构造器

构造器和说明
EmbeddedExecutor(Collection<org.apache.flink.api.common.JobID> submittedJobIds, org.apache.flink.runtime.dispatcher.DispatcherGateway dispatcherGateway, EmbeddedJobClientCreator jobClientCreator) Creates a EmbeddedExecutor.

方法概要

限定符和类型	方法和说明
CompletableFuture<org.apache.flink.core.execution.JobClient>	execute(org.apache.flink.api.dag.Pipeline pipeline, org.apache.flink.configuration.Configuration configuration)

从类继承的方法 java.lang.Object

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

字段详细资料

NAME

public static final String NAME

另请参阅:

常量字段值

构造器详细资料

EmbeddedExecutor

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

Creates a EmbeddedExecutor.

参数:

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.

方法详细资料

execute

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

指定者:

execute 在接口中 org.apache.flink.core.execution.PipelineExecutor

抛出:

MalformedURLException