public interface ExecutionSlotAllocator
|Modifier and Type||Method and Description|
Allocate slots for the given executions.
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–2020 The Apache Software Foundation. All rights reserved.