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

类 WebSubmissionExecutorFactory

java.lang.Object

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

所有已实现的接口:

org.apache.flink.core.execution.PipelineExecutorFactory

@Internal
public class WebSubmissionExecutorFactory
extends Object
implements org.apache.flink.core.execution.PipelineExecutorFactory

A PipelineExecutorFactory for an EmbeddedExecutor that returns a WebSubmissionJobClient.

构造器概要

构造器

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

方法概要

限定符和类型	方法和说明
org.apache.flink.core.execution.PipelineExecutor	getExecutor(org.apache.flink.configuration.Configuration configuration)
String	getName()
boolean	isCompatibleWith(org.apache.flink.configuration.Configuration configuration)

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

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

构造器详细资料

WebSubmissionExecutorFactory

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

Creates an WebSubmissionExecutorFactory.

参数:

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.

方法详细资料

getName

public String getName()

指定者:

getName 在接口中 org.apache.flink.core.execution.PipelineExecutorFactory

isCompatibleWith

public boolean isCompatibleWith(org.apache.flink.configuration.Configuration configuration)

指定者:

isCompatibleWith 在接口中 org.apache.flink.core.execution.PipelineExecutorFactory

getExecutor

public org.apache.flink.core.execution.PipelineExecutor getExecutor(org.apache.flink.configuration.Configuration configuration)

指定者:

getExecutor 在接口中 org.apache.flink.core.execution.PipelineExecutorFactory