8be60e6f2a06d3783c744749bb76aac14496e3aa
Files Diff
- Added: 0
- Removed: 0
- Renamed: 0
- Modified: 1
Refactorings reported:
Refactoring Name | Occurences | ||
---|---|---|---|
Rename Method | 3 | ||
Rename Method public testRequestNextInputSplitWithDataSourceFailover() : void renamed to public testRequestNextInputSplitWithLocalFailover() : void in class org.apache.flink.runtime.jobmaster.JobMasterTest | From | To | |
Rename Method public testRequestNextInputSplit() : void renamed to public testRequestNextInputSplitWithGlobalFailover() : void in class org.apache.flink.runtime.jobmaster.JobMasterTest | From | To | |
Rename Method private waitUntilOnlyExecutionIsScheduled(jobMasterGateway JobMasterGateway) : void renamed to private waitUntilAllExecutionsAreScheduled(jobMasterGateway JobMasterGateway) : void in class org.apache.flink.runtime.jobmaster.JobMasterTest | From | To | |
Rename Variable | 7 | ||
Rename Variable testJobGraph : JobGraph to inputSplitjobGraph : JobGraph in method private runRequestNextInputSplitTest(expectedRemainingInputSplits Function<List<List<InputSplit>>,Collection<InputSplit>>) : void in class org.apache.flink.runtime.jobmaster.JobMasterTest | From | To | |
Rename Variable actualInputSplits : List<InputSplit> to allRequestedInputSplits : List<InputSplit> in method private runRequestNextInputSplitTest(expectedRemainingInputSplits Function<List<List<InputSplit>>,Collection<InputSplit>>) : void in class org.apache.flink.runtime.jobmaster.JobMasterTest | From | To | |
Rename Variable inputSplits1 : List<InputSplit> to allRequestedInputSplits : List<InputSplit> in method private runRequestNextInputSplitTest(expectedRemainingInputSplits Function<List<List<InputSplit>>,Collection<InputSplit>>) : void in class org.apache.flink.runtime.jobmaster.JobMasterTest | From | To | |
Rename Variable producer : JobVertex to source : JobVertex in method private runRequestNextInputSplitTest(expectedRemainingInputSplits Function<List<List<InputSplit>>,Collection<InputSplit>>) : void in class org.apache.flink.runtime.jobmaster.JobMasterTest | From | To | |
Rename Variable producerID : JobVertexID to sourceId : JobVertexID in method private runRequestNextInputSplitTest(expectedRemainingInputSplits Function<List<List<InputSplit>>,Collection<InputSplit>>) : void in class org.apache.flink.runtime.jobmaster.JobMasterTest | From | To | |
Rename Variable expectedInputSplits : List<TestingInputSplit> to allInputSplits : List<TestingInputSplit> in method private runRequestNextInputSplitTest(expectedRemainingInputSplits Function<List<List<InputSplit>>,Collection<InputSplit>>) : void in class org.apache.flink.runtime.jobmaster.JobMasterTest | From | To | |
Inline Variable | 2 | ||
Inline Variable expectedInputSplitsMatcher : Matcher<Iterable<? extends InputSplit>> in method public testRequestNextInputSplitWithDataSourceFailover() : void from class org.apache.flink.runtime.jobmaster.JobMasterTest | From | To | |
Inline Variable expectedInputSplitsMatcher : Matcher<Iterable<? extends InputSplit>> in method public testRequestNextInputSplit() : void from class org.apache.flink.runtime.jobmaster.JobMasterTest | From | To | |
Extract Method | 2 | ||
Extract Method private runRequestNextInputSplitTest(expectedRemainingInputSplits Function<List<List<InputSplit>>,Collection<InputSplit>>) : void extracted from public testRequestNextInputSplit() : void in class org.apache.flink.runtime.jobmaster.JobMasterTest | From | To | |
Extract Method private runRequestNextInputSplitTest(expectedRemainingInputSplits Function<List<List<InputSplit>>,Collection<InputSplit>>) : void extracted from public testRequestNextInputSplitWithDataSourceFailover() : void in class org.apache.flink.runtime.jobmaster.JobMasterTest | From | To |