|
Rename Variable future : CompletableFuture<SimpleSlot> to allocationFuture : CompletableFuture<Execution> in method public allocateResourcesForAll(resourceProvider SlotProvider, queued boolean) : Collection<CompletableFuture<Execution>> in class org.apache.flink.runtime.executiongraph.ExecutionJobVertex |
From |
To |
|
Rename Variable sourceSlot : SimpleSlot to taskManagerLocationFuture : CompletableFuture<TaskManagerLocation> in method public getPreferredLocationsBasedOnInputs() : Collection<CompletableFuture<TaskManagerLocation>> in class org.apache.flink.runtime.executiongraph.ExecutionVertex |
From |
To |
|
Rename Variable slotAllocationFuture : CompletableFuture<SimpleSlot> to allocationFuture : CompletableFuture<Execution> in method public scheduleForExecution(slotProvider SlotProvider, queued boolean) : boolean in class org.apache.flink.runtime.executiongraph.Execution |
From |
To |
|
Rename Variable slotFutures : ArrayList<CompletableFuture<SimpleSlot>> to allAllocationFutures : ArrayList<CompletableFuture<Execution>> in method private scheduleEager(slotProvider SlotProvider, timeout Time) : void in class org.apache.flink.runtime.executiongraph.ExecutionGraph |
From |
To |
|
Rename Variable slots : ExecutionAndSlot[] to allocationFutures : Collection<CompletableFuture<Execution>> in method private scheduleEager(slotProvider SlotProvider, timeout Time) : void in class org.apache.flink.runtime.executiongraph.ExecutionGraph |
From |
To |
|
Rename Variable locationPreferences : Iterable<TaskManagerLocation> to locationPreferenceFutures : Collection<CompletableFuture<TaskManagerLocation>> in method public allocateSlot(task ScheduledUnit, allowQueued boolean) : CompletableFuture<SimpleSlot> in class org.apache.flink.runtime.instance.SlotPool.ProviderAndOwner |
From |
To |
|
Change Return Type ExecutionAndSlot[] to Collection<CompletableFuture<Execution>> in method public allocateResourcesForAll(resourceProvider SlotProvider, queued boolean) : Collection<CompletableFuture<Execution>> in class org.apache.flink.runtime.executiongraph.ExecutionJobVertex |
From |
To |
|
Change Return Type Iterable<TaskManagerLocation> to Collection<CompletableFuture<TaskManagerLocation>> in method public getPreferredLocations() : Collection<CompletableFuture<TaskManagerLocation>> in class org.apache.flink.runtime.executiongraph.ExecutionVertex |
From |
To |
|
Change Return Type Iterable<TaskManagerLocation> to Collection<CompletableFuture<TaskManagerLocation>> in method public getPreferredLocationsBasedOnState() : Collection<CompletableFuture<TaskManagerLocation>> in class org.apache.flink.runtime.executiongraph.ExecutionVertex |
From |
To |
|
Change Return Type CompletableFuture<SimpleSlot> to CompletableFuture<Execution> in method public allocateAndAssignSlotForExecution(slotProvider SlotProvider, queued boolean) : CompletableFuture<Execution> in class org.apache.flink.runtime.executiongraph.Execution |
From |
To |
|
Change Return Type Iterable<TaskManagerLocation> to Collection<CompletableFuture<TaskManagerLocation>> in method public getPreferredLocationsBasedOnInputs() : Collection<CompletableFuture<TaskManagerLocation>> in class org.apache.flink.runtime.executiongraph.ExecutionVertex |
From |
To |
|
Change Variable Type slotAllocationFuture : CompletableFuture<SimpleSlot> to allocationFuture : CompletableFuture<Execution> in method public scheduleForExecution(slotProvider SlotProvider, queued boolean) : boolean in class org.apache.flink.runtime.executiongraph.Execution |
From |
To |
|
Change Variable Type preference : Iterator<TaskManagerLocation> to preference : Iterator<CompletableFuture<TaskManagerLocation>> in method public testLocalityInputBasedForward() : void in class org.apache.flink.runtime.executiongraph.ExecutionVertexLocalityTest |
From |
To |
|
Change Variable Type preference : Iterator<TaskManagerLocation> to preference : Iterator<CompletableFuture<TaskManagerLocation>> in method public testNoLocalityInputLargeAllToAll() : void in class org.apache.flink.runtime.executiongraph.ExecutionVertexLocalityTest |
From |
To |
|
Change Variable Type preference : Iterator<TaskManagerLocation> to preference : Iterator<CompletableFuture<TaskManagerLocation>> in method public testLocalityBasedOnState() : void in class org.apache.flink.runtime.executiongraph.ExecutionVertexLocalityTest |
From |
To |
|
Change Variable Type inputLocations : Set<TaskManagerLocation> to inputLocations : Set<CompletableFuture<TaskManagerLocation>> in method public getPreferredLocationsBasedOnInputs() : Collection<CompletableFuture<TaskManagerLocation>> in class org.apache.flink.runtime.executiongraph.ExecutionVertex |
From |
To |
|
Change Variable Type slotFutures : ArrayList<CompletableFuture<SimpleSlot>> to allAllocationFutures : ArrayList<CompletableFuture<Execution>> in method private scheduleEager(slotProvider SlotProvider, timeout Time) : void in class org.apache.flink.runtime.executiongraph.ExecutionGraph |
From |
To |
|
Change Variable Type slots : ExecutionAndSlot[] to allocationFutures : Collection<CompletableFuture<Execution>> in method private scheduleEager(slotProvider SlotProvider, timeout Time) : void in class org.apache.flink.runtime.executiongraph.ExecutionGraph |
From |
To |
|
Change Variable Type basedOnState : Iterable<TaskManagerLocation> to basedOnState : Collection<CompletableFuture<TaskManagerLocation>> in method public getPreferredLocations() : Collection<CompletableFuture<TaskManagerLocation>> in class org.apache.flink.runtime.executiongraph.ExecutionVertex |
From |
To |
|
Change Variable Type locationPreferences : Iterable<TaskManagerLocation> to locationPreferenceFutures : Collection<CompletableFuture<TaskManagerLocation>> in method public allocateSlot(task ScheduledUnit, allowQueued boolean) : CompletableFuture<SimpleSlot> in class org.apache.flink.runtime.instance.SlotPool.ProviderAndOwner |
From |
To |
|
Change Variable Type future : CompletableFuture<SimpleSlot> to allocationFuture : CompletableFuture<Execution> in method public allocateResourcesForAll(resourceProvider SlotProvider, queued boolean) : Collection<CompletableFuture<Execution>> in class org.apache.flink.runtime.executiongraph.ExecutionJobVertex |
From |
To |
|
Change Variable Type sourceSlot : SimpleSlot to taskManagerLocationFuture : CompletableFuture<TaskManagerLocation> in method public getPreferredLocationsBasedOnInputs() : Collection<CompletableFuture<TaskManagerLocation>> in class org.apache.flink.runtime.executiongraph.ExecutionVertex |
From |
To |