public class StandaloneDispatcher extends Dispatcher
Dispatcher.DefaultJobManagerRunnerFactory, Dispatcher.JobManagerRunnerFactory
RpcEndpoint.MainThreadExecutor
DISPATCHER_NAME, restAddress
log, rpcServer
Constructor and Description |
---|
StandaloneDispatcher(RpcService rpcService,
String endpointId,
Configuration configuration,
HighAvailabilityServices highAvailabilityServices,
ResourceManagerGateway resourceManagerGateway,
BlobServer blobServer,
HeartbeatServices heartbeatServices,
JobManagerMetricGroup jobManagerMetricGroup,
String metricQueryServicePath,
ArchivedExecutionGraphStore archivedExecutionGraphStore,
Dispatcher.JobManagerRunnerFactory jobManagerRunnerFactory,
FatalErrorHandler fatalErrorHandler,
String restAddress,
HistoryServerArchivist historyServerArchivist) |
cancelJob, disposeSavepoint, getBlobServerPort, grantLeadership, handleError, jobNotFinished, jobReachedGloballyTerminalState, listJobs, onAddedJobGraph, onFatalError, onRemovedJobGraph, postStop, requestClusterOverview, requestJob, requestJobResult, requestJobStatus, requestMetricQueryServicePaths, requestMultipleJobDetails, requestOperatorBackPressureStats, requestRestAddress, requestTaskManagerMetricQueryServicePaths, rescaleJob, revokeLeadership, shutDownCluster, start, stopJob, submitJob, triggerSavepoint
callAsyncWithoutFencing, getFencingToken, getMainThreadExecutor, getUnfencedMainThreadExecutor, runAsyncWithoutFencing, setFencingToken
callAsync, getAddress, getEndpointId, getHostname, getRpcService, getSelfGateway, getTerminationFuture, runAsync, scheduleRunAsync, scheduleRunAsync, shutDown, stop, validateRunsInMainThread
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getFencingToken
getAddress, getHostname
getAddress
public StandaloneDispatcher(RpcService rpcService, String endpointId, Configuration configuration, HighAvailabilityServices highAvailabilityServices, ResourceManagerGateway resourceManagerGateway, BlobServer blobServer, HeartbeatServices heartbeatServices, JobManagerMetricGroup jobManagerMetricGroup, @Nullable String metricQueryServicePath, ArchivedExecutionGraphStore archivedExecutionGraphStore, Dispatcher.JobManagerRunnerFactory jobManagerRunnerFactory, FatalErrorHandler fatalErrorHandler, @Nullable String restAddress, HistoryServerArchivist historyServerArchivist) throws Exception
Exception
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.