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