Package | Description |
---|---|
org.apache.flink.runtime.executiongraph | |
org.apache.flink.runtime.jobmanager | |
org.apache.flink.runtime.testingUtils | |
org.apache.flink.yarn |
Modifier and Type | Method and Description |
---|---|
Scheduler |
ExecutionGraph.getScheduler() |
Modifier and Type | Method and Description |
---|---|
void |
ExecutionJobVertex.scheduleAll(Scheduler scheduler,
boolean queued) |
boolean |
ExecutionVertex.scheduleForExecution(Scheduler scheduler,
boolean queued) |
boolean |
Execution.scheduleForExecution(Scheduler scheduler,
boolean queued)
NOTE: This method only throws exceptions if it is in an illegal state to be scheduled, or if the tasks needs
to be scheduled immediately and no resource is available.
|
Constructor and Description |
---|
ExecutionGraph(Executor futureExecutor,
Executor ioExecutor,
JobID jobId,
String jobName,
Configuration jobConfig,
SerializedValue<ExecutionConfig> serializedConfig,
scala.concurrent.duration.FiniteDuration timeout,
RestartStrategy restartStrategy,
List<BlobKey> requiredJarFiles,
List<URL> requiredClasspaths,
Scheduler scheduler,
ClassLoader userClassLoader,
MetricGroup metricGroup) |
Modifier and Type | Method and Description |
---|---|
protected Scheduler |
JobManager.scheduler() |
Modifier and Type | Method and Description |
---|---|
static scala.Tuple12<InstanceManager,Scheduler,BlobLibraryCacheManager,RestartStrategyFactory,scala.concurrent.duration.FiniteDuration,Object,LeaderElectionService,SubmittedJobGraphStore,CheckpointRecoveryFactory,SavepointStore,scala.concurrent.duration.FiniteDuration,scala.Option<MetricRegistry>> |
JobManager.createJobManagerComponents(Configuration configuration,
Executor futureExecutor,
Executor ioExecutor,
scala.Option<LeaderElectionService> leaderElectionServiceOption)
Create the job manager components as (instanceManager, scheduler, libraryCacheManager,
archiverProps, defaultExecutionRetries,
delayBetweenRetries, timeout)
|
scala.Tuple12<InstanceManager,Scheduler,BlobLibraryCacheManager,RestartStrategyFactory,scala.concurrent.duration.FiniteDuration,Object,LeaderElectionService,SubmittedJobGraphStore,CheckpointRecoveryFactory,SavepointStore,scala.concurrent.duration.FiniteDuration,scala.Option<MetricRegistry>> |
JobManager$.createJobManagerComponents(Configuration configuration,
Executor futureExecutor,
Executor ioExecutor,
scala.Option<LeaderElectionService> leaderElectionServiceOption)
Create the job manager components as (instanceManager, scheduler, libraryCacheManager,
archiverProps, defaultExecutionRetries,
delayBetweenRetries, timeout)
|
Constructor and Description |
---|
JobManager(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> metricsRegistry) |
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) |
Constructor and Description |
---|
YarnJobManager(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> metricsRegistry) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.