public class StandaloneDispatcher extends Dispatcher
RpcEndpoint.MainThreadExecutor
DISPATCHER_NAME, shutDownFuture
log, rpcServer
Constructor and Description |
---|
StandaloneDispatcher(RpcService rpcService,
String endpointId,
DispatcherId fencingToken,
Collection<JobGraph> recoveredJobs,
DispatcherServices dispatcherServices) |
cancelJob, disposeSavepoint, getBlobServerPort, getShutDownFuture, jobNotFinished, jobReachedGloballyTerminalState, listJobs, onFatalError, onRemovedJobGraph, onStart, onStop, requestClusterOverview, requestJob, requestJobResult, requestJobStatus, requestMetricQueryServiceAddresses, requestMultipleJobDetails, requestOperatorBackPressureStats, requestTaskManagerMetricQueryServiceAddresses, shutDownCluster, stopWithSavepoint, submitJob, triggerSavepoint
setFencingToken
callAsyncWithoutFencing, getFencingToken, getMainThreadExecutor, getUnfencedMainThreadExecutor, runAsyncWithoutFencing
callAsync, closeAsync, getAddress, getEndpointId, getHostname, getRpcService, getSelfGateway, getTerminationFuture, internalCallOnStart, internalCallOnStop, isRunning, runAsync, scheduleRunAsync, scheduleRunAsync, start, stop, validateRunsInMainThread
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getFencingToken
getAddress, getHostname
close
public StandaloneDispatcher(RpcService rpcService, String endpointId, DispatcherId fencingToken, Collection<JobGraph> recoveredJobs, DispatcherServices dispatcherServices) throws Exception
Exception
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.