Modifier and Type | Class and Description |
---|---|
static class |
ComponentMainThreadExecutor.DummyComponentMainThreadExecutor
Dummy implementation of ComponentMainThreadExecutor.
|
Modifier and Type | Method and Description |
---|---|
ComponentMainThreadExecutor |
ExecutionGraph.getJobMasterMainThreadExecutor() |
Modifier and Type | Method and Description |
---|---|
void |
ExecutionGraph.start(ComponentMainThreadExecutor jobMasterMainThreadExecutor) |
Modifier and Type | Method and Description |
---|---|
void |
PhysicalSlotRequestBulkCheckerImpl.start(ComponentMainThreadExecutor mainThreadExecutor) |
void |
Scheduler.start(ComponentMainThreadExecutor mainThreadExecutor)
Start the scheduler by initializing the main thread executor.
|
void |
SchedulerImpl.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 |
SlotPoolImpl.start(JobMasterId jobMasterId,
String newJobManagerAddress,
ComponentMainThreadExecutor componentMainThreadExecutor)
Start the slot pool to accept RPC calls.
|
Modifier and Type | Method and Description |
---|---|
void |
OperatorCoordinatorHolder.lazyInitialize(SchedulerNG scheduler,
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 |
---|---|
void |
SchedulerBase.setMainThreadExecutor(ComponentMainThreadExecutor mainThreadExecutor) |
void |
SchedulerNG.setMainThreadExecutor(ComponentMainThreadExecutor mainThreadExecutor) |
void |
DefaultScheduler.setMainThreadExecutor(ComponentMainThreadExecutor mainThreadExecutor) |
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–2021 The Apache Software Foundation. All rights reserved.