5c637a6a071b720b7acf8c725ffcbcb07d2f5745
Files Diff
- Added: 0
- Removed: 0
- Renamed: 0
- Modified: 2
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Extract Attribute | 1 | ||
| Extract Attribute private PARALLELISM : int in class org.apache.flink.test.streaming.runtime.PartitionerITCase | From | To | |
| Rename Parameter | 2 | ||
| Rename Parameter numberOfOutputChannels : int to numChannels : int in method private resetValue(numChannels int, newChannel int) : int in class org.apache.flink.streaming.runtime.partitioner.RebalancePartitioner | From | To | |
| Rename Parameter numberOfOutputChannels : int to numChannels : int in method public selectChannels(record SerializationDelegate<StreamRecord<T>>, numChannels int) : int[] in class org.apache.flink.streaming.runtime.partitioner.RebalancePartitioner | From | To |