public interface ExecutionSlotAllocator
Execution
.Modifier and Type | Method and Description |
---|---|
List<SlotExecutionVertexAssignment> |
allocateSlotsFor(List<ExecutionVertexSchedulingRequirements> executionVertexSchedulingRequirements)
Allocate slots for the given executions.
|
void |
cancel(ExecutionVertexID executionVertexId)
Cancel an ongoing slot request.
|
CompletableFuture<Void> |
stop()
Stop the allocator.
|
List<SlotExecutionVertexAssignment> allocateSlotsFor(List<ExecutionVertexSchedulingRequirements> executionVertexSchedulingRequirements)
executionVertexSchedulingRequirements
- The requirements for scheduling the executions.void cancel(ExecutionVertexID executionVertexId)
executionVertexId
- identifying which slot request should be canceled.CompletableFuture<Void> stop()
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.