Package org.apache.flink.runtime.dispatcher.runner

Class JobDispatcherLeaderProcess

java.lang.Object

org.apache.flink.runtime.dispatcher.runner.AbstractDispatcherLeaderProcess

org.apache.flink.runtime.dispatcher.runner.JobDispatcherLeaderProcess

All Implemented Interfaces:

AutoCloseable, AutoCloseableAsync

public class JobDispatcherLeaderProcess
extends AbstractDispatcherLeaderProcess

DispatcherLeaderProcess implementation for the per-job mode.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.flink.runtime.dispatcher.runner.AbstractDispatcherLeaderProcess

AbstractDispatcherLeaderProcess.DispatcherGatewayService, AbstractDispatcherLeaderProcess.DispatcherGatewayServiceFactory, AbstractDispatcherLeaderProcess.State

Field Summary

Fields inherited from class org.apache.flink.runtime.dispatcher.runner.AbstractDispatcherLeaderProcess

log

Method Summary

Modifier and Type	Method	Description
protected void	onStart()

Methods inherited from class org.apache.flink.runtime.dispatcher.runner.AbstractDispatcherLeaderProcess

closeAsync, getDispatcherGateway, getDispatcherService, getLeaderAddressFuture, getLeaderSessionId, getShutDownFuture, onClose, start

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.util.AutoCloseableAsync

close

Method Detail

onStart

protected void onStart()

Specified by:

onStart in class AbstractDispatcherLeaderProcess