a7251c56d0d03293f95f0e3b084326a96fe50ce3
Files Diff
- Added: 6
- Removed: 0
- Renamed: 0
- Modified: 5
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Push Down Method | 2 | ||
| Push Down Method public streamBufferWithoutGroups(i Iterator<IN1>, c Collector<OUT>) : void from class org.apache.flink.python.api.streaming.data.PythonStreamer to public streamBufferWithoutGroups(iterator Iterator<IN>, c Collector<OUT>) : void from class org.apache.flink.python.api.streaming.data.PythonSingleInputStreamer | From | To | |
| Push Down Method public streamBufferWithGroups(i1 Iterator<IN1>, i2 Iterator<IN2>, c Collector<OUT>) : void from class org.apache.flink.python.api.streaming.data.PythonStreamer to public streamBufferWithGroups(iterator1 Iterator<IN1>, iterator2 Iterator<IN2>, c Collector<OUT>) : void from class org.apache.flink.python.api.streaming.data.PythonDualInputStreamer | From | To | |
| Change Parameter Type | 1 | ||
| Change Parameter Type i : Iterator<IN1> to iterator : Iterator<IN> in method public streamBufferWithoutGroups(iterator Iterator<IN>, c Collector<OUT>) : void in class org.apache.flink.python.api.streaming.data.PythonSingleInputStreamer | From | To | |
| Change Attribute Type | 3 | ||
| Change Attribute Type sender : PythonSender to sender : S in class org.apache.flink.python.api.streaming.data.PythonStreamer | From | To | |
| Change Attribute Type streamer : PythonStreamer<IN1,IN2,OUT> to streamer : PythonDualInputStreamer<IN1,IN2,OUT> in class org.apache.flink.python.api.functions.PythonCoGroup | From | To | |
| Change Attribute Type streamer : PythonStreamer<IN,IN,OUT> to streamer : PythonSingleInputStreamer<IN,OUT> in class org.apache.flink.python.api.functions.PythonMapPartition | From | To | |
| Rename Parameter | 3 | ||
| Rename Parameter i2 : Iterator<IN2> to iterator2 : Iterator<IN2> in method public streamBufferWithGroups(iterator1 Iterator<IN1>, iterator2 Iterator<IN2>, c Collector<OUT>) : void in class org.apache.flink.python.api.streaming.data.PythonDualInputStreamer | From | To | |
| Rename Parameter i1 : Iterator<IN1> to iterator1 : Iterator<IN1> in method public streamBufferWithGroups(iterator1 Iterator<IN1>, iterator2 Iterator<IN2>, c Collector<OUT>) : void in class org.apache.flink.python.api.streaming.data.PythonDualInputStreamer | From | To | |
| Rename Parameter i : Iterator<IN1> to iterator : Iterator<IN> in method public streamBufferWithoutGroups(iterator Iterator<IN>, c Collector<OUT>) : void in class org.apache.flink.python.api.streaming.data.PythonSingleInputStreamer | From | To |