public class TestingJobManager extends JobManager implements TestingJobManagerLike
Constructor and Description |
---|
TestingJobManager(Configuration flinkConfiguration,
Executor futureExecutor,
Executor ioExecutor,
InstanceManager instanceManager,
Scheduler scheduler,
BlobLibraryCacheManager libraryCacheManager,
akka.actor.ActorRef archive,
RestartStrategyFactory restartStrategyFactory,
scala.concurrent.duration.FiniteDuration timeout,
LeaderElectionService leaderElectionService,
SubmittedJobGraphStore submittedJobGraphs,
CheckpointRecoveryFactory checkpointRecoveryFactory,
SavepointStore savepointStore,
scala.concurrent.duration.FiniteDuration jobRecoveryTimeout,
scala.Option<MetricRegistry> metricRegistry) |
ARCHIVE_NAME, archive, checkpointRecoveryFactory, createJobManagerComponents, currentJobs, currentResourceManager, executionContext, flinkConfiguration, futureExecutor, futuresToComplete, getAddress, getJobManagerActorRef, getJobManagerActorRef, getJobManagerActorRef, getJobManagerActorRefFuture, getJobManagerAkkaURL, getLocalJobManagerAkkaURL, getRemoteJobManagerAkkaURL, getRemoteJobManagerAkkaURL, grantLeadership, handleError, handleMessage, instanceManager, ioExecutor, JOB_MANAGER_NAME, jobManagerMetricGroup, jobRecoveryTimeout, leaderElectionService, leaderSessionID, libraryCacheManager, log, LOG, main, metricsRegistry, onAddedJobGraph, onRemovedJobGraph, parseArgs, postStop, preStart, recoveryMode, restartStrategyFactory, retryOnBindException, revokeLeadership, runJobManager, runJobManager, RUNTIME_FAILURE_RETURN_CODE, savepointStore, scheduler, shutdown, startActorSystemAndJobManagerActors, startJobManagerActors, startJobManagerActors, STARTUP_FAILURE_RETURN_CODE, submittedJobGraphs, timeout, unhandled, webMonitorPort
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
checkIfAllVerticesRunning, checkIfAllVerticesRunningOrFinished, disconnectDisabled, handleMessage, handleTestingMessage, notifyListeners, periodicCheck, postStop, postStopEnabled, shutdown, waitForAccumulatorUpdate, waitForAllVerticesToBeRunning, waitForAllVerticesToBeRunningOrFinished, waitForJobStatus, waitForLeader, waitForNumRegisteredTaskManagers, waitForShutdown, waitForTaskManagerToBeTerminated
decorateMessage, log, receive
akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, context, postRestart, preRestart, preStart, self, sender, supervisorStrategy, unhandled
decorateMessage, handleDiscardedMessage, receive
receive
public TestingJobManager(Configuration flinkConfiguration, Executor futureExecutor, Executor ioExecutor, InstanceManager instanceManager, Scheduler scheduler, BlobLibraryCacheManager libraryCacheManager, akka.actor.ActorRef archive, RestartStrategyFactory restartStrategyFactory, scala.concurrent.duration.FiniteDuration timeout, LeaderElectionService leaderElectionService, SubmittedJobGraphStore submittedJobGraphs, CheckpointRecoveryFactory checkpointRecoveryFactory, SavepointStore savepointStore, scala.concurrent.duration.FiniteDuration jobRecoveryTimeout, scala.Option<MetricRegistry> metricRegistry)
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.