Modifier and Type | Class and Description |
---|---|
static class |
ComponentMainThreadExecutor.DummyComponentMainThreadExecutor
Dummy implementation of ComponentMainThreadExecutor.
|
Modifier and Type | Method and Description |
---|---|
ComponentMainThreadExecutor |
DefaultExecutionGraph.getJobMasterMainThreadExecutor() |
ComponentMainThreadExecutor |
InternalExecutionGraphAccessor.getJobMasterMainThreadExecutor() |
ComponentMainThreadExecutor |
ExecutionGraph.getJobMasterMainThreadExecutor() |
Modifier and Type | Method and Description |
---|---|
void |
DefaultExecutionGraph.start(ComponentMainThreadExecutor jobMasterMainThreadExecutor) |
void |
ExecutionGraph.start(ComponentMainThreadExecutor jobMasterMainThreadExecutor) |
Modifier and Type | Method and Description |
---|---|
SchedulerNG |
SlotPoolServiceSchedulerFactory.createScheduler(org.slf4j.Logger log,
JobGraph jobGraph,
Executor ioExecutor,
Configuration configuration,
SlotPoolService slotPoolService,
ScheduledExecutorService futureExecutor,
ClassLoader userCodeLoader,
CheckpointRecoveryFactory checkpointRecoveryFactory,
Time rpcTimeout,
BlobWriter blobWriter,
JobManagerJobMetricGroup jobManagerJobMetricGroup,
Time slotRequestTimeout,
ShuffleMaster<?> shuffleMaster,
JobMasterPartitionTracker partitionTracker,
ExecutionDeploymentTracker executionDeploymentTracker,
long initializationTimestamp,
ComponentMainThreadExecutor mainThreadExecutor,
FatalErrorHandler fatalErrorHandler,
JobStatusListener jobStatusListener)
Creates a
SchedulerNG . |
SchedulerNG |
DefaultSlotPoolServiceSchedulerFactory.createScheduler(org.slf4j.Logger log,
JobGraph jobGraph,
Executor ioExecutor,
Configuration configuration,
SlotPoolService slotPoolService,
ScheduledExecutorService futureExecutor,
ClassLoader userCodeLoader,
CheckpointRecoveryFactory checkpointRecoveryFactory,
Time rpcTimeout,
BlobWriter blobWriter,
JobManagerJobMetricGroup jobManagerJobMetricGroup,
Time slotRequestTimeout,
ShuffleMaster<?> shuffleMaster,
JobMasterPartitionTracker partitionTracker,
ExecutionDeploymentTracker executionDeploymentTracker,
long initializationTimestamp,
ComponentMainThreadExecutor mainThreadExecutor,
FatalErrorHandler fatalErrorHandler,
JobStatusListener jobStatusListener) |
Modifier and Type | Method and Description |
---|---|
protected void |
DeclarativeSlotPoolService.onStart(ComponentMainThreadExecutor componentMainThreadExecutor)
This method is called when the slot pool service is started.
|
protected void |
DeclarativeSlotPoolBridge.onStart(ComponentMainThreadExecutor componentMainThreadExecutor) |
void |
PhysicalSlotRequestBulkCheckerImpl.start(ComponentMainThreadExecutor mainThreadExecutor) |
void |
PhysicalSlotRequestBulkChecker.start(ComponentMainThreadExecutor mainThreadExecutor)
Starts the bulk checker by initializing the main thread executor.
|
void |
SlotPool.start(JobMasterId jobMasterId,
String newJobManagerAddress,
ComponentMainThreadExecutor jmMainThreadScheduledExecutor) |
void |
SlotPoolService.start(JobMasterId jobMasterId,
String address,
ComponentMainThreadExecutor mainThreadExecutor)
Start the encapsulated slot pool implementation.
|
void |
DeclarativeSlotPoolService.start(JobMasterId jobMasterId,
String address,
ComponentMainThreadExecutor mainThreadExecutor) |
Modifier and Type | Method and Description |
---|---|
void |
OperatorCoordinatorHolder.lazyInitialize(java.util.function.Consumer<Throwable> globalFailureHandler,
ComponentMainThreadExecutor mainThreadExecutor) |
Modifier and Type | Class and Description |
---|---|
protected static class |
RpcEndpoint.MainThreadExecutor
Executor which executes runnables in the main thread context.
|
Modifier and Type | Method and Description |
---|---|
protected ComponentMainThreadExecutor |
SchedulerBase.getMainThreadExecutor() |
Modifier and Type | Method and Description |
---|---|
SchedulerNG |
DefaultSchedulerFactory.createInstance(org.slf4j.Logger log,
JobGraph jobGraph,
Executor ioExecutor,
Configuration jobMasterConfiguration,
SlotPoolService slotPoolService,
ScheduledExecutorService futureExecutor,
ClassLoader userCodeLoader,
CheckpointRecoveryFactory checkpointRecoveryFactory,
Time rpcTimeout,
BlobWriter blobWriter,
JobManagerJobMetricGroup jobManagerJobMetricGroup,
Time slotRequestTimeout,
ShuffleMaster<?> shuffleMaster,
JobMasterPartitionTracker partitionTracker,
ExecutionDeploymentTracker executionDeploymentTracker,
long initializationTimestamp,
ComponentMainThreadExecutor mainThreadExecutor,
FatalErrorHandler fatalErrorHandler,
JobStatusListener jobStatusListener) |
SchedulerNG |
SchedulerNGFactory.createInstance(org.slf4j.Logger log,
JobGraph jobGraph,
Executor ioExecutor,
Configuration jobMasterConfiguration,
SlotPoolService slotPoolService,
ScheduledExecutorService futureExecutor,
ClassLoader userCodeLoader,
CheckpointRecoveryFactory checkpointRecoveryFactory,
Time rpcTimeout,
BlobWriter blobWriter,
JobManagerJobMetricGroup jobManagerJobMetricGroup,
Time slotRequestTimeout,
ShuffleMaster<?> shuffleMaster,
JobMasterPartitionTracker partitionTracker,
ExecutionDeploymentTracker executionDeploymentTracker,
long initializationTimestamp,
ComponentMainThreadExecutor mainThreadExecutor,
FatalErrorHandler fatalErrorHandler,
JobStatusListener jobStatusListener) |
void |
DefaultOperatorCoordinatorHandler.initializeOperatorCoordinators(ComponentMainThreadExecutor mainThreadExecutor) |
void |
OperatorCoordinatorHandler.initializeOperatorCoordinators(ComponentMainThreadExecutor mainThreadExecutor)
Initialize operator coordinators.
|
Constructor and Description |
---|
ExecutionGraphHandler(ExecutionGraph executionGraph,
org.slf4j.Logger log,
Executor ioExecutor,
ComponentMainThreadExecutor mainThreadExecutor) |
SchedulerBase(org.slf4j.Logger log,
JobGraph jobGraph,
Executor ioExecutor,
Configuration jobMasterConfiguration,
ClassLoader userCodeLoader,
CheckpointsCleaner checkpointsCleaner,
CheckpointRecoveryFactory checkpointRecoveryFactory,
JobManagerJobMetricGroup jobManagerJobMetricGroup,
ExecutionVertexVersioner executionVertexVersioner,
long initializationTimestamp,
ComponentMainThreadExecutor mainThreadExecutor,
JobStatusListener jobStatusListener,
ExecutionGraphFactory executionGraphFactory) |
Modifier and Type | Method and Description |
---|---|
SchedulerNG |
AdaptiveSchedulerFactory.createInstance(org.slf4j.Logger log,
JobGraph jobGraph,
Executor ioExecutor,
Configuration jobMasterConfiguration,
SlotPoolService slotPoolService,
ScheduledExecutorService futureExecutor,
ClassLoader userCodeLoader,
CheckpointRecoveryFactory checkpointRecoveryFactory,
Time rpcTimeout,
BlobWriter blobWriter,
JobManagerJobMetricGroup jobManagerJobMetricGroup,
Time slotRequestTimeout,
ShuffleMaster<?> shuffleMaster,
JobMasterPartitionTracker partitionTracker,
ExecutionDeploymentTracker executionDeploymentTracker,
long initializationTimestamp,
ComponentMainThreadExecutor mainThreadExecutor,
FatalErrorHandler fatalErrorHandler,
JobStatusListener jobStatusListener) |
Constructor and Description |
---|
AdaptiveScheduler(JobGraph jobGraph,
Configuration configuration,
DeclarativeSlotPool declarativeSlotPool,
SlotAllocator slotAllocator,
Executor ioExecutor,
ClassLoader userCodeClassLoader,
CheckpointsCleaner checkpointsCleaner,
CheckpointRecoveryFactory checkpointRecoveryFactory,
java.time.Duration initialResourceAllocationTimeout,
java.time.Duration resourceStabilizationTimeout,
JobManagerJobMetricGroup jobManagerJobMetricGroup,
RestartBackoffTimeStrategy restartBackoffTimeStrategy,
long initializationTimestamp,
ComponentMainThreadExecutor mainThreadExecutor,
FatalErrorHandler fatalErrorHandler,
JobStatusListener jobStatusListener,
ExecutionGraphFactory executionGraphFactory) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<String> |
StopWithSavepointTerminationManager.stopWithSavepoint(CompletableFuture<CompletedCheckpoint> completedSavepointFuture,
CompletableFuture<Collection<ExecutionState>> terminatedExecutionStatesFuture,
ComponentMainThreadExecutor mainThreadExecutor)
Enforces the correct completion order of the passed
CompletableFuture instances in
accordance to the contract of StopWithSavepointTerminationHandler . |
Modifier and Type | Method and Description |
---|---|
void |
TaskSlotTableImpl.start(SlotActions initialSlotActions,
ComponentMainThreadExecutor mainThreadExecutor) |
void |
TaskSlotTable.start(SlotActions initialSlotActions,
ComponentMainThreadExecutor mainThreadExecutor)
Start the task slot table with the given slot actions.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.