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

类 EmbeddedExecutorServiceLoader

java.lang.Object

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

所有已实现的接口:

org.apache.flink.core.execution.PipelineExecutorServiceLoader

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

A PipelineExecutorServiceLoader that always returns an EmbeddedExecutorFactory. This is useful when running the user's main on the cluster.

构造器概要

构造器

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

方法概要

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

构造器详细资料

EmbeddedExecutorServiceLoader

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

Creates an EmbeddedExecutorServiceLoader.

参数:

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