org.apache.flink.runtime.dispatcher

Class StandaloneDispatcher

java.lang.Object

org.apache.flink.runtime.rpc.RpcEndpoint

org.apache.flink.runtime.rpc.FencedRpcEndpoint<F>

org.apache.flink.runtime.rpc.PermanentlyFencedRpcEndpoint<DispatcherId>

org.apache.flink.runtime.dispatcher.Dispatcher

org.apache.flink.runtime.dispatcher.StandaloneDispatcher

All Implemented Interfaces:

AutoCloseable, DispatcherGateway, FencedRpcGateway<DispatcherId>, RpcGateway, RestfulGateway, AutoCloseableAsync

public class StandaloneDispatcher
extends Dispatcher

Dispatcher implementation which spawns a JobMaster for each submitted JobGraph within in the same process. This dispatcher can be used as the default for all different session clusters.

Nested Class Summary

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

Dispatcher.ExecutionType

Nested classes/interfaces inherited from class org.apache.flink.runtime.rpc.RpcEndpoint

RpcEndpoint.MainThreadExecutor

Field Summary

Fields inherited from class org.apache.flink.runtime.dispatcher.Dispatcher

DISPATCHER_NAME, shutDownFuture

Fields inherited from class org.apache.flink.runtime.rpc.RpcEndpoint

log, rpcServer

Constructor Summary

Constructors

Constructor and Description
StandaloneDispatcher(RpcService rpcService, DispatcherId fencingToken, Collection<JobGraph> recoveredJobs, DispatcherBootstrapFactory dispatcherBootstrapFactory, DispatcherServices dispatcherServices)

Method Summary

Methods inherited from class org.apache.flink.runtime.dispatcher.Dispatcher

cancelJob, deliverCoordinationRequestToCoordinator, disposeSavepoint, getBlobServerPort, getShutDownFuture, jobReachedTerminalState, listJobs, onFatalError, onRemovedJobGraph, onStart, onStop, requestClusterOverview, requestJob, requestJobResult, requestJobStatus, requestMetricQueryServiceAddresses, requestMultipleJobDetails, requestOperatorBackPressureStats, requestTaskManagerMetricQueryServiceAddresses, shutDownCluster, shutDownCluster, stopWithSavepoint, submitJob, triggerSavepoint

Methods inherited from class org.apache.flink.runtime.rpc.PermanentlyFencedRpcEndpoint

setFencingToken

Methods inherited from class org.apache.flink.runtime.rpc.FencedRpcEndpoint

callAsyncWithoutFencing, getFencingToken, getMainThreadExecutor, getUnfencedMainThreadExecutor, runAsyncWithoutFencing

Methods inherited from class org.apache.flink.runtime.rpc.RpcEndpoint

callAsync, closeAsync, getAddress, getEndpointId, getHostname, getRpcService, getSelfGateway, getTerminationFuture, internalCallOnStart, internalCallOnStop, isRunning, runAsync, scheduleRunAsync, scheduleRunAsync, start, stop, validateRunsInMainThread

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.runtime.rpc.FencedRpcGateway

getFencingToken

Methods inherited from interface org.apache.flink.runtime.rpc.RpcGateway

getAddress, getHostname

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

close

Constructor Detail

StandaloneDispatcher

public StandaloneDispatcher(RpcService rpcService,
                            DispatcherId fencingToken,
                            Collection<JobGraph> recoveredJobs,
                            DispatcherBootstrapFactory dispatcherBootstrapFactory,
                            DispatcherServices dispatcherServices)
                     throws Exception

Throws:

Exception