Package | Description |
---|---|
org.apache.flink.runtime.jobmaster.slotpool | |
org.apache.flink.runtime.scheduler |
Modifier and Type | Class and Description |
---|---|
class |
SlotPoolImpl
The slot pool serves slot request issued by
ExecutionGraph . |
Modifier and Type | Method and Description |
---|---|
SlotPool |
DefaultSlotPoolFactory.createSlotPool(JobID jobId) |
SlotPool |
SlotPoolFactory.createSlotPool(JobID jobId) |
Modifier and Type | Method and Description |
---|---|
static PhysicalSlotRequestBulkCheckerImpl |
PhysicalSlotRequestBulkCheckerImpl.createFromSlotPool(SlotPool slotPool,
Clock clock) |
Constructor and Description |
---|
PhysicalSlotProviderImpl(SlotSelectionStrategy slotSelectionStrategy,
SlotPool slotPool) |
SchedulerImpl(SlotSelectionStrategy slotSelectionStrategy,
SlotPool slotPool) |
SchedulerImpl(SlotSelectionStrategy slotSelectionStrategy,
SlotPool slotPool,
Map<SlotSharingGroupId,SlotSharingManager> slotSharingManagers) |
Modifier and Type | Method and Description |
---|---|
SchedulerNG |
SchedulerNGFactory.createInstance(org.slf4j.Logger log,
JobGraph jobGraph,
BackPressureStatsTracker backPressureStatsTracker,
Executor ioExecutor,
Configuration jobMasterConfiguration,
SlotPool slotPool,
ScheduledExecutorService futureExecutor,
ClassLoader userCodeLoader,
CheckpointRecoveryFactory checkpointRecoveryFactory,
Time rpcTimeout,
BlobWriter blobWriter,
JobManagerJobMetricGroup jobManagerJobMetricGroup,
Time slotRequestTimeout,
ShuffleMaster<?> shuffleMaster,
JobMasterPartitionTracker partitionTracker,
ExecutionDeploymentTracker executionDeploymentTracker,
long initializationTimestamp) |
SchedulerNG |
DefaultSchedulerFactory.createInstance(org.slf4j.Logger log,
JobGraph jobGraph,
BackPressureStatsTracker backPressureStatsTracker,
Executor ioExecutor,
Configuration jobMasterConfiguration,
SlotPool slotPool,
ScheduledExecutorService futureExecutor,
ClassLoader userCodeLoader,
CheckpointRecoveryFactory checkpointRecoveryFactory,
Time rpcTimeout,
BlobWriter blobWriter,
JobManagerJobMetricGroup jobManagerJobMetricGroup,
Time slotRequestTimeout,
ShuffleMaster<?> shuffleMaster,
JobMasterPartitionTracker partitionTracker,
ExecutionDeploymentTracker executionDeploymentTracker,
long initializationTimestamp) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.