flink c8a6471a580cb05113e325514682e4e56aa42198

c8a6471a580cb05113e325514682e4e56aa42198

Files Diff

Added: 1
Removed: 0
Renamed: 0
Modified: 20

Link to commit

Dependency Action

Refactorings reported:

Refactoring Name	Occurences
Rename Method	4
Rename Method public getPriorAllocations() : Collection<AllocationID> renamed to public getPreferredAllocations() : Collection<AllocationID> in class org.apache.flink.runtime.clusterframework.types.SlotProfile	From	To
Rename Method public matchPreviousLocationNotAvailable() : void renamed to public matchPreviousLocationNotAvailableButByLocality() : void in class org.apache.flink.runtime.clusterframework.types.SlotProfileTest	From	To
Rename Method public findMatchWithLocality(slotProfile SlotProfile, candidates Stream<IN>, contextExtractor Function<IN,SlotContext>, additionalRequirementsFilter Predicate<IN>, resultProducer BiFunction<IN,Locality,OUT>) : OUT renamed to protected doFindMatchWithLocality(slotProfile SlotProfile, candidates Stream<IN>, contextExtractor Function<IN,SlotInfo>, additionalRequirementsFilter Predicate<IN>, resultProducer BiFunction<IN,Locality,OUT>) : OUT in class org.apache.flink.runtime.jobmaster.slotpool.LocationPreferenceSchedulingStrategy	From	To
Rename Method public testLocalRecovery() : void renamed to private testLocalRecoveryInternal(failoverStrategyValue String) : void in class org.apache.flink.test.runtime.SchedulingITCase	From	To
Change Parameter Type	5
Change Parameter Type contextExtractor : Function<IN,SlotContext> to contextExtractor : Function<IN,SlotInfo> in method protected doFindMatchWithLocality(slotProfile SlotProfile, candidates Stream<IN>, contextExtractor Function<IN,SlotInfo>, additionalRequirementsFilter Predicate<IN>, resultProducer BiFunction<IN,Locality,OUT>) : OUT in class org.apache.flink.runtime.jobmaster.slotpool.LocationPreferenceSchedulingStrategy	From	To
Change Parameter Type candidates : Stream<IN> to candidates : Supplier<Stream<IN>> in method public findMatchWithLocality(slotProfile SlotProfile, candidates Supplier<Stream<IN>>, contextExtractor Function<IN,SlotInfo>, additionalRequirementsFilter Predicate<IN>, resultProducer BiFunction<IN,Locality,OUT>) : OUT in class org.apache.flink.runtime.jobmaster.slotpool.SchedulingStrategy	From	To
Change Parameter Type contextExtractor : Function<IN,SlotContext> to contextExtractor : Function<IN,SlotInfo> in method public findMatchWithLocality(slotProfile SlotProfile, candidates Supplier<Stream<IN>>, contextExtractor Function<IN,SlotInfo>, additionalRequirementsFilter Predicate<IN>, resultProducer BiFunction<IN,Locality,OUT>) : OUT in class org.apache.flink.runtime.jobmaster.slotpool.SchedulingStrategy	From	To
Change Parameter Type candidates : Stream<IN> to candidates : Supplier<Stream<IN>> in method public findMatchWithLocality(slotProfile SlotProfile, candidates Supplier<Stream<IN>>, contextExtractor Function<IN,SlotInfo>, additionalRequirementsFilter Predicate<IN>, resultProducer BiFunction<IN,Locality,OUT>) : OUT in class org.apache.flink.runtime.jobmaster.slotpool.PreviousAllocationSchedulingStrategy	From	To
Change Parameter Type contextExtractor : Function<IN,SlotContext> to contextExtractor : Function<IN,SlotInfo> in method public findMatchWithLocality(slotProfile SlotProfile, candidates Supplier<Stream<IN>>, contextExtractor Function<IN,SlotInfo>, additionalRequirementsFilter Predicate<IN>, resultProducer BiFunction<IN,Locality,OUT>) : OUT in class org.apache.flink.runtime.jobmaster.slotpool.PreviousAllocationSchedulingStrategy	From	To
Change Variable Type	1
Change Variable Type slotContext : SlotContext to slotContext : SlotInfo in method protected doFindMatchWithLocality(slotProfile SlotProfile, candidates Stream<IN>, contextExtractor Function<IN,SlotInfo>, additionalRequirementsFilter Predicate<IN>, resultProducer BiFunction<IN,Locality,OUT>) : OUT in class org.apache.flink.runtime.jobmaster.slotpool.LocationPreferenceSchedulingStrategy	From	To
Extract Interface	1
Extract Interface org.apache.flink.runtime.jobmaster.SlotInfo from classes [org.apache.flink.runtime.jobmaster.SlotContext]	From	To
Inline Variable	1
Inline Variable slotSharingGroupId : SlotSharingGroupId in method public allocateSlot(slotRequestId SlotRequestId, task ScheduledUnit, slotProfile SlotProfile, allowQueuedScheduling boolean, allocationTimeout Time) : CompletableFuture<LogicalSlot> from class org.apache.flink.runtime.jobmaster.slotpool.SlotPool	From	To
Extract Method	4
Extract Method private releaseSingleSlot(slotRequestId SlotRequestId, cause Throwable) : void extracted from public releaseSlot(slotRequestId SlotRequestId, slotSharingGroupId SlotSharingGroupId, cause Throwable) : CompletableFuture<Acknowledge> in class org.apache.flink.runtime.jobmaster.slotpool.SlotPool	From	To
Extract Method private allocateSharedSlot(slotRequestId SlotRequestId, task ScheduledUnit, slotProfile SlotProfile, allowQueuedScheduling boolean, allocationTimeout Time) : CompletableFuture<LogicalSlot> extracted from public allocateSlot(slotRequestId SlotRequestId, task ScheduledUnit, slotProfile SlotProfile, allowQueuedScheduling boolean, allocationTimeout Time) : CompletableFuture<LogicalSlot> in class org.apache.flink.runtime.jobmaster.slotpool.SlotPool	From	To
Extract Method private allocateSingleSlot(slotRequestId SlotRequestId, slotProfile SlotProfile, allowQueuedScheduling boolean, allocationTimeout Time) : CompletableFuture<LogicalSlot> extracted from public allocateSlot(slotRequestId SlotRequestId, task ScheduledUnit, slotProfile SlotProfile, allowQueuedScheduling boolean, allocationTimeout Time) : CompletableFuture<LogicalSlot> in class org.apache.flink.runtime.jobmaster.slotpool.SlotPool	From	To
Extract Method private releaseSharedSlot(slotRequestId SlotRequestId, slotSharingGroupId SlotSharingGroupId, cause Throwable) : void extracted from public releaseSlot(slotRequestId SlotRequestId, slotSharingGroupId SlotSharingGroupId, cause Throwable) : CompletableFuture<Acknowledge> in class org.apache.flink.runtime.jobmaster.slotpool.SlotPool	From	To
Rename Parameter	1
Rename Parameter priorAllocations : Collection<AllocationID> to preferredAllocations : Collection<AllocationID> in method public SlotProfile(resourceProfile ResourceProfile, preferredLocations Collection<TaskManagerLocation>, preferredAllocations Collection<AllocationID>) in class org.apache.flink.runtime.clusterframework.types.SlotProfile	From	To

c8a6471a580cb05113e325514682e4e56aa42198

Files Diff

Link to commit

Third party dependencies:

Refactorings reported: