8b8dd8031819336200005e690ca66deaed5b1268
Files Diff
- Added: 0
- Removed: 0
- Renamed: 0
- Modified: 5
Refactorings reported:
Refactoring Name | Occurences | ||
---|---|---|---|
Move Method | 2 | ||
Move Method public getNamespaceSerializer() : TypeSerializer<N> from class org.apache.flink.streaming.api.operators.InternalTimersSnapshot to public getNamespaceSerializer() : TypeSerializer<N> from class org.apache.flink.streaming.api.operators.InternalTimerServiceImpl | From | To | |
Move Method public getKeySerializer() : TypeSerializer<K> from class org.apache.flink.streaming.api.operators.InternalTimersSnapshot to public getKeySerializer() : TypeSerializer<K> from class org.apache.flink.streaming.api.operators.InternalTimerServiceImpl | From | To | |
Move Attribute | 2 | ||
Move Attribute private namespaceSerializer : TypeSerializer<N> from class org.apache.flink.streaming.api.operators.InternalTimersSnapshot to protected namespaceSerializer : TypeSerializer<N> from class org.apache.flink.streaming.api.operators.InternalTimersSnapshotReaderWriters.AbstractInternalTimersSnapshotWriter | From | To | |
Move Attribute private keySerializer : TypeSerializer<K> from class org.apache.flink.streaming.api.operators.InternalTimersSnapshot to protected keySerializer : TypeSerializer<K> from class org.apache.flink.streaming.api.operators.InternalTimersSnapshotReaderWriters.AbstractInternalTimersSnapshotWriter | From | To | |
Change Variable Type | 2 | ||
Change Variable Type timersSnapshot : InternalTimersSnapshot<?,?> to timersSnapshot : InternalTimersSnapshot<Integer,String> in method private testSnapshotAndRestore(snapshotVersion int) : void in class org.apache.flink.streaming.api.operators.InternalTimerServiceImplTest | From | To | |
Change Variable Type timersSnapshot : InternalTimersSnapshot<?,?> to timersSnapshot : InternalTimersSnapshot<Integer,String> in method private testSnapshotAndRebalancingRestore(snapshotVersion int) : void in class org.apache.flink.streaming.api.operators.InternalTimerServiceImplTest | From | To | |
Split Attribute | 1 | ||
Split Attribute timersSnapshot : InternalTimersSnapshot<K,N> to [keySerializer : TypeSerializer<K>, namespaceSerializer : TypeSerializer<N>] in class org.apache.flink.streaming.api.operators.InternalTimersSnapshotReaderWriters.AbstractInternalTimersSnapshotWriter | From | To |