7c2054326b259bde0e8dd28d3428e63fd285454c
Files Diff
- Added: 0
- Removed: 0
- Renamed: 0
- Modified: 23
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Method | 2 | ||
| Rename Method public setKvState(kvState KvStateSnapshot<?,?,?>) : void renamed to public setKvStates(kvStates HashMap<String,KvStateSnapshot<?,?,?>>) : void in class org.apache.flink.streaming.runtime.tasks.StreamTaskState | From | To | |
| Rename Method public getKvState() : KvStateSnapshot<?,?,?> renamed to public getKvStates() : HashMap<String,KvStateSnapshot<?,?,?>> in class org.apache.flink.streaming.runtime.tasks.StreamTaskState | From | To | |
| Change Parameter Type | 2 | ||
| Change Parameter Type kvState : KvStateSnapshot<?,?,?> to kvStates : HashMap<String,KvStateSnapshot<?,?,?>> in method public setKvStates(kvStates HashMap<String,KvStateSnapshot<?,?,?>>) : void in class org.apache.flink.streaming.runtime.tasks.StreamTaskState | From | To | |
| Change Parameter Type tupleTypeInfo : TupleTypeInfo to tupleTypeInfo : TupleTypeInfo<Tuple> in method package ComparableKeySelector(comparator TypeComparator<IN>, keyLength int, tupleTypeInfo TupleTypeInfo<Tuple>) in class org.apache.flink.streaming.util.keys.KeySelectorUtil.ComparableKeySelector | From | To | |
| Change Return Type | 1 | ||
| Change Return Type KvStateSnapshot<?,?,?> to HashMap<String,KvStateSnapshot<?,?,?>> in method public getKvStates() : HashMap<String,KvStateSnapshot<?,?,?>> in class org.apache.flink.streaming.runtime.tasks.StreamTaskState | From | To | |
| Rename Attribute | 4 | ||
| Rename Attribute kvState : KvStateSnapshot<?,?,?> to kvStates : HashMap<String,KvStateSnapshot<?,?,?>> in class org.apache.flink.streaming.runtime.tasks.StreamTaskState | From | To | |
| Rename Attribute counts : OperatorState<NonSerializableLong> to aCounts : OperatorState<NonSerializableLong> in class org.apache.flink.test.checkpointing.PartitionedStateCheckpointingITCase.CounterSink | From | To | |
| Rename Attribute keyValueStateSnapshot : KvStateSnapshot<?,?,?> to keyValueStateSnapshots : HashMap<String,KvStateSnapshot<?,?,?>> in class org.apache.flink.streaming.api.operators.AbstractStreamOperator | From | To | |
| Rename Attribute keyValueState : KvState<?,?,?> to keyValueStates : KvState<?,?,?>[] in class org.apache.flink.streaming.api.operators.AbstractStreamOperator | From | To | |
| Change Variable Type | 2 | ||
| Change Variable Type array2 : Object[] to array2 : String[] in method public testObjectArrays() : void in class org.apache.flink.streaming.util.keys.ArrayKeySelectorTest | From | To | |
| Change Variable Type array1 : Object[] to array1 : String[] in method public testObjectArrays() : void in class org.apache.flink.streaming.util.keys.ArrayKeySelectorTest | From | To | |
| Change Attribute Type | 4 | ||
| Change Attribute Type kvState : KvStateSnapshot<?,?,?> to kvStates : HashMap<String,KvStateSnapshot<?,?,?>> in class org.apache.flink.streaming.runtime.tasks.StreamTaskState | From | To | |
| Change Attribute Type keyValueStateSnapshot : KvStateSnapshot<?,?,?> to keyValueStateSnapshots : HashMap<String,KvStateSnapshot<?,?,?>> in class org.apache.flink.streaming.api.operators.AbstractStreamOperator | From | To | |
| Change Attribute Type keyValueState : KvState<?,?,?> to keyValueStates : KvState<?,?,?>[] in class org.apache.flink.streaming.api.operators.AbstractStreamOperator | From | To | |
| Change Attribute Type tupleTypeInfo : TupleTypeInfo to tupleTypeInfo : TupleTypeInfo<Tuple> in class org.apache.flink.streaming.util.keys.KeySelectorUtil.ComparableKeySelector | From | To | |
| Rename Parameter | 1 | ||
| Rename Parameter kvState : KvStateSnapshot<?,?,?> to kvStates : HashMap<String,KvStateSnapshot<?,?,?>> in method public setKvStates(kvStates HashMap<String,KvStateSnapshot<?,?,?>>) : void in class org.apache.flink.streaming.runtime.tasks.StreamTaskState | From | To |