72aa2622299ea492c74c4ab0d3e00f0d323df4a9
Files Diff
- Added: 1
- Removed: 1
- Renamed: 0
- Modified: 0
Refactorings reported:
Refactoring Name | Occurences | ||
---|---|---|---|
Change Parameter Type | 1 | ||
Change Parameter Type numElements : long to failurePos : int in method package OnceFailingPartitionedSum(failurePos int) in class org.apache.flink.test.checkpointing.KeyedStateCheckpointingITCase.OnceFailingPartitionedSum | From | To | |
Move Class | 5 | ||
Move Class org.apache.flink.test.checkpointing.PartitionedStateCheckpointingITCase.CounterSink moved to org.apache.flink.test.checkpointing.KeyedStateCheckpointingITCase.CounterSink | From | To | |
Move Class org.apache.flink.test.checkpointing.PartitionedStateCheckpointingITCase.IdentityKeySelector moved to org.apache.flink.test.checkpointing.KeyedStateCheckpointingITCase.IdentityKeySelector | From | To | |
Move Class org.apache.flink.test.checkpointing.PartitionedStateCheckpointingITCase.OnceFailingPartitionedSum moved to org.apache.flink.test.checkpointing.KeyedStateCheckpointingITCase.OnceFailingPartitionedSum | From | To | |
Move Class org.apache.flink.test.checkpointing.PartitionedStateCheckpointingITCase.NonSerializableLong moved to org.apache.flink.test.checkpointing.KeyedStateCheckpointingITCase.NonSerializableLong | From | To | |
Move Class org.apache.flink.test.checkpointing.PartitionedStateCheckpointingITCase.IntGeneratingSourceFunction moved to org.apache.flink.test.checkpointing.KeyedStateCheckpointingITCase.IntGeneratingSourceFunction | From | To | |
Change Attribute Type | 3 | ||
Change Attribute Type numElements : long to numElements : int in class org.apache.flink.test.checkpointing.KeyedStateCheckpointingITCase.IntGeneratingSourceFunction | From | To | |
Change Attribute Type count : long to count : int in class org.apache.flink.test.checkpointing.KeyedStateCheckpointingITCase.OnceFailingPartitionedSum | From | To | |
Change Attribute Type value : Long to value : long in class org.apache.flink.test.checkpointing.KeyedStateCheckpointingITCase.NonSerializableLong | From | To | |
Rename Parameter | 2 | ||
Rename Parameter numElements : long to failurePos : int in method package OnceFailingPartitionedSum(failurePos int) in class org.apache.flink.test.checkpointing.KeyedStateCheckpointingITCase.OnceFailingPartitionedSum | From | To | |
Rename Parameter o : Object to obj : Object in method public equals(obj Object) : boolean in class org.apache.flink.test.checkpointing.KeyedStateCheckpointingITCase.NonSerializableLong | From | To |