|
Change Parameter Type slots : Iterable<SlotOffer> to slots : Collection<SlotOffer> in method public offerSlots(taskManagerId ResourceID, slots Collection<SlotOffer>, timeout Time) : CompletableFuture<Collection<SlotOffer>> in class org.apache.flink.runtime.jobmaster.JobMaster |
From |
To |
|
Change Parameter Type slot : Slot to allocatedSlot : SlotContext in method public returnAllocatedSlot(allocatedSlot SlotContext) : void in class org.apache.flink.runtime.instance.SlotPool |
From |
To |
|
Change Parameter Type offers : Collection<Tuple2<AllocatedSlot,SlotOffer>> to offers : Collection<SlotOffer> in method public offerSlots(taskManagerLocation TaskManagerLocation, taskManagerGateway TaskManagerGateway, offers Collection<SlotOffer>) : CompletableFuture<Collection<SlotOffer>> in class org.apache.flink.runtime.instance.SlotPool |
From |
To |
|
Change Parameter Type allocatedSlot : AllocatedSlot to slotContext : SlotContext in method public SimpleSlot(slotContext SlotContext, owner SlotOwner, slotNumber int) in class org.apache.flink.runtime.instance.SimpleSlot |
From |
To |
|
Change Parameter Type slots : Iterable<SlotOffer> to slots : Collection<SlotOffer> in method public offerSlots(taskManagerId ResourceID, slots Collection<SlotOffer>, timeout Time) : CompletableFuture<Collection<SlotOffer>> in class org.apache.flink.runtime.jobmaster.JobMasterGateway |
From |
To |
|
Change Parameter Type slot : Slot to slotInformation : SlotContext in method public returnAllocatedSlot(slotInformation SlotContext) : void in class org.apache.flink.runtime.instance.SlotPoolGateway |
From |
To |
|
Change Parameter Type allocatedSlot : AllocatedSlot to slotContext : SlotContext in method public SharedSlot(slotContext SlotContext, owner SlotOwner, assignmentGroup SlotSharingGroupAssignment) in class org.apache.flink.runtime.instance.SharedSlot |
From |
To |
|
Change Parameter Type offers : Collection<Tuple2<AllocatedSlot,SlotOffer>> to offers : Collection<SlotOffer> in method public offerSlots(taskManagerLocation TaskManagerLocation, taskManagerGateway TaskManagerGateway, offers Collection<SlotOffer>) : CompletableFuture<Collection<SlotOffer>> in class org.apache.flink.runtime.instance.SlotPoolGateway |
From |
To |
|
Change Parameter Type allocatedSlot : AllocatedSlot to slotInformation : SlotContext in method private SharedSlot(slotInformation SlotContext, owner SlotOwner, slotNumber int, assignmentGroup SlotSharingGroupAssignment, parent SharedSlot, groupId AbstractID) in class org.apache.flink.runtime.instance.SharedSlot |
From |
To |
|
Change Parameter Type slot : Slot to allocationId : AllocationID in method private internalReturnAllocatedSlot(allocationId AllocationID) : void in class org.apache.flink.runtime.instance.SlotPool |
From |
To |
|
Change Parameter Type allocatedSlot : AllocatedSlot to slotContext : SlotContext in method protected Slot(slotContext SlotContext, owner SlotOwner, slotNumber int, parent SharedSlot, groupID AbstractID) in class org.apache.flink.runtime.instance.Slot |
From |
To |
|
Change Parameter Type allocatedSlot : AllocatedSlot to slotContext : SlotContext in method private SimpleSlot(slotContext SlotContext, owner SlotOwner, slotNumber int, parent SharedSlot, groupID AbstractID) in class org.apache.flink.runtime.instance.SimpleSlot |
From |
To |
|
Change Variable Type slot : Slot to allocatedSlot : AllocatedSlot in method public cancelSlotRequest(requestId SlotRequestID) : CompletableFuture<Acknowledge> in class org.apache.flink.runtime.instance.SlotPool |
From |
To |
|
Change Variable Type resourceID : ResourceID to taskManagerLocation : TaskManagerLocation in method public testAllocateSimpleSlot() : void in class org.apache.flink.runtime.instance.SlotPoolTest |
From |
To |
|
Change Variable Type slotsForTM : Set<Slot> to slotsForTM : Set<AllocatedSlot> in method package remove(slotId AllocationID) : AllocatedSlot in class org.apache.flink.runtime.instance.SlotPool.AllocatedSlots |
From |
To |
|
Change Variable Type allocatedSlotsForResource : Set<Slot> to allocatedSlotsForResource : Set<AllocatedSlot> in method public releaseTaskManager(resourceID ResourceID) : CompletableFuture<Acknowledge> in class org.apache.flink.runtime.instance.SlotPool |
From |
To |
|
Change Variable Type slotsForTaskManager : Set<Slot> to slotsForTaskManager : Set<AllocatedSlot> in method package removeSlotsForTaskManager(resourceID ResourceID) : Set<AllocatedSlot> in class org.apache.flink.runtime.instance.SlotPool.AllocatedSlots |
From |
To |
|
Change Variable Type slot : Slot to allocatedSlot : AllocatedSlot in method package removeSlotsForTaskManager(resourceID ResourceID) : Set<AllocatedSlot> in class org.apache.flink.runtime.instance.SlotPool.AllocatedSlots |
From |
To |
|
Change Variable Type slot : Slot to allocatedSlot : AllocatedSlot in method public failAllocation(allocationID AllocationID, cause Exception) : void in class org.apache.flink.runtime.instance.SlotPool |
From |
To |
|
Change Variable Type slot : AllocatedSlot to slot : SlotContext in method public allocateSlot(task ScheduledUnit, allowQueued boolean, preferredLocations Collection<TaskManagerLocation>) : CompletableFuture<LogicalSlot> in class org.apache.flink.runtime.executiongraph.utils.SimpleSlotProvider |
From |
To |
|
Change Variable Type slot : Slot to allocatedSlot : AllocatedSlot in method package remove(slotId AllocationID) : AllocatedSlot in class org.apache.flink.runtime.instance.SlotPool.AllocatedSlots |
From |
To |
|
Rename Method public cancelSlotAllocation(requestId SlotRequestID) : CompletableFuture<Acknowledge> renamed to public cancelSlotRequest(requestId SlotRequestID) : CompletableFuture<Acknowledge> in class org.apache.flink.runtime.instance.SlotPoolGateway |
From |
To |
|
Rename Method public getFuture() : CompletableFuture<LogicalSlot> renamed to public getAllocatedSlotFuture() : CompletableFuture<AllocatedSlot> in class org.apache.flink.runtime.instance.SlotPool.PendingRequest |
From |
To |
|
Rename Method public getAllocatedSlot() : AllocatedSlot renamed to public getSlotContext() : SlotContext in class org.apache.flink.runtime.instance.Slot |
From |
To |
|
Rename Method public cancelSlotAllocation(requestId SlotRequestID) : CompletableFuture<Acknowledge> renamed to public cancelSlotRequest(requestId SlotRequestID) : CompletableFuture<Acknowledge> in class org.apache.flink.runtime.instance.SlotPool |
From |
To |
|
Rename Method public getSlotNumber() : int renamed to public getPhysicalSlotNumber() : int in class org.apache.flink.runtime.instance.AllocatedSlot |
From |
To |
|
Rename Method public getSlotAllocationId() : AllocationID renamed to public getAllocationId() : AllocationID in class org.apache.flink.runtime.instance.AllocatedSlot |
From |
To |
|
Rename Method public cancelSlotAllocation(slotRequestId SlotRequestID) : CompletableFuture<Acknowledge> renamed to public cancelSlotRequest(slotRequestId SlotRequestID) : CompletableFuture<Acknowledge> in class org.apache.flink.runtime.instance.SlotPoolRpcTest.TestingSlotPool |
From |
To |
|
Change Return Type Set<Slot> to Set<AllocatedSlot> in method package getSlotsForTaskManager(resourceId ResourceID) : Set<AllocatedSlot> in class org.apache.flink.runtime.instance.SlotPool.AllocatedSlots |
From |
To |
|
Change Return Type Slot to AllocatedSlot in method package get(allocationID AllocationID) : AllocatedSlot in class org.apache.flink.runtime.instance.SlotPool.AllocatedSlots |
From |
To |
|
Change Return Type Set<Slot> to Set<AllocatedSlot> in method package removeSlotsForTaskManager(resourceID ResourceID) : Set<AllocatedSlot> in class org.apache.flink.runtime.instance.SlotPool.AllocatedSlots |
From |
To |
|
Change Return Type AllocatedSlot to SlotContext in method public getSlotContext() : SlotContext in class org.apache.flink.runtime.instance.Slot |
From |
To |
|
Change Return Type Slot to AllocatedSlot in method package get(slotRequestId SlotRequestID) : AllocatedSlot in class org.apache.flink.runtime.instance.SlotPool.AllocatedSlots |
From |
To |
|
Change Return Type Slot to AllocatedSlot in method package remove(slotId AllocationID) : AllocatedSlot in class org.apache.flink.runtime.instance.SlotPool.AllocatedSlots |
From |
To |
|
Change Return Type CompletableFuture<LogicalSlot> to CompletableFuture<AllocatedSlot> in method public getAllocatedSlotFuture() : CompletableFuture<AllocatedSlot> in class org.apache.flink.runtime.instance.SlotPool.PendingRequest |
From |
To |
|
Change Attribute Type allocatedSlotsByTaskManager : Map<ResourceID,Set<Slot>> to allocatedSlotsByTaskManager : Map<ResourceID,Set<AllocatedSlot>> in class org.apache.flink.runtime.instance.SlotPool.AllocatedSlots |
From |
To |
|
Change Attribute Type slots : ArrayDeque<AllocatedSlot> to slots : ArrayDeque<SlotContext> in class org.apache.flink.runtime.executiongraph.utils.SimpleSlotProvider |
From |
To |
|
Change Attribute Type allocatedSlot : AllocatedSlot to slotContext : SlotContext in class org.apache.flink.runtime.instance.Slot |
From |
To |
|
Change Attribute Type jobID : JobID to slotOwner : SlotOwner in class org.apache.flink.runtime.instance.AllocatedSlot |
From |
To |
|
Change Attribute Type allocatedSlotsById : DualKeyMap<AllocationID,SlotRequestID,Slot> to allocatedSlotsById : DualKeyMap<AllocationID,SlotRequestID,AllocatedSlot> in class org.apache.flink.runtime.instance.SlotPool.AllocatedSlots |
From |
To |
|
Rename Parameter slot : Slot to allocatedSlot : SlotContext in method public returnAllocatedSlot(allocatedSlot SlotContext) : void in class org.apache.flink.runtime.instance.SlotPool |
From |
To |
|
Rename Parameter allocatedSlot : AllocatedSlot to slotInformation : SlotContext in method private SharedSlot(slotInformation SlotContext, owner SlotOwner, slotNumber int, assignmentGroup SlotSharingGroupAssignment, parent SharedSlot, groupId AbstractID) in class org.apache.flink.runtime.instance.SharedSlot |
From |
To |
|
Rename Parameter slot : Slot to allocationId : AllocationID in method private internalReturnAllocatedSlot(allocationId AllocationID) : void in class org.apache.flink.runtime.instance.SlotPool |
From |
To |
|
Rename Parameter allocatedSlot : AllocatedSlot to slotContext : SlotContext in method public SimpleSlot(slotContext SlotContext, owner SlotOwner, slotNumber int) in class org.apache.flink.runtime.instance.SimpleSlot |
From |
To |
|
Rename Parameter allocatedSlot : AllocatedSlot to slotContext : SlotContext in method protected Slot(slotContext SlotContext, owner SlotOwner, slotNumber int, parent SharedSlot, groupID AbstractID) in class org.apache.flink.runtime.instance.Slot |
From |
To |
|
Rename Parameter allocatedSlot : AllocatedSlot to slotContext : SlotContext in method private SimpleSlot(slotContext SlotContext, owner SlotOwner, slotNumber int, parent SharedSlot, groupID AbstractID) in class org.apache.flink.runtime.instance.SimpleSlot |
From |
To |
|
Rename Parameter slot : Slot to slotInformation : SlotContext in method public returnAllocatedSlot(slotInformation SlotContext) : void in class org.apache.flink.runtime.instance.SlotPoolGateway |
From |
To |
|
Rename Parameter slotNumber : int to physicalSlotNumber : int in method public AllocatedSlot(slotAllocationId AllocationID, location TaskManagerLocation, physicalSlotNumber int, resourceProfile ResourceProfile, taskManagerGateway TaskManagerGateway, slotOwner SlotOwner) in class org.apache.flink.runtime.instance.AllocatedSlot |
From |
To |
|
Rename Parameter allocatedSlot : AllocatedSlot to slotContext : SlotContext in method public SharedSlot(slotContext SlotContext, owner SlotOwner, assignmentGroup SlotSharingGroupAssignment) in class org.apache.flink.runtime.instance.SharedSlot |
From |
To |