6685b0bac54b95705426fd78bb819171271004e6
Files Diff
- Added: 3
- Removed: 0
- Renamed: 0
- Modified: 36
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Method | 5 | ||
| Rename Method public close() : void renamed to public cancel() : void in class org.apache.flink.streaming.api.functions.source.SocketTextStreamFunction | From | To | |
| Rename Method public close() : void renamed to public cancel() : void in class org.apache.flink.streaming.connectors.kafka.api.KafkaSource | From | To | |
| Rename Method public next() : Integer renamed to private getTrainingData() : Integer in class org.apache.flink.streaming.examples.ml.IncrementalLearningSkeleton.TrainingDataSource | From | To | |
| Rename Method public next() : Integer renamed to private getNewData() : Integer in class org.apache.flink.streaming.examples.ml.IncrementalLearningSkeleton.NewDataSource | From | To | |
| Rename Method private closeConnection() : void renamed to public close() : void in class org.apache.flink.streaming.connectors.twitter.TwitterSource | From | To | |
| Move And Inline Method | 1 | ||
| Move And Inline Method public open(parameters Configuration) : void moved from class org.apache.flink.streaming.api.functions.source.FromElementsFunction to class org.apache.flink.streaming.connectors.kafka.KafkaITCase & inlined to public bigRecordTestTopology() : void | From | To | |
| Change Parameter Type | 5 | ||
| Change Parameter Type newDataPoint : Tuple2<RectangleClass,Integer> to newDataPoint : Tuple2<Rectangle,Integer> in method public getDelta(oldDataPoint Tuple2<Rectangle,Integer>, newDataPoint Tuple2<Rectangle,Integer>) : double in class org.apache.flink.streaming.api.complex.ComplexIntegrationTest.MyDelta | From | To | |
| Change Parameter Type out : Collector<Tuple2<RectangleClass,Integer>> to out : Collector<Tuple2<Rectangle,Integer>> in method public mapWindow(values Iterable<Tuple2<Rectangle,Integer>>, out Collector<Tuple2<Rectangle,Integer>>) : void in class org.apache.flink.streaming.api.complex.ComplexIntegrationTest.MyWindowMapFunction | From | To | |
| Change Parameter Type value : RectangleClass to value : Rectangle in method public map(value Rectangle) : Tuple2<Rectangle,Integer> in class org.apache.flink.streaming.api.complex.ComplexIntegrationTest.RectangleMapFunction | From | To | |
| Change Parameter Type oldDataPoint : Tuple2<RectangleClass,Integer> to oldDataPoint : Tuple2<Rectangle,Integer> in method public getDelta(oldDataPoint Tuple2<Rectangle,Integer>, newDataPoint Tuple2<Rectangle,Integer>) : double in class org.apache.flink.streaming.api.complex.ComplexIntegrationTest.MyDelta | From | To | |
| Change Parameter Type values : Iterable<Tuple2<RectangleClass,Integer>> to values : Iterable<Tuple2<Rectangle,Integer>> in method public mapWindow(values Iterable<Tuple2<Rectangle,Integer>>, out Collector<Tuple2<Rectangle,Integer>>) : void in class org.apache.flink.streaming.api.complex.ComplexIntegrationTest.MyWindowMapFunction | From | To | |
| Move Method | 2 | ||
| Move Method public open(config Configuration) : void from class org.apache.flink.test.recovery.ProcessFailureStreamingRecoveryITCase.SleepyDurableGenerateSequence to public open(parameters Configuration) : void from class org.apache.flink.test.recovery.ProcessFailureStreamingRecoveryITCase.CheckpointedSink | From | To | |
| Move Method public run() : void from class org.apache.flink.streaming.api.operators.StreamSource to public run(checkpointLock Object, out Collector<OUT>) : void from class org.apache.flink.streaming.connectors.rabbitmq.RMQSource | From | To | |
| Change Return Type | 2 | ||
| Change Return Type Tuple2<RectangleClass,Integer> to Tuple2<Rectangle,Integer> in method public map(value Rectangle) : Tuple2<Rectangle,Integer> in class org.apache.flink.streaming.api.complex.ComplexIntegrationTest.RectangleMapFunction | From | To | |
| Change Return Type RectangleClass to Rectangle in method public next() : Rectangle in class org.apache.flink.streaming.api.complex.ComplexIntegrationTest.Rectangle | From | To | |
| Move Attribute | 3 | ||
| Move Attribute private congruence : long from class org.apache.flink.test.recovery.ProcessFailureStreamingRecoveryITCase.SleepyDurableGenerateSequence to private congruence : long from class org.apache.flink.test.recovery.ProcessFailureStreamingRecoveryITCase.CheckpointedSink | From | To | |
| Move Attribute private toCollect : long from class org.apache.flink.test.recovery.ProcessFailureStreamingRecoveryITCase.SleepyDurableGenerateSequence to private toCollect : long from class org.apache.flink.test.recovery.ProcessFailureStreamingRecoveryITCase.CheckpointedSink | From | To | |
| Move Attribute private stepSize : long from class org.apache.flink.test.recovery.ProcessFailureStreamingRecoveryITCase.SleepyDurableGenerateSequence to private stepSize : long from class org.apache.flink.test.recovery.ProcessFailureStreamingRecoveryITCase.CheckpointedSink | From | To | |
| Rename Class | 1 | ||
| Rename Class org.apache.flink.streaming.api.complex.ComplexIntegrationTest.RectangleClass renamed to org.apache.flink.streaming.api.complex.ComplexIntegrationTest.Rectangle | From | To | |
| Change Attribute Type | 1 | ||
| Change Attribute Type rectangle : RectangleClass to rectangle : Rectangle in class org.apache.flink.streaming.api.complex.ComplexIntegrationTest.RectangleSource | From | To | |
| Rename Parameter | 1 | ||
| Rename Parameter config : Configuration to parameters : Configuration in method public open(parameters Configuration) : void in class org.apache.flink.test.recovery.ProcessFailureStreamingRecoveryITCase.CheckpointedSink | From | To |