f45b7f7ff27df019e9045895e718fa112d12139c
Files Diff
- Added: 17
- Removed: 11
- Renamed: 0
- Modified: 35
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Move And Rename Method | 1 | ||
| Move And Rename Method private unexpiredAndUpdateOrCleanup(e Map.Entry<UK,TtlValue<UV>>) : boolean from class org.apache.flink.runtime.state.ttl.TtlMapState to private getUnexpiredAndUpdateOrCleanup(e Map.Entry<UK,TtlValue<UV>>) : Map.Entry<UK,UV> from class org.apache.flink.runtime.state.ttl.TtlMapState.EntriesIterator | From | To | |
| Move Method | 1 | ||
| Move Method package abstract initTestValues() : void from class org.apache.flink.runtime.state.ttl.TtlStateTestBase to package abstract initTestValues() : void from class org.apache.flink.runtime.state.ttl.TtlStateTestContextBase | From | To | |
| Move Attribute | 8 | ||
| Move Attribute package updateUnexpired : UV from class org.apache.flink.runtime.state.ttl.TtlStateTestBase to package updateUnexpired : UV from class org.apache.flink.runtime.state.ttl.TtlStateTestContextBase | From | To | |
| Move Attribute package ttlState : S from class org.apache.flink.runtime.state.ttl.TtlStateTestBase to package ttlState : S from class org.apache.flink.runtime.state.ttl.TtlStateTestContextBase | From | To | |
| Move Attribute package updateExpired : UV from class org.apache.flink.runtime.state.ttl.TtlStateTestBase to package updateExpired : UV from class org.apache.flink.runtime.state.ttl.TtlStateTestContextBase | From | To | |
| Move Attribute package updateEmpty : UV from class org.apache.flink.runtime.state.ttl.TtlStateTestBase to package updateEmpty : UV from class org.apache.flink.runtime.state.ttl.TtlStateTestContextBase | From | To | |
| Move Attribute package getUpdateEmpty : GV from class org.apache.flink.runtime.state.ttl.TtlStateTestBase to package getUpdateEmpty : GV from class org.apache.flink.runtime.state.ttl.TtlStateTestContextBase | From | To | |
| Move Attribute package getUpdateExpired : GV from class org.apache.flink.runtime.state.ttl.TtlStateTestBase to package getUpdateExpired : GV from class org.apache.flink.runtime.state.ttl.TtlStateTestContextBase | From | To | |
| Move Attribute package emptyValue : GV from class org.apache.flink.runtime.state.ttl.TtlStateTestBase to package emptyValue : GV from class org.apache.flink.runtime.state.ttl.TtlStateTestContextBase | From | To | |
| Move Attribute package getUnexpired : GV from class org.apache.flink.runtime.state.ttl.TtlStateTestBase to package getUnexpired : GV from class org.apache.flink.runtime.state.ttl.TtlStateTestContextBase | From | To | |
| Extract Class | 2 | ||
| Extract Class org.apache.flink.runtime.state.ttl.StateBackendTestContext from class org.apache.flink.runtime.state.ttl.TtlStateTestBase | From | To | |
| Extract Class org.apache.flink.runtime.state.ttl.TtlStateTestContextBase from class org.apache.flink.runtime.state.ttl.TtlStateTestBase | From | To | |
| Rename Class | 6 | ||
| Rename Class org.apache.flink.runtime.state.ttl.TtlListStateTest renamed to org.apache.flink.runtime.state.ttl.TtlListStateTestContext | From | To | |
| Rename Class org.apache.flink.runtime.state.ttl.TtlAggregatingStateTest renamed to org.apache.flink.runtime.state.ttl.TtlAggregatingStateTestContext | From | To | |
| Rename Class org.apache.flink.runtime.state.ttl.TtlReducingStateTest renamed to org.apache.flink.runtime.state.ttl.TtlReducingStateTestContext | From | To | |
| Rename Class org.apache.flink.runtime.state.ttl.TtlMapStateTest renamed to org.apache.flink.runtime.state.ttl.TtlMapStateAllEntriesTestContext | From | To | |
| Rename Class org.apache.flink.runtime.state.ttl.MockTimeProvider renamed to org.apache.flink.runtime.state.ttl.MockTtlTimeProvider | From | To | |
| Rename Class org.apache.flink.runtime.state.ttl.TtlMergingStateBase renamed to org.apache.flink.runtime.state.ttl.TtlMergingStateTestContext | From | To | |
| Move And Rename Class | 1 | ||
| Move And Rename Class org.apache.flink.runtime.state.ttl.TtlMergingStateBase.TtlIntegerMergingStateBase moved and renamed to org.apache.flink.runtime.state.ttl.TtlMergingStateTestContext.TtlIntegerMergingStateTestContext | From | To | |
| Extract Method | 1 | ||
| Extract Method private publishQueryableStateIfEnabled(stateDescriptor StateDescriptor<?,?>, kvState InternalKvState<?,?,?>) : void extracted from public getOrCreateKeyedState(namespaceSerializer TypeSerializer<N>, stateDescriptor StateDescriptor<S,V>) : S in class org.apache.flink.runtime.state.AbstractKeyedStateBackend | From | To | |
| Rename Method | 4 | ||
| Rename Method package PrecomputedParameters(immutableTargetType boolean, fieldSerializers TypeSerializer<Object>[]) renamed to package precompute(immutableTargetType boolean, fieldSerializers TypeSerializer<Object>[]) : PrecomputedParameters in class org.apache.flink.api.common.typeutils.CompositeSerializer.PrecomputedParameters | From | To | |
| Rename Method public createState(namespaceSerializer TypeSerializer<N>, stateDesc StateDescriptor<S,SV>) : IS renamed to public createInternalState(namespaceSerializer TypeSerializer<N>, stateDesc StateDescriptor<S,SV>) : IS in class org.apache.flink.runtime.state.KeyedStateFactory | From | To | |
| Rename Method public createState(namespaceSerializer TypeSerializer<N>, stateDesc StateDescriptor<S,SV>) : IS renamed to public createInternalState(namespaceSerializer TypeSerializer<N>, stateDesc StateDescriptor<S,SV>) : IS in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend | From | To | |
| Rename Method public createState(namespaceSerializer TypeSerializer<N>, stateDesc StateDescriptor<S,SV>) : IS renamed to public createInternalState(namespaceSerializer TypeSerializer<N>, stateDesc StateDescriptor<S,SV>) : IS in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend | From | To | |
| Inline Method | 12 | ||
| Inline Method private copy() : Map<UK,UV> inlined to public values() : Iterable<UV> in class org.apache.flink.runtime.state.ttl.mock.MockInternalMapState | From | To | |
| Inline Method private copy() : Map<UK,UV> inlined to public keys() : Iterable<UK> in class org.apache.flink.runtime.state.ttl.mock.MockInternalMapState | From | To | |
| Inline Method private copy() : Map<UK,UV> inlined to public entries() : Iterable<Map.Entry<UK,UV>> in class org.apache.flink.runtime.state.ttl.mock.MockInternalMapState | From | To | |
| Change Return Type | 1 | ||
| Change Return Type boolean to Map.Entry<UK,UV> in method private getUnexpiredAndUpdateOrCleanup(e Map.Entry<UK,TtlValue<UV>>) : Map.Entry<UK,UV> in class org.apache.flink.runtime.state.ttl.TtlMapState.EntriesIterator | From | To | |
| Extract Superclass | 2 | ||
| Extract Superclass org.apache.flink.runtime.state.ttl.TtlMapStateTestContext from classes [org.apache.flink.runtime.state.ttl.TtlMapStateAllEntriesTestContext] | From | To | |
| Extract Superclass org.apache.flink.runtime.state.ttl.TtlStateTestContextBase from classes [org.apache.flink.runtime.state.ttl.TtlMergingStateTestContext] | From | To | |
| Change Attribute Type | 1 | ||
| Change Attribute Type timeProvider : MockTimeProvider to timeProvider : MockTtlTimeProvider in class org.apache.flink.runtime.state.ttl.TtlStateTestBase | From | To | |
| Extract And Move Method | 1 | ||
| Extract And Move Method public getTtlConfig() : StateTtlConfiguration extracted from public createStateAndWrapWithTtlIfEnabled(namespaceSerializer TypeSerializer<N>, stateDesc StateDescriptor<S,SV>, originalStateFactory KeyedStateFactory, ttlConfig StateTtlConfiguration, timeProvider TtlTimeProvider) : IS in class org.apache.flink.runtime.state.ttl.TtlStateFactory & moved to class org.apache.flink.api.common.state.StateDescriptor | From | To |