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

类 WebSubmissionExecutorServiceLoader

java.lang.Object

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

所有已实现的接口:

org.apache.flink.core.execution.PipelineExecutorServiceLoader

@Internal
public class WebSubmissionExecutorServiceLoader
extends Object
implements org.apache.flink.core.execution.PipelineExecutorServiceLoader

A PipelineExecutorServiceLoader that always returns an WebSubmissionExecutorFactory.

构造器概要

构造器

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

方法概要

限定符和类型	方法和说明
org.apache.flink.core.execution.PipelineExecutorFactory	getExecutorFactory(org.apache.flink.configuration.Configuration configuration)
java.util.stream.Stream<String>	getExecutorNames()

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

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

构造器详细资料

WebSubmissionExecutorServiceLoader

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

Creates an WebSubmissionExecutorServiceLoader.

参数:

submittedJobIds - a list that is going to be filled by the EmbeddedExecutor 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.

方法详细资料

getExecutorFactory

public org.apache.flink.core.execution.PipelineExecutorFactory getExecutorFactory(org.apache.flink.configuration.Configuration configuration)

指定者:

getExecutorFactory 在接口中 org.apache.flink.core.execution.PipelineExecutorServiceLoader

getExecutorNames

public java.util.stream.Stream<String> getExecutorNames()

指定者:

getExecutorNames 在接口中 org.apache.flink.core.execution.PipelineExecutorServiceLoader