14aae5937e27a9df806dc6cce9bcb88c9188802b
Files Diff
- Added: 0
- Removed: 0
- Renamed: 0
- Modified: 2
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Extract Variable | 2 | ||
| Extract Variable keySerializer : TypeSerializer<K> in method protected restoreKeyAndNamespaceSerializers(restoredTimersSnapshot InternalTimersSnapshot<K,N>, in DataInputView) : void from class org.apache.flink.streaming.api.operators.InternalTimersSnapshotReaderWriters.InternalTimersSnapshotReaderPreVersioned | From | To | |
| Extract Variable namespaceSerializer : TypeSerializer<N> in method protected restoreKeyAndNamespaceSerializers(restoredTimersSnapshot InternalTimersSnapshot<K,N>, in DataInputView) : void from class org.apache.flink.streaming.api.operators.InternalTimersSnapshotReaderWriters.InternalTimersSnapshotReaderPreVersioned | From | To | |
| Change Variable Type | 2 | ||
| Change Variable Type keySerializerCompatibility : CompatibilityResult<K> to keySerializerCompatibility : TypeSerializerSchemaCompatibility<K> in method public startTimerService(keySerializer TypeSerializer<K>, namespaceSerializer TypeSerializer<N>, triggerTarget Triggerable<K,N>) : void in class org.apache.flink.streaming.api.operators.InternalTimerServiceImpl | From | To | |
| Change Variable Type namespaceSerializerCompatibility : CompatibilityResult<N> to namespaceSerializerCompatibility : TypeSerializerSchemaCompatibility<N> in method public startTimerService(keySerializer TypeSerializer<K>, namespaceSerializer TypeSerializer<N>, triggerTarget Triggerable<K,N>) : void in class org.apache.flink.streaming.api.operators.InternalTimerServiceImpl | From | To |