ec975aaba79449bd93020f296b05ea509ea57bdc
Files Diff
- Added: 6
- Removed: 3
- Renamed: 0
- Modified: 50
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Class | 1 | ||
| Rename Class org.apache.flink.streaming.runtime.partitioner.HashPartitionerTest renamed to org.apache.flink.streaming.runtime.partitioner.KeyGroupStreamPartitionerTest | From | To | |
| Rename Attribute | 1 | ||
| Rename Attribute hashPartitioner : HashPartitioner<Tuple2<String,Integer>> to keyGroupPartitioner : KeyGroupStreamPartitioner<Tuple2<String,Integer>,String> in class org.apache.flink.streaming.runtime.partitioner.KeyGroupStreamPartitionerTest | From | To | |
| Change Attribute Type | 1 | ||
| Change Attribute Type hashPartitioner : HashPartitioner<Tuple2<String,Integer>> to keyGroupPartitioner : KeyGroupStreamPartitioner<Tuple2<String,Integer>,String> in class org.apache.flink.streaming.runtime.partitioner.KeyGroupStreamPartitionerTest | From | To | |
| Extract Method | 2 | ||
| Extract Method public waitForTaskRunning(timeout long) : void extracted from public waitForTaskRunning() : void in class org.apache.flink.streaming.runtime.tasks.StreamTaskTestHarness | From | To | |
| Extract Method public waitForTaskCompletion(timeout long) : void extracted from public waitForTaskCompletion() : void in class org.apache.flink.streaming.runtime.tasks.StreamTaskTestHarness | From | To |