flink ce96c409148d1a9bc40f581e13900818b5f11f6a

ce96c409148d1a9bc40f581e13900818b5f11f6a

Files Diff

Added: 4
Removed: 1
Renamed: 0
Modified: 28

Link to commit

Dependency Action

Refactorings reported:

Refactoring Name	Occurences
Change Parameter Type	23
Change Parameter Type config : StateTtlConfiguration to config : StateTtlConfig in method package TtlReduceFunction(originalReduceFunction ReduceFunction<T>, config StateTtlConfig, timeProvider TtlTimeProvider) in class org.apache.flink.runtime.state.ttl.TtlReduceFunction	From	To
Change Parameter Type config : StateTtlConfiguration to config : StateTtlConfig in method package TtlMapState(original InternalMapState<K,N,UK,TtlValue<UV>>, config StateTtlConfig, timeProvider TtlTimeProvider, valueSerializer TypeSerializer<Map<UK,UV>>) in class org.apache.flink.runtime.state.ttl.TtlMapState	From	To
Change Parameter Type config : StateTtlConfiguration to config : StateTtlConfig in method package TtlFoldFunction(original FoldFunction<T,ACC>, config StateTtlConfig, timeProvider TtlTimeProvider, defaultAccumulator ACC) in class org.apache.flink.runtime.state.ttl.TtlFoldFunction	From	To
Change Parameter Type config : StateTtlConfiguration to config : StateTtlConfig in method package TtlFoldingState(originalState InternalFoldingState<K,N,T,TtlValue<ACC>>, config StateTtlConfig, timeProvider TtlTimeProvider, valueSerializer TypeSerializer<ACC>) in class org.apache.flink.runtime.state.ttl.TtlFoldingState	From	To
Change Parameter Type ttlConfig : StateTtlConfiguration to ttlConfig : StateTtlConfig in method public createState(context FunctionInitializationContext, ttlConfig StateTtlConfig) : State in class org.apache.flink.streaming.tests.verify.AbstractTtlStateVerifier	From	To
Change Parameter Type config : StateTtlConfiguration to config : StateTtlConfig in method package AbstractTtlDecorator(original T, config StateTtlConfig, timeProvider TtlTimeProvider) in class org.apache.flink.runtime.state.ttl.AbstractTtlDecorator	From	To
Change Parameter Type config : StateTtlConfiguration to config : StateTtlConfig in method package TtlAggregateFunction(aggFunction AggregateFunction<IN,ACC,OUT>, config StateTtlConfig, timeProvider TtlTimeProvider) in class org.apache.flink.runtime.state.ttl.TtlAggregateFunction	From	To
Change Parameter Type config : StateTtlConfiguration to config : StateTtlConfig in method package TtlListState(originalState InternalListState<K,N,TtlValue<T>>, config StateTtlConfig, timeProvider TtlTimeProvider, valueSerializer TypeSerializer<List<T>>) in class org.apache.flink.runtime.state.ttl.TtlListState	From	To
Change Parameter Type ttlConfig : StateTtlConfiguration to ttlConfig : StateTtlConfig in method public enableTimeToLive(ttlConfig StateTtlConfig) : void in class org.apache.flink.api.common.state.StateDescriptor	From	To
Change Parameter Type config : StateTtlConfiguration to config : StateTtlConfig in method package TtlReducingState(originalState InternalReducingState<K,N,TtlValue<T>>, config StateTtlConfig, timeProvider TtlTimeProvider, valueSerializer TypeSerializer<T>) in class org.apache.flink.runtime.state.ttl.TtlReducingState	From	To
Change Parameter Type config : StateTtlConfiguration to config : StateTtlConfig in method package TtlAggregatingState(originalState InternalAggregatingState<K,N,IN,TtlValue<ACC>,OUT>, config StateTtlConfig, timeProvider TtlTimeProvider, valueSerializer TypeSerializer<ACC>, aggregateFunction TtlAggregateFunction<IN,ACC,OUT>) in class org.apache.flink.runtime.state.ttl.TtlAggregatingState	From	To
Change Parameter Type ttlUpdateType : TtlUpdateType to updateType : UpdateType in method private StateTtlConfig(updateType UpdateType, stateVisibility StateVisibility, timeCharacteristic TimeCharacteristic, ttl Time, cleanupStrategies CleanupStrategies) in class org.apache.flink.api.common.state.StateTtlConfig	From	To
Change Parameter Type ttlConfig : StateTtlConfiguration to ttlConfig : StateTtlConfig in method package TtlVerifyUpdateFunction(ttlConfig StateTtlConfig, reportStatAfterUpdatesNum long) in class org.apache.flink.streaming.tests.TtlVerifyUpdateFunction	From	To
Change Parameter Type timeCharacteristic : TtlTimeCharacteristic to timeCharacteristic : TimeCharacteristic in method public setTimeCharacteristic(timeCharacteristic TimeCharacteristic) : Builder in class org.apache.flink.api.common.state.StateTtlConfig.Builder	From	To
Change Parameter Type timeCharacteristic : TtlTimeCharacteristic to timeCharacteristic : TimeCharacteristic in method private StateTtlConfig(updateType UpdateType, stateVisibility StateVisibility, timeCharacteristic TimeCharacteristic, ttl Time, cleanupStrategies CleanupStrategies) in class org.apache.flink.api.common.state.StateTtlConfig	From	To
Change Parameter Type stateVisibility : TtlStateVisibility to stateVisibility : StateVisibility in method private StateTtlConfig(updateType UpdateType, stateVisibility StateVisibility, timeCharacteristic TimeCharacteristic, ttl Time, cleanupStrategies CleanupStrategies) in class org.apache.flink.api.common.state.StateTtlConfig	From	To
Change Parameter Type stateVisibility : TtlStateVisibility to stateVisibility : StateVisibility in method public setStateVisibility(stateVisibility StateVisibility) : Builder in class org.apache.flink.api.common.state.StateTtlConfig.Builder	From	To
Change Parameter Type updateType : StateTtlConfiguration.TtlUpdateType to updateType : StateTtlConfig.UpdateType in method private initTest(updateType StateTtlConfig.UpdateType, visibility StateTtlConfig.StateVisibility) : void in class org.apache.flink.runtime.state.ttl.TtlStateTestBase	From	To
Change Parameter Type config : StateTtlConfiguration to config : StateTtlConfig in method package TtlValueState(originalState InternalValueState<K,N,TtlValue<T>>, config StateTtlConfig, timeProvider TtlTimeProvider, valueSerializer TypeSerializer<T>) in class org.apache.flink.runtime.state.ttl.TtlValueState	From	To
Change Parameter Type ttlUpdateType : TtlUpdateType to updateType : UpdateType in method public setUpdateType(updateType UpdateType) : Builder in class org.apache.flink.api.common.state.StateTtlConfig.Builder	From	To
Change Parameter Type visibility : StateTtlConfiguration.TtlStateVisibility to visibility : StateTtlConfig.StateVisibility in method private initTest(updateType StateTtlConfig.UpdateType, visibility StateTtlConfig.StateVisibility) : void in class org.apache.flink.runtime.state.ttl.TtlStateTestBase	From	To
Change Parameter Type config : StateTtlConfiguration to config : StateTtlConfig in method package AbstractTtlState(original S, config StateTtlConfig, timeProvider TtlTimeProvider, valueSerializer TypeSerializer<SV>) in class org.apache.flink.runtime.state.ttl.AbstractTtlState	From	To
Change Parameter Type ttlConfig : StateTtlConfiguration to ttlConfig : StateTtlConfig in method public createState(context FunctionInitializationContext, ttlConfig StateTtlConfig) : State in class org.apache.flink.streaming.tests.verify.TtlStateVerifier	From	To
Move Method	2
Move Method package wrapWithTs(value V, ts long) : TtlValue<V> from class org.apache.flink.runtime.state.ttl.AbstractTtlDecorator to package wrapWithTs(value V, ts long) : TtlValue<V> from class org.apache.flink.runtime.state.ttl.TtlUtils	From	To
Move Method private getExpirationTimestamp(ttlValue TtlValue<?>) : long from class org.apache.flink.runtime.state.ttl.AbstractTtlDecorator to private getExpirationTimestamp(ts long, ttl long) : long from class org.apache.flink.runtime.state.ttl.TtlUtils	From	To
Rename Class	1
Rename Class org.apache.flink.api.common.state.StateTtlConfiguration renamed to org.apache.flink.api.common.state.StateTtlConfig	From	To
Move And Rename Class	3
Move And Rename Class org.apache.flink.api.common.state.StateTtlConfiguration.TtlUpdateType moved and renamed to org.apache.flink.api.common.state.StateTtlConfig.UpdateType	From	To
Move And Rename Class org.apache.flink.api.common.state.StateTtlConfiguration.TtlTimeCharacteristic moved and renamed to org.apache.flink.api.common.state.StateTtlConfig.TimeCharacteristic	From	To
Move And Rename Class org.apache.flink.api.common.state.StateTtlConfiguration.TtlStateVisibility moved and renamed to org.apache.flink.api.common.state.StateTtlConfig.StateVisibility	From	To
Change Variable Type	4
Change Variable Type stateFactory : KeyedStateFactory to stateFactory : StateFactory in method public createInternalState(namespaceSerializer TypeSerializer<N>, stateDesc StateDescriptor<S,SV>, snapshotTransformFactory StateSnapshotTransformFactory<SEV>) : IS in class org.apache.flink.runtime.state.ttl.mock.MockKeyedStateBackend	From	To
Change Variable Type stateFactory : KeyedStateFactory to stateFactory : SupplierWithException<IS,Exception> in method private createState() : IS in class org.apache.flink.runtime.state.ttl.TtlStateFactory	From	To
Change Variable Type ttlConfig : StateTtlConfiguration to ttlConfig : StateTtlConfig in method public main(args String[]) : void in class org.apache.flink.streaming.tests.DataStreamStateTTLTestProgram	From	To
Change Variable Type columnFamilyHandle : ColumnFamilyHandle to tuple2 : Tuple2<ColumnFamilyHandle,RegisteredStateMetaInfoBase> in method private writeKVStateMetaData() : void in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBFullSnapshotOperation	From	To
Extract Method	6
Extract Method package tryAddToSource(currentIndex int, entry CopyOnWriteStateTable.StateTableEntry<K,N,S>) : int extracted from protected reportAllElementKeyGroups() : void in class org.apache.flink.runtime.state.heap.CopyOnWriteStateTableSnapshot.StateTableKeyGroupPartitioner	From	To
Extract Method private deserializeList(valueBytes byte[], elementSerializer TypeSerializer<V>) : List<V> extracted from public getInternal() : List<V> in class org.apache.flink.contrib.streaming.state.RocksDBListState	From	To
Extract Method private copyEntry(stateValues Map<String,Map<K,Map<Object,Object>>>, snapshotedValues Map<Object,Object>, stateName String, key K, namespace Object, stateSnapshotTransformer StateSnapshotTransformer<Object>) : void extracted from private copy(stateValues Map<String,Map<K,Map<Object,Object>>>) : Map<String,Map<K,Map<Object,Object>>> in class org.apache.flink.runtime.state.ttl.mock.MockKeyedStateBackend	From	To
Extract Method private copy(stateValues Map<String,Map<K,Map<Object,Object>>>, stateSnapshotFilters Map<String,StateSnapshotTransformer<Object>>) : Map<String,Map<K,Map<Object,Object>>> extracted from private copy(stateValues Map<String,Map<K,Map<Object,Object>>>) : Map<String,Map<K,Map<Object,Object>>> in class org.apache.flink.runtime.state.ttl.mock.MockKeyedStateBackend	From	To
Extract Method private writeElement(namespace N, keyEntry Map.Entry<K,S>, dov DataOutputView) : void extracted from public writeStateInKeyGroup(dov DataOutputView, keyGroupId int) : void in class org.apache.flink.runtime.state.heap.NestedMapsStateTable.NestedMapsStateTableSnapshot	From	To
Extract Method private deserializeNextElement(in DataInputViewStreamWrapper, elementSerializer TypeSerializer<V>) : V extracted from public getInternal() : List<V> in class org.apache.flink.contrib.streaming.state.RocksDBListState	From	To
Rename Method	2
Rename Method public getTtlUpdateType() : TtlUpdateType renamed to public getUpdateType() : UpdateType in class org.apache.flink.api.common.state.StateTtlConfig	From	To
Rename Method public setTtlUpdateType(ttlUpdateType TtlUpdateType) : Builder renamed to public setUpdateType(updateType UpdateType) : Builder in class org.apache.flink.api.common.state.StateTtlConfig.Builder	From	To
Rename Variable	3
Rename Variable keyGroupPartitioner : StateTableKeyGroupPartitioner<K,N,S> to stateTableKeyGroupPartitioner : StateTableKeyGroupPartitioner<K,N,S> in method public getKeyGroupWriter() : StateKeyGroupWriter in class org.apache.flink.runtime.state.heap.CopyOnWriteStateTableSnapshot	From	To
Rename Variable columnFamilyHandle : ColumnFamilyHandle to tuple2 : Tuple2<ColumnFamilyHandle,RegisteredStateMetaInfoBase> in method private writeKVStateMetaData() : void in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBFullSnapshotOperation	From	To
Rename Variable values : Map<Object,Object> to snapshotedValues : Map<Object,Object> in method private copy(stateValues Map<String,Map<K,Map<Object,Object>>>, stateSnapshotFilters Map<String,StateSnapshotTransformer<Object>>) : Map<String,Map<K,Map<Object,Object>>> in class org.apache.flink.runtime.state.ttl.mock.MockKeyedStateBackend	From	To
Change Return Type	7
Change Return Type TtlStateVisibility to StateVisibility in method public getStateVisibility() : StateVisibility in class org.apache.flink.api.common.state.StateTtlConfig	From	To
Change Return Type TtlUpdateType to UpdateType in method public getUpdateType() : UpdateType in class org.apache.flink.api.common.state.StateTtlConfig	From	To
Change Return Type Map<Class<? extends StateDescriptor>,KeyedStateFactory> to Map<Class<? extends StateDescriptor>,SupplierWithException<IS,Exception>> in method private createStateFactories() : Map<Class<? extends StateDescriptor>,SupplierWithException<IS,Exception>> in class org.apache.flink.runtime.state.ttl.TtlStateFactory	From	To
Change Return Type StateTtlConfiguration to StateTtlConfig in method public getTtlConfig() : StateTtlConfig in class org.apache.flink.api.common.state.StateDescriptor	From	To
Change Return Type void to int in method private buildHistogramByAccumulatingCounts() : int in class org.apache.flink.runtime.state.KeyGroupPartitioner	From	To
Change Return Type StateTtlConfiguration to StateTtlConfig in method public build() : StateTtlConfig in class org.apache.flink.api.common.state.StateTtlConfig.Builder	From	To
Change Return Type TtlTimeCharacteristic to TimeCharacteristic in method public getTimeCharacteristic() : TimeCharacteristic in class org.apache.flink.api.common.state.StateTtlConfig	From	To
Parameterize Variable	1
Parameterize Variable flattenIndex : int to currentIndex : int in method package tryAddToSource(currentIndex int, entry CopyOnWriteStateTable.StateTableEntry<K,N,S>) : int in class org.apache.flink.runtime.state.heap.CopyOnWriteStateTableSnapshot.StateTableKeyGroupPartitioner	From	To
Rename Attribute	3
Rename Attribute copiedColumnFamilyHandles : List<ColumnFamilyHandle> to copiedMeta : List<Tuple2<ColumnFamilyHandle,RegisteredStateMetaInfoBase>> in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBFullSnapshotOperation	From	To
Rename Attribute ttlUpdateType : TtlUpdateType to updateType : UpdateType in class org.apache.flink.api.common.state.StateTtlConfig.Builder	From	To
Rename Attribute ttlUpdateType : TtlUpdateType to updateType : UpdateType in class org.apache.flink.api.common.state.StateTtlConfig	From	To
Change Attribute Type	15
Change Attribute Type ttlConfig : StateTtlConfiguration to ttlConfig : StateTtlConfig in class org.apache.flink.api.common.state.StateDescriptor	From	To
Change Attribute Type ttlConfig : StateTtlConfiguration to ttlConfig : StateTtlConfig in class org.apache.flink.runtime.state.ttl.TtlStateFactory	From	To
Change Attribute Type stateFactories : Map<Class<? extends StateDescriptor>,KeyedStateFactory> to stateFactories : Map<Class<? extends StateDescriptor>,SupplierWithException<IS,Exception>> in class org.apache.flink.runtime.state.ttl.TtlStateFactory	From	To
Change Attribute Type ttlConfig : StateTtlConfiguration to ttlConfig : StateTtlConfig in class org.apache.flink.runtime.state.ttl.TtlStateTestBase	From	To
Change Attribute Type DISABLED : StateTtlConfiguration to DISABLED : StateTtlConfig in class org.apache.flink.api.common.state.StateTtlConfig	From	To
Change Attribute Type timeCharacteristic : TtlTimeCharacteristic to timeCharacteristic : TimeCharacteristic in class org.apache.flink.api.common.state.StateTtlConfig	From	To
Change Attribute Type timeCharacteristic : TtlTimeCharacteristic to timeCharacteristic : TimeCharacteristic in class org.apache.flink.api.common.state.StateTtlConfig.Builder	From	To
Change Attribute Type ttlConfig : StateTtlConfiguration to ttlConfig : StateTtlConfig in class org.apache.flink.streaming.tests.TtlVerifyUpdateFunction	From	To
Change Attribute Type copiedColumnFamilyHandles : List<ColumnFamilyHandle> to copiedMeta : List<Tuple2<ColumnFamilyHandle,RegisteredStateMetaInfoBase>> in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBFullSnapshotOperation	From	To
Change Attribute Type config : StateTtlConfiguration to config : StateTtlConfig in class org.apache.flink.runtime.state.ttl.AbstractTtlDecorator	From	To
Change Attribute Type ttlUpdateType : TtlUpdateType to updateType : UpdateType in class org.apache.flink.api.common.state.StateTtlConfig	From	To
Change Attribute Type stateVisibility : TtlStateVisibility to stateVisibility : StateVisibility in class org.apache.flink.api.common.state.StateTtlConfig	From	To
Change Attribute Type STATE_FACTORIES : Map<Class<? extends StateDescriptor>,KeyedStateFactory> to STATE_FACTORIES : Map<Class<? extends StateDescriptor>,StateFactory> in class org.apache.flink.runtime.state.ttl.mock.MockKeyedStateBackend	From	To
Change Attribute Type stateVisibility : TtlStateVisibility to stateVisibility : StateVisibility in class org.apache.flink.api.common.state.StateTtlConfig.Builder	From	To
Change Attribute Type ttlUpdateType : TtlUpdateType to updateType : UpdateType in class org.apache.flink.api.common.state.StateTtlConfig.Builder	From	To
Rename Parameter	2
Rename Parameter ttlUpdateType : TtlUpdateType to updateType : UpdateType in method private StateTtlConfig(updateType UpdateType, stateVisibility StateVisibility, timeCharacteristic TimeCharacteristic, ttl Time, cleanupStrategies CleanupStrategies) in class org.apache.flink.api.common.state.StateTtlConfig	From	To
Rename Parameter ttlUpdateType : TtlUpdateType to updateType : UpdateType in method public setUpdateType(updateType UpdateType) : Builder in class org.apache.flink.api.common.state.StateTtlConfig.Builder	From	To

ce96c409148d1a9bc40f581e13900818b5f11f6a

Files Diff

Link to commit

Third party dependencies:

Refactorings reported: