Modifier and Type | Field and Description |
---|---|
protected static SlotSharingGroupId |
Slot.NO_SLOT_SHARING_GROUP_ID |
Modifier and Type | Method and Description |
---|---|
SlotSharingGroupId |
SharedSlot.getSlotSharingGroupId() |
SlotSharingGroupId |
SimpleSlot.getSlotSharingGroupId() |
Modifier and Type | Method and Description |
---|---|
SlotSharingGroupId |
ScheduledUnit.getSlotSharingGroupId() |
SlotSharingGroupId |
SlotSharingGroup.getSlotSharingGroupId() |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<Acknowledge> |
Scheduler.cancelSlotRequest(SlotRequestId slotRequestId,
SlotSharingGroupId slotSharingGroupId,
Throwable cause) |
Constructor and Description |
---|
ScheduledUnit(Execution task,
JobVertexID jobVertexId,
SlotSharingGroupId slotSharingGroupId,
CoLocationConstraint coLocationConstraint) |
ScheduledUnit(Execution task,
SlotSharingGroupId slotSharingGroupId) |
ScheduledUnit(Execution task,
SlotSharingGroupId slotSharingGroupId,
CoLocationConstraint coLocationConstraint) |
ScheduledUnit(JobVertexID jobVertexId,
SlotSharingGroupId slotSharingGroupId,
CoLocationConstraint coLocationConstraint) |
Modifier and Type | Method and Description |
---|---|
SlotSharingGroupId |
LogicalSlot.getSlotSharingGroupId()
Gets the slot sharing group id to which this slot belongs.
|
Modifier and Type | Field and Description |
---|---|
protected Map<SlotSharingGroupId,SlotSharingManager> |
SlotPool.slotSharingManagers
Managers for the different slot sharing groups.
|
Modifier and Type | Method and Description |
---|---|
SlotSharingGroupId |
SingleLogicalSlot.getSlotSharingGroupId() |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<Acknowledge> |
SlotPool.ProviderAndOwner.cancelSlotRequest(SlotRequestId slotRequestId,
SlotSharingGroupId slotSharingGroupId,
Throwable cause) |
CompletableFuture<Acknowledge> |
SlotProvider.cancelSlotRequest(SlotRequestId slotRequestId,
SlotSharingGroupId slotSharingGroupId,
Throwable cause)
Cancels the slot request with the given
SlotRequestId and SlotSharingGroupId . |
CompletableFuture<Acknowledge> |
SlotPool.releaseSlot(SlotRequestId slotRequestId,
SlotSharingGroupId slotSharingGroupId,
Throwable cause) |
CompletableFuture<Acknowledge> |
AllocatedSlotActions.releaseSlot(SlotRequestId slotRequestId,
SlotSharingGroupId slotSharingGroupId,
Throwable cause)
Releases the slot with the given
SlotRequestId . |
Constructor and Description |
---|
SingleLogicalSlot(SlotRequestId slotRequestId,
SlotContext slotContext,
SlotSharingGroupId slotSharingGroupId,
Locality locality,
SlotOwner slotOwner) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.