ddba1b69f43cbb885e178dfaafa120f1fe196a13
Files Diff
- Added: 8
- Removed: 26
- Renamed: 0
- Modified: 25
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Method | 2 | ||
| Rename Method public getSingleAbstractMethodNoAbstractMethods() : void renamed to public testSingleAbstractMethodNoAbstractMethods() : void in class org.apache.flink.api.java.typeutils.LambdaExtractionTest | From | To | |
| Rename Method public getSingleAbstractMethodNotAnInterface() : void renamed to public testSingleAbstractMethodNotAnInterface() : void in class org.apache.flink.api.java.typeutils.LambdaExtractionTest | From | To | |
| Move And Rename Method | 4 | ||
| Move And Rename Method public testFilterFunctionOnLambda4() : void from class org.apache.flink.runtime.util.JarFileCreatorLambdaTest to public testFilterWithIndirection() : void from class org.apache.flink.runtime.util.JarFileCreatorTest | From | To | |
| Move And Rename Method public testFilterFunctionOnLambda2() : void from class org.apache.flink.runtime.util.JarFileCreatorLambdaTest to public testFilterWithLambda() : void from class org.apache.flink.runtime.util.JarFileCreatorTest | From | To | |
| Move And Rename Method protected testProgram() : void from class org.apache.flink.test.api.java.operators.lambdas.CoGroupITCase to public testCoGroupLambda() : void from class org.apache.flink.test.operators.CoGroupITCase | From | To | |
| Move And Rename Method public testFilterFunctionOnLambda1() : void from class org.apache.flink.runtime.util.JarFileCreatorLambdaTest to public testFilterWithMethodReference() : void from class org.apache.flink.runtime.util.JarFileCreatorTest | From | To | |
| Rename Variable | 1 | ||
| Rename Variable resultType : TypeInformation<OUT> to outputType : TypeInformation<OUT> in method public process(processJoinFunction ProcessJoinFunction<IN1,IN2,OUT>) : SingleOutputStreamOperator<OUT> in class org.apache.flink.streaming.api.datastream.KeyedStream.IntervalJoined | From | To | |
| Move Source Folder | 1 | ||
| Move Source Folder flink-java8 to flink-runtime | From | To | |
| Change Return Type | 1 | ||
| Change Return Type DataStream<OUT> to SingleOutputStreamOperator<OUT> in method public process(processJoinFunction ProcessJoinFunction<IN1,IN2,OUT>) : SingleOutputStreamOperator<OUT> in class org.apache.flink.streaming.api.datastream.KeyedStream.IntervalJoined | From | To | |
| Rename Class | 3 | ||
| Rename Class org.apache.flink.runtime.util.jartestprogram.FilterLambda2 renamed to org.apache.flink.runtime.util.jartestprogram.FilterWithIndirection | From | To | |
| Rename Class org.apache.flink.runtime.util.jartestprogram.FilterLambda1 renamed to org.apache.flink.runtime.util.jartestprogram.FilterWithLambda | From | To | |
| Rename Class org.apache.flink.runtime.util.jartestprogram.FilterLambda3 renamed to org.apache.flink.runtime.util.jartestprogram.FilterWithMethodReference | From | To | |
| Move Class | 2 | ||
| Move Class org.apache.flink.test.api.java.operators.lambdas.MapITCase.Trade moved to org.apache.flink.test.operators.MapITCase.Trade | From | To | |
| Move Class org.apache.flink.api.java.type.lambdas.LambdaExtractionTest moved to org.apache.flink.api.java.typeutils.LambdaExtractionTest | From | To | |
| Parameterize Variable | 2 | ||
| Parameterize Variable otherKey : TypeInformation<KEY> to keyType : TypeInformation<KEY> in method public equalTo(keySelector KeySelector<T2,KEY>, keyType TypeInformation<KEY>) : EqualTo in class org.apache.flink.streaming.api.datastream.CoGroupedStreams.Where | From | To | |
| Parameterize Variable otherKey : TypeInformation<KEY> to keyType : TypeInformation<KEY> in method public equalTo(keySelector KeySelector<T2,KEY>, keyType TypeInformation<KEY>) : EqualTo in class org.apache.flink.streaming.api.datastream.JoinedStreams.Where | From | To | |
| Extract Method | 5 | ||
| Extract Method public process(processJoinFunction ProcessJoinFunction<IN1,IN2,OUT>, outputType TypeInformation<OUT>) : SingleOutputStreamOperator<OUT> extracted from public process(udf ProcessJoinFunction<IN1,IN2,OUT>) : DataStream<OUT> in class org.apache.flink.streaming.api.datastream.KeyedStream.IntervalJoined | From | To | |
| Extract Method public where(keySelector KeySelector<T1,KEY>, keyType TypeInformation<KEY>) : Where<KEY> extracted from public where(keySelector KeySelector<T1,KEY>) : Where<KEY> in class org.apache.flink.streaming.api.datastream.CoGroupedStreams | From | To | |
| Extract Method public equalTo(keySelector KeySelector<T2,KEY>, keyType TypeInformation<KEY>) : EqualTo extracted from public equalTo(keySelector KeySelector<T2,KEY>) : EqualTo in class org.apache.flink.streaming.api.datastream.CoGroupedStreams.Where | From | To | |
| Extract Method public where(keySelector KeySelector<T1,KEY>, keyType TypeInformation<KEY>) : Where<KEY> extracted from public where(keySelector KeySelector<T1,KEY>) : Where<KEY> in class org.apache.flink.streaming.api.datastream.JoinedStreams | From | To | |
| Extract Method public equalTo(keySelector KeySelector<T2,KEY>, keyType TypeInformation<KEY>) : EqualTo extracted from public equalTo(keySelector KeySelector<T2,KEY>) : EqualTo in class org.apache.flink.streaming.api.datastream.JoinedStreams.Where | From | To | |
| Rename Parameter | 2 | ||
| Rename Parameter udf : ProcessJoinFunction<IN1,IN2,OUT> to processJoinFunction : ProcessJoinFunction<IN1,IN2,OUT> in method public process(processJoinFunction ProcessJoinFunction<IN1,IN2,OUT>) : SingleOutputStreamOperator<OUT> in class org.apache.flink.streaming.api.datastream.KeyedStream.IntervalJoined | From | To | |
| Rename Parameter udf : ProcessJoinFunction<IN1,IN2,OUT> to processJoinFunction : ProcessJoinFunction<IN1,IN2,OUT> in method public process(processJoinFunction ProcessJoinFunction<IN1,IN2,OUT>, outputType TypeInformation<OUT>) : SingleOutputStreamOperator<OUT> in class org.apache.flink.streaming.api.datastream.KeyedStream.IntervalJoined | From | To |