Package | Description |
---|---|
org.apache.flink.runtime.executiongraph | |
org.apache.flink.runtime.instance | |
org.apache.flink.runtime.jobmanager.scheduler |
Modifier and Type | Method and Description |
---|---|
SlotProvider |
ExecutionGraph.getSlotProvider() |
Modifier and Type | Method and Description |
---|---|
ExecutionAndSlot[] |
ExecutionJobVertex.allocateResourcesForAll(SlotProvider resourceProvider,
boolean queued)
Acquires a slot for all the execution vertices of this ExecutionJobVertex.
|
Future<SimpleSlot> |
Execution.allocateSlotForExecution(SlotProvider slotProvider,
boolean queued) |
static ExecutionGraph |
ExecutionGraphBuilder.buildGraph(ExecutionGraph prior,
JobGraph jobGraph,
Configuration jobManagerConfig,
ScheduledExecutorService futureExecutor,
Executor ioExecutor,
SlotProvider slotProvider,
ClassLoader classLoader,
CheckpointRecoveryFactory recoveryFactory,
Time timeout,
RestartStrategy restartStrategy,
MetricGroup metrics,
int parallelismForAutoMax,
org.slf4j.Logger log)
Builds the ExecutionGraph from the JobGraph.
|
void |
ExecutionJobVertex.scheduleAll(SlotProvider slotProvider,
boolean queued) |
boolean |
ExecutionVertex.scheduleForExecution(SlotProvider slotProvider,
boolean queued) |
boolean |
Execution.scheduleForExecution(SlotProvider slotProvider,
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(ScheduledExecutorService futureExecutor,
Executor ioExecutor,
JobID jobId,
String jobName,
Configuration jobConfig,
SerializedValue<ExecutionConfig> serializedConfig,
Time timeout,
RestartStrategy restartStrategy,
FailoverStrategy.Factory failoverStrategyFactory,
List<BlobKey> requiredJarFiles,
List<URL> requiredClasspaths,
SlotProvider slotProvider,
ClassLoader userClassLoader) |
Modifier and Type | Method and Description |
---|---|
SlotProvider |
SlotPool.getSlotProvider()
Gets the slot provider implementation for this pool.
|
Modifier and Type | Class and Description |
---|---|
class |
Scheduler
The scheduler is responsible for distributing the ready-to-run tasks among instances and slots.
|
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.