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