53ee80e7873e126242c1ebac949a8463f4367a6b
Files Diff
- Added: 1
- Removed: 0
- Renamed: 0
- Modified: 7
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Method | 5 | ||
| Rename Method public setPartitioner() : void renamed to public createPartitioner() : StreamPartitioner<Tuple> in class org.apache.flink.streaming.runtime.partitioner.RescalePartitionerTest | From | To | |
| Rename Method public setPartitioner() : void renamed to public createPartitioner() : StreamPartitioner<Tuple> in class org.apache.flink.streaming.runtime.partitioner.ShufflePartitionerTest | From | To | |
| Rename Method public setPartitioner() : void renamed to public createPartitioner() : StreamPartitioner<Tuple> in class org.apache.flink.streaming.runtime.partitioner.GlobalPartitionerTest | From | To | |
| Rename Method public setPartitioner() : void renamed to public createPartitioner() : StreamPartitioner<Tuple> in class org.apache.flink.streaming.runtime.partitioner.RebalancePartitionerTest | From | To | |
| Rename Method public setPartitioner() : void renamed to public createPartitioner() : StreamPartitioner<Tuple> in class org.apache.flink.streaming.runtime.partitioner.ForwardPartitionerTest | From | To | |
| Pull Up Method | 4 | ||
| Pull Up Method public testSelectChannelsLength() : void from class org.apache.flink.streaming.runtime.partitioner.RebalancePartitionerTest to public testSelectChannelsLength() : void from class org.apache.flink.streaming.runtime.partitioner.StreamPartitionerTest | From | To | |
| Pull Up Method public testSelectChannelsLength() : void from class org.apache.flink.streaming.runtime.partitioner.ForwardPartitionerTest to public testSelectChannelsLength() : void from class org.apache.flink.streaming.runtime.partitioner.StreamPartitionerTest | From | To | |
| Pull Up Method public testSelectChannelsLength() : void from class org.apache.flink.streaming.runtime.partitioner.ShufflePartitionerTest to public testSelectChannelsLength() : void from class org.apache.flink.streaming.runtime.partitioner.StreamPartitionerTest | From | To | |
| Pull Up Method public testSelectChannelsLength() : void from class org.apache.flink.streaming.runtime.partitioner.RescalePartitionerTest to public testSelectChannelsLength() : void from class org.apache.flink.streaming.runtime.partitioner.StreamPartitionerTest | From | To | |
| Pull Up Attribute | 5 | ||
| Pull Up Attribute private streamRecord : StreamRecord<Tuple> from class org.apache.flink.streaming.runtime.partitioner.GlobalPartitionerTest to protected streamRecord : StreamRecord<Tuple> from class org.apache.flink.streaming.runtime.partitioner.StreamPartitionerTest | From | To | |
| Pull Up Attribute private streamRecord : StreamRecord<Tuple> from class org.apache.flink.streaming.runtime.partitioner.ShufflePartitionerTest to protected streamRecord : StreamRecord<Tuple> from class org.apache.flink.streaming.runtime.partitioner.StreamPartitionerTest | From | To | |
| Pull Up Attribute private streamRecord : StreamRecord<Tuple> from class org.apache.flink.streaming.runtime.partitioner.RebalancePartitionerTest to protected streamRecord : StreamRecord<Tuple> from class org.apache.flink.streaming.runtime.partitioner.StreamPartitionerTest | From | To | |
| Pull Up Attribute private streamRecord : StreamRecord<Tuple> from class org.apache.flink.streaming.runtime.partitioner.ForwardPartitionerTest to protected streamRecord : StreamRecord<Tuple> from class org.apache.flink.streaming.runtime.partitioner.StreamPartitionerTest | From | To | |
| Pull Up Attribute private streamRecord : StreamRecord<Tuple> from class org.apache.flink.streaming.runtime.partitioner.RescalePartitionerTest to protected streamRecord : StreamRecord<Tuple> from class org.apache.flink.streaming.runtime.partitioner.StreamPartitionerTest | From | To | |
| Change Return Type | 5 | ||
| Change Return Type void to StreamPartitioner<Tuple> in method public createPartitioner() : StreamPartitioner<Tuple> in class org.apache.flink.streaming.runtime.partitioner.RescalePartitionerTest | From | To | |
| Change Return Type void to StreamPartitioner<Tuple> in method public createPartitioner() : StreamPartitioner<Tuple> in class org.apache.flink.streaming.runtime.partitioner.GlobalPartitionerTest | From | To | |
| Change Return Type void to StreamPartitioner<Tuple> in method public createPartitioner() : StreamPartitioner<Tuple> in class org.apache.flink.streaming.runtime.partitioner.RebalancePartitionerTest | From | To | |
| Change Return Type void to StreamPartitioner<Tuple> in method public createPartitioner() : StreamPartitioner<Tuple> in class org.apache.flink.streaming.runtime.partitioner.ForwardPartitionerTest | From | To | |
| Change Return Type void to StreamPartitioner<Tuple> in method public createPartitioner() : StreamPartitioner<Tuple> in class org.apache.flink.streaming.runtime.partitioner.ShufflePartitionerTest | From | To | |
| Extract Superclass | 1 | ||
| Extract Superclass org.apache.flink.streaming.runtime.partitioner.StreamPartitionerTest from classes [org.apache.flink.streaming.runtime.partitioner.ForwardPartitionerTest, org.apache.flink.streaming.runtime.partitioner.GlobalPartitionerTest, org.apache.flink.streaming.runtime.partitioner.RebalancePartitionerTest, org.apache.flink.streaming.runtime.partitioner.ShufflePartitionerTest, org.apache.flink.streaming.runtime.partitioner.RescalePartitionerTest] | From | To | |
| Rename Attribute | 3 | ||
| Rename Attribute sd1 : SerializationDelegate<StreamRecord<Tuple2<String,Integer>>> to serializationDelegate1 : SerializationDelegate<StreamRecord<Tuple2<String,Integer>>> in class org.apache.flink.streaming.runtime.partitioner.KeyGroupStreamPartitionerTest | From | To | |
| Rename Attribute sd : SerializationDelegate<StreamRecord<Tuple>> to serializationDelegate : SerializationDelegate<StreamRecord<Tuple>> in class org.apache.flink.streaming.runtime.partitioner.BroadcastPartitionerTest | From | To | |
| Rename Attribute sd2 : SerializationDelegate<StreamRecord<Tuple2<String,Integer>>> to serializationDelegate2 : SerializationDelegate<StreamRecord<Tuple2<String,Integer>>> in class org.apache.flink.streaming.runtime.partitioner.KeyGroupStreamPartitionerTest | From | To |