6d4981a431e1ad28dee3a2143477fa7d2696d5fd
Files Diff
- Added: 0
- Removed: 0
- Renamed: 0
- Modified: 2
Refactorings reported:
Refactoring Name | Occurences | ||
---|---|---|---|
Rename Method | 1 | ||
Rename Method public future() : FlinkCompletableFuture<SimpleSlot> renamed to public getFuture() : CompletableFuture<SimpleSlot> in class org.apache.flink.runtime.instance.SlotPool.PendingRequest | From | To | |
Change Parameter Type | 3 | ||
Change Parameter Type future : FlinkCompletableFuture<SimpleSlot> to future : CompletableFuture<SimpleSlot> in method package PendingRequest(allocationID AllocationID, future CompletableFuture<SimpleSlot>, resourceProfile ResourceProfile) in class org.apache.flink.runtime.instance.SlotPool.PendingRequest | From | To | |
Change Parameter Type future : FlinkCompletableFuture<SimpleSlot> to future : CompletableFuture<SimpleSlot> in method private stashRequestWaitingForResourceManager(allocationID AllocationID, resources ResourceProfile, future CompletableFuture<SimpleSlot>) : void in class org.apache.flink.runtime.instance.SlotPool | From | To | |
Change Parameter Type future : FlinkCompletableFuture<SimpleSlot> to future : CompletableFuture<SimpleSlot> in method private requestSlotFromResourceManager(allocationID AllocationID, future CompletableFuture<SimpleSlot>, resources ResourceProfile) : void in class org.apache.flink.runtime.instance.SlotPool | From | To | |
Change Return Type | 2 | ||
Change Return Type Future<SimpleSlot> to CompletableFuture<SimpleSlot> in method package internalAllocateSlot(task ScheduledUnit, resources ResourceProfile, locationPreferences Iterable<TaskManagerLocation>) : CompletableFuture<SimpleSlot> in class org.apache.flink.runtime.instance.SlotPool | From | To | |
Change Return Type FlinkCompletableFuture<SimpleSlot> to CompletableFuture<SimpleSlot> in method public getFuture() : CompletableFuture<SimpleSlot> in class org.apache.flink.runtime.instance.SlotPool.PendingRequest | From | To | |
Change Variable Type | 2 | ||
Change Variable Type future : FlinkCompletableFuture<SimpleSlot> to future : CompletableFuture<SimpleSlot> in method package internalAllocateSlot(task ScheduledUnit, resources ResourceProfile, locationPreferences Iterable<TaskManagerLocation>) : CompletableFuture<SimpleSlot> in class org.apache.flink.runtime.instance.SlotPool | From | To | |
Change Variable Type rmResponse : Future<Acknowledge> to rmResponse : CompletableFuture<Acknowledge> in method private requestSlotFromResourceManager(allocationID AllocationID, future CompletableFuture<SimpleSlot>, resources ResourceProfile) : void in class org.apache.flink.runtime.instance.SlotPool | From | To | |
Change Attribute Type | 1 | ||
Change Attribute Type future : FlinkCompletableFuture<SimpleSlot> to future : CompletableFuture<SimpleSlot> in class org.apache.flink.runtime.instance.SlotPool.PendingRequest | From | To |