public interface ExecutionSlotAllocator
Execution
.Modifier and Type | Method and Description |
---|---|
Map<ExecutionAttemptID,org.apache.flink.runtime.scheduler.ExecutionSlotAssignment> |
allocateSlotsFor(List<ExecutionAttemptID> executionAttemptIds)
Allocate slots for the given executions.
|
void |
cancel(ExecutionAttemptID executionAttemptId)
Cancel the ongoing slot request of the given
Execution . |
Map<ExecutionAttemptID,org.apache.flink.runtime.scheduler.ExecutionSlotAssignment> allocateSlotsFor(List<ExecutionAttemptID> executionAttemptIds)
executionAttemptIds
- executions to allocate slots forvoid cancel(ExecutionAttemptID executionAttemptId)
Execution
.executionAttemptId
- identifying the Execution
of which the slot request should
be canceled.Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.