6774054a7bf1ff6947ec774d74ef6f3941c58b27
Files Diff
- Added: 7
- Removed: 0
- Renamed: 0
- Modified: 41
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Change Parameter Type | 2 | ||
| Change Parameter Type other : Accumulator<T,SerializableHashSet<T>> to other : Accumulator<T,HashSet<T>> in method public merge(other Accumulator<T,HashSet<T>>) : void in class org.apache.flink.test.accumulators.AccumulatorITCase.SetAccumulator | From | To | |
| Change Parameter Type other : Accumulator<T,SerializableHashSet<T>> to other : Accumulator<T,HashSet<T>> in method public merge(other Accumulator<T,HashSet<T>>) : void in class org.apache.flink.test.recordJobs.wordcount.WordCountAccumulators.SetAccumulator | From | To | |
| Rename Variable | 1 | ||
| Rename Variable jobAccumulator : JobAccumulators to acc : JobAccumulators in method public getJobAccumulatorResults(jobID JobID) : Map<String,Object> in class org.apache.flink.runtime.jobmanager.accumulators.AccumulatorManager | From | To | |
| Pull Up Attribute | 1 | ||
| Pull Up Attribute private serializedData : byte[] from class org.apache.flink.runtime.accumulators.AccumulatorEvent to private serializedData : byte[] from class org.apache.flink.runtime.util.SerializedValue | From | To | |
| Change Return Type | 5 | ||
| Change Return Type Accumulator<Long,Long> to LongCounter in method public clone() : LongCounter in class org.apache.flink.api.common.accumulators.LongCounter | From | To | |
| Change Return Type Accumulator<T,SerializableHashSet<T>> to Accumulator<T,HashSet<T>> in method public clone() : Accumulator<T,HashSet<T>> in class org.apache.flink.test.accumulators.AccumulatorITCase.SetAccumulator | From | To | |
| Change Return Type Accumulator<T,SerializableHashSet<T>> to Accumulator<T,HashSet<T>> in method public clone() : Accumulator<T,HashSet<T>> in class org.apache.flink.test.recordJobs.wordcount.WordCountAccumulators.SetAccumulator | From | To | |
| Change Return Type SerializableHashSet<T> to HashSet<T> in method public getLocalValue() : HashSet<T> in class org.apache.flink.test.accumulators.AccumulatorITCase.SetAccumulator | From | To | |
| Change Return Type SerializableHashSet<T> to HashSet<T> in method public getLocalValue() : HashSet<T> in class org.apache.flink.test.recordJobs.wordcount.WordCountAccumulators.SetAccumulator | From | To | |
| Extract Superclass | 1 | ||
| Extract Superclass org.apache.flink.runtime.util.SerializedValue from classes [org.apache.flink.runtime.accumulators.AccumulatorEvent] | From | To | |
| Change Variable Type | 2 | ||
| Change Variable Type result : JobExecutionResult to result : SerializedJobExecutionResult in method public execute(jobName String) : JobExecutionResult in class org.apache.flink.test.util.TestEnvironment | From | To | |
| Change Variable Type accumulator : Entry<String,Object> to accumulator : StringifiedAccumulatorResult in method private writeJsonForArchivedJob(wrt PrintWriter, graph ExecutionGraph) : void in class org.apache.flink.runtime.jobmanager.web.JobManagerInfoServlet | From | To | |
| Change Attribute Type | 4 | ||
| Change Attribute Type set : SerializableHashSet<T> to set : HashSet<T> in class org.apache.flink.test.recordJobs.wordcount.WordCountAccumulators.SetAccumulator | From | To | |
| Change Attribute Type accumulator : ListAccumulator<T> to accumulator : SerializedListAccumulator<T> in class org.apache.flink.api.java.Utils.CollectHelper | From | To | |
| Change Attribute Type set : SerializableHashSet<T> to set : HashSet<T> in class org.apache.flink.test.accumulators.AccumulatorITCase.SetAccumulator | From | To | |
| Change Attribute Type localValue : ArrayList<byte[]> to localValue : ArrayList<T> in class org.apache.flink.api.common.accumulators.ListAccumulator | From | To |