592f3a9a299826efcf9ffa17c56221ac3904f021
Files Diff
- Added: 4
- Removed: 1
- Renamed: 0
- Modified: 38
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Change Parameter Type | 2 | ||
| Change Parameter Type originalStateFactory : KeyedStateFactory to stateBackend : KeyedStateBackend<K> in method private TtlStateFactory(namespaceSerializer TypeSerializer<N>, stateDesc StateDescriptor<S,SV>, stateBackend KeyedStateBackend<K>, timeProvider TtlTimeProvider) in class org.apache.flink.runtime.state.ttl.TtlStateFactory | From | To | |
| Change Parameter Type originalStateFactory : KeyedStateFactory to stateBackend : KeyedStateBackend<K> in method public createStateAndWrapWithTtlIfEnabled(namespaceSerializer TypeSerializer<N>, stateDesc StateDescriptor<S,SV>, stateBackend KeyedStateBackend<K>, timeProvider TtlTimeProvider) : IS in class org.apache.flink.runtime.state.ttl.TtlStateFactory | From | To | |
| Change Return Type | 1 | ||
| Change Return Type StateTableEntry<K,N,S> to StateEntry<K,N,S> in method public next() : StateEntry<K,N,S> in class org.apache.flink.runtime.state.heap.CopyOnWriteStateTable.StateEntryIterator | From | To | |
| Move Attribute | 7 | ||
| Move Attribute private REPORT_STAT_AFTER_UPDATES_NUM : ConfigOption<Long> from class org.apache.flink.streaming.tests.DataStreamStateTTLTestProgram to private REPORT_STAT_AFTER_UPDATES_NUM : ConfigOption<Long> from class org.apache.flink.streaming.tests.TtlTestConfig | From | To | |
| Move Attribute private UPDATE_GENERATOR_SRC_KEYSPACE : ConfigOption<Integer> from class org.apache.flink.streaming.tests.DataStreamStateTTLTestProgram to private UPDATE_GENERATOR_SRC_KEYSPACE : ConfigOption<Integer> from class org.apache.flink.streaming.tests.TtlTestConfig | From | To | |
| Move Attribute private activeTable : StateTableEntry<K,N,S>[] from class org.apache.flink.runtime.state.heap.CopyOnWriteStateTable.StateEntryIterator to package activeTable : StateTableEntry<K,N,S>[] from class org.apache.flink.runtime.state.heap.CopyOnWriteStateTable.StateEntryChainIterator | From | To | |
| Move Attribute private nextTablePosition : int from class org.apache.flink.runtime.state.heap.CopyOnWriteStateTable.StateEntryIterator to private nextTablePosition : int from class org.apache.flink.runtime.state.heap.CopyOnWriteStateTable.StateEntryChainIterator | From | To | |
| Move Attribute private STATE_TTL_VERIFIER_TTL_MILLI : ConfigOption<Long> from class org.apache.flink.streaming.tests.DataStreamStateTTLTestProgram to private STATE_TTL_VERIFIER_TTL_MILLI : ConfigOption<Long> from class org.apache.flink.streaming.tests.TtlTestConfig | From | To | |
| Move Attribute private UPDATE_GENERATOR_SRC_SLEEP_TIME : ConfigOption<Long> from class org.apache.flink.streaming.tests.DataStreamStateTTLTestProgram to private UPDATE_GENERATOR_SRC_SLEEP_TIME : ConfigOption<Long> from class org.apache.flink.streaming.tests.TtlTestConfig | From | To | |
| Move Attribute private UPDATE_GENERATOR_SRC_SLEEP_AFTER_ELEMENTS : ConfigOption<Long> from class org.apache.flink.streaming.tests.DataStreamStateTTLTestProgram to private UPDATE_GENERATOR_SRC_SLEEP_AFTER_ELEMENTS : ConfigOption<Long> from class org.apache.flink.streaming.tests.TtlTestConfig | From | To | |
| Extract Class | 2 | ||
| Extract Class org.apache.flink.streaming.tests.TtlTestConfig from class org.apache.flink.streaming.tests.DataStreamStateTTLTestProgram | From | To | |
| Extract Class org.apache.flink.runtime.state.heap.CopyOnWriteStateTable.StateEntryChainIterator from class org.apache.flink.runtime.state.heap.CopyOnWriteStateTable.StateEntryIterator | From | To | |
| Extract Attribute | 1 | ||
| Extract Attribute public DEFAULT_CAPACITY : int in class org.apache.flink.runtime.state.heap.CopyOnWriteStateTable | From | To | |
| Move Class | 1 | ||
| Move Class org.apache.flink.runtime.state.heap.StateEntry moved to org.apache.flink.runtime.state.StateEntry | From | To | |
| Merge Parameter | 1 | ||
| Merge Parameter [original : S, config : StateTtlConfig, timeProvider : TtlTimeProvider, valueSerializer : TypeSerializer<SV>] to ttlStateContext : TtlStateContext<S,SV> in method package AbstractTtlState(ttlStateContext TtlStateContext<S,SV>) in class org.apache.flink.runtime.state.ttl.AbstractTtlState | From | To | |
| Extract Method | 2 | ||
| Extract Method private restoreSnapshot(snapshot KeyedStateHandle) : void extracted from private takeAndRestoreSnapshot() : void in class org.apache.flink.runtime.state.ttl.TtlStateTestBase | From | To | |
| Extract Method package triggerSnapshot() : RunnableFuture<SnapshotResult<KeyedStateHandle>> extracted from package takeSnapshot() : KeyedStateHandle in class org.apache.flink.runtime.state.ttl.StateBackendTestContext | From | To | |
| Rename Parameter | 2 | ||
| Rename Parameter originalStateFactory : KeyedStateFactory to stateBackend : KeyedStateBackend<K> in method private TtlStateFactory(namespaceSerializer TypeSerializer<N>, stateDesc StateDescriptor<S,SV>, stateBackend KeyedStateBackend<K>, timeProvider TtlTimeProvider) in class org.apache.flink.runtime.state.ttl.TtlStateFactory | From | To | |
| Rename Parameter originalStateFactory : KeyedStateFactory to stateBackend : KeyedStateBackend<K> in method public createStateAndWrapWithTtlIfEnabled(namespaceSerializer TypeSerializer<N>, stateDesc StateDescriptor<S,SV>, stateBackend KeyedStateBackend<K>, timeProvider TtlTimeProvider) : IS in class org.apache.flink.runtime.state.ttl.TtlStateFactory | From | To |