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

类 EmbeddedExecutorFactory

java.lang.Object

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

所有已实现的接口:

org.apache.flink.core.execution.PipelineExecutorFactory

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

An PipelineExecutorFactory for the EmbeddedExecutor.

构造器概要

构造器

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

方法概要

限定符和类型	方法和说明
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

构造器详细资料

EmbeddedExecutorFactory

public EmbeddedExecutorFactory(Collection<org.apache.flink.api.common.JobID> submittedJobIds,
                               org.apache.flink.runtime.dispatcher.DispatcherGateway dispatcherGateway,
                               org.apache.flink.runtime.concurrent.ScheduledExecutor retryExecutor)

Creates an EmbeddedExecutorFactory.

参数:

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