org.apache.flink.client.deployment.application

类 ApplicationDispatcherBootstrap

java.lang.Object

org.apache.flink.runtime.dispatcher.AbstractDispatcherBootstrap

org.apache.flink.client.deployment.application.ApplicationDispatcherBootstrap

所有已实现的接口:

org.apache.flink.runtime.dispatcher.DispatcherBootstrap

@Internal
public class ApplicationDispatcherBootstrap
extends org.apache.flink.runtime.dispatcher.AbstractDispatcherBootstrap

A DispatcherBootstrap used for running the user's main() in "Application Mode" (see FLIP-85).

This dispatcher bootstrap submits the recovered job graphs for re-execution (in case of recovery from a failure), and then submits the remaining jobs of the application for execution.

To achieve this, it works in conjunction with the EmbeddedExecutor which decides if it should submit a job for execution (in case of a new job) or the job was already recovered and is running.

字段概要

字段

限定符和类型	字段和说明
static org.apache.flink.api.common.JobID	ZERO_JOB_ID

构造器概要

构造器

构造器和说明
ApplicationDispatcherBootstrap(PackagedProgram application, Collection<org.apache.flink.runtime.jobgraph.JobGraph> recoveredJobs, org.apache.flink.configuration.Configuration configuration)

方法概要

限定符和类型	方法和说明
void	initialize(org.apache.flink.runtime.dispatcher.Dispatcher dispatcher, org.apache.flink.runtime.concurrent.ScheduledExecutor scheduledExecutor)
void	stop()

从类继承的方法 org.apache.flink.runtime.dispatcher.AbstractDispatcherBootstrap

launchRecoveredJobGraphs

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

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

字段详细资料

ZERO_JOB_ID

public static final org.apache.flink.api.common.JobID ZERO_JOB_ID

构造器详细资料

ApplicationDispatcherBootstrap

public ApplicationDispatcherBootstrap(PackagedProgram application,
                                      Collection<org.apache.flink.runtime.jobgraph.JobGraph> recoveredJobs,
                                      org.apache.flink.configuration.Configuration configuration)

方法详细资料

initialize

public void initialize(org.apache.flink.runtime.dispatcher.Dispatcher dispatcher,
                       org.apache.flink.runtime.concurrent.ScheduledExecutor scheduledExecutor)

stop

public void stop()