public interface ExecutionSlotAllocator
Execution
.Modifier and Type | Method and Description |
---|---|
Collection<SlotExecutionVertexAssignment> |
allocateSlotsFor(Collection<ExecutionVertexSchedulingRequirements> executionVertexSchedulingRequirements)
Allocate slots for the given executions.
|
void |
cancel(ExecutionVertexID executionVertexId)
Cancel an ongoing slot request.
|
CompletableFuture<Void> |
stop()
Stop the allocator.
|
Collection<SlotExecutionVertexAssignment> allocateSlotsFor(Collection<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–2020 The Apache Software Foundation. All rights reserved.