flink bced96a5a0b8f7b7848add316c12071e0398404a

bced96a5a0b8f7b7848add316c12071e0398404a

Files Diff

Added: 3
Removed: 0
Renamed: 0
Modified: 11

Link to commit

Dependency Action

Refactorings reported:

Refactoring Name	Occurences
Rename Method	3
Rename Method public updateSnapshotTransformer(snapshotTransformer StateSnapshotTransformer<S>) : void renamed to public updateSnapshotTransformFactory(stateSnapshotTransformFactory StateSnapshotTransformFactory<S>) : void in class org.apache.flink.runtime.state.RegisteredKeyValueStateBackendMetaInfo	From	To
Rename Method public getSnapshotTransformer() : StateSnapshotTransformer<S> renamed to public getStateSnapshotTransformFactory() : StateSnapshotTransformFactory<S> in class org.apache.flink.runtime.state.RegisteredKeyValueStateBackendMetaInfo	From	To
Rename Method private getStateSnapshotTransformer(stateDesc StateDescriptor<?,SV>, snapshotTransformFactory StateSnapshotTransformFactory<SEV>) : StateSnapshotTransformer<SV> renamed to private getStateSnapshotTransformFactory(stateDesc StateDescriptor<?,SV>, snapshotTransformFactory StateSnapshotTransformFactory<SEV>) : StateSnapshotTransformFactory<SV> in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend	From	To
Change Parameter Type	6
Change Parameter Type snapshotTransformer : StateSnapshotTransformer<S> to stateSnapshotTransformFactory : StateSnapshotTransformFactory<S> in method public RegisteredKeyValueStateBackendMetaInfo(stateType StateDescriptor.Type, name String, namespaceSerializer TypeSerializer<N>, stateSerializer TypeSerializer<S>, stateSnapshotTransformFactory StateSnapshotTransformFactory<S>) in class org.apache.flink.runtime.state.RegisteredKeyValueStateBackendMetaInfo	From	To
Change Parameter Type snapshotTransformer : StateSnapshotTransformer<V> to snapshotTransformFactory : StateSnapshotTransformFactory<V> in method private tryRegisterStateTable(namespaceSerializer TypeSerializer<N>, stateDesc StateDescriptor<?,V>, snapshotTransformFactory StateSnapshotTransformFactory<V>) : StateTable<K,N,V> in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend	From	To
Change Parameter Type snapshotTransformer : StateSnapshotTransformer<S> to stateSnapshotTransformFactory : StateSnapshotTransformFactory<S> in method public updateSnapshotTransformFactory(stateSnapshotTransformFactory StateSnapshotTransformFactory<S>) : void in class org.apache.flink.runtime.state.RegisteredKeyValueStateBackendMetaInfo	From	To
Change Parameter Type snapshotFilter : StateSnapshotTransformer<S> to snapshotTransformFactory : StateSnapshotTransformFactory<S> in method package NestedMapsStateTableSnapshot(owningTable NestedMapsStateTable<K,N,S>, snapshotTransformFactory StateSnapshotTransformFactory<S>) in class org.apache.flink.runtime.state.heap.NestedMapsStateTable.NestedMapsStateTableSnapshot	From	To
Change Parameter Type snapshotTransformer : StateSnapshotTransformer<S> to stateSnapshotTransformFactory : StateSnapshotTransformFactory<S> in method private RegisteredKeyValueStateBackendMetaInfo(stateType StateDescriptor.Type, name String, namespaceSerializerProvider StateSerializerProvider<N>, stateSerializerProvider StateSerializerProvider<S>, stateSnapshotTransformFactory StateSnapshotTransformFactory<S>) in class org.apache.flink.runtime.state.RegisteredKeyValueStateBackendMetaInfo	From	To
Change Parameter Type snapshotTransformer : StateSnapshotTransformer<SV> to snapshotTransformFactory : StateSnapshotTransformFactory<SEV> in method private tryRegisterKvStateInformation(stateDesc StateDescriptor<S,SV>, namespaceSerializer TypeSerializer<N>, snapshotTransformFactory StateSnapshotTransformFactory<SEV>) : Tuple2<ColumnFamilyHandle,RegisteredKeyValueStateBackendMetaInfo<N,SV>> in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend	From	To
Rename Variable	1
Rename Variable tuple2 : Tuple2<ColumnFamilyHandle,RegisteredStateMetaInfoBase> to metaDataEntry : MetaData in method private writeKVStateMetaData(kvStateIterators List<Tuple2<RocksIteratorWrapper,Integer>>, readOptions ReadOptions, outputView DataOutputView) : void in class org.apache.flink.contrib.streaming.state.snapshot.RocksFullSnapshotStrategy.SnapshotAsynchronousPartCallable	From	To
Change Return Type	2
Change Return Type StateSnapshotTransformer<SV> to StateSnapshotTransformFactory<SV> in method private getStateSnapshotTransformFactory(stateDesc StateDescriptor<?,SV>, snapshotTransformFactory StateSnapshotTransformFactory<SEV>) : StateSnapshotTransformFactory<SV> in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend	From	To
Change Return Type StateSnapshotTransformer<S> to StateSnapshotTransformFactory<S> in method public getStateSnapshotTransformFactory() : StateSnapshotTransformFactory<S> in class org.apache.flink.runtime.state.RegisteredKeyValueStateBackendMetaInfo	From	To
Move Class	2
Move Class org.apache.flink.runtime.state.StateSnapshotTransformer.MapStateSnapshotTransformer moved to org.apache.flink.runtime.state.StateSnapshotTransformers.MapStateSnapshotTransformer	From	To
Move Class org.apache.flink.runtime.state.StateSnapshotTransformer.ListStateSnapshotTransformer moved to org.apache.flink.runtime.state.StateSnapshotTransformers.ListStateSnapshotTransformer	From	To
Rename Attribute	2
Rename Attribute snapshotTransformer : StateSnapshotTransformer<S> to stateSnapshotTransformFactory : StateSnapshotTransformFactory<S> in class org.apache.flink.runtime.state.RegisteredKeyValueStateBackendMetaInfo	From	To
Rename Attribute metaDataCopy : List<Tuple2<ColumnFamilyHandle,RegisteredStateMetaInfoBase>> to metaData : List<MetaData> in class org.apache.flink.contrib.streaming.state.snapshot.RocksFullSnapshotStrategy.SnapshotAsynchronousPartCallable	From	To
Change Variable Type	1
Change Variable Type tuple2 : Tuple2<ColumnFamilyHandle,RegisteredStateMetaInfoBase> to metaDataEntry : MetaData in method private writeKVStateMetaData(kvStateIterators List<Tuple2<RocksIteratorWrapper,Integer>>, readOptions ReadOptions, outputView DataOutputView) : void in class org.apache.flink.contrib.streaming.state.snapshot.RocksFullSnapshotStrategy.SnapshotAsynchronousPartCallable	From	To
Change Attribute Type	3
Change Attribute Type transformStrategy : TransformStrategy to transformStrategy : CollectionStateSnapshotTransformer.TransformStrategy in class org.apache.flink.runtime.state.StateSnapshotTransformers.ListStateSnapshotTransformer	From	To
Change Attribute Type snapshotTransformer : StateSnapshotTransformer<S> to stateSnapshotTransformFactory : StateSnapshotTransformFactory<S> in class org.apache.flink.runtime.state.RegisteredKeyValueStateBackendMetaInfo	From	To
Change Attribute Type metaDataCopy : List<Tuple2<ColumnFamilyHandle,RegisteredStateMetaInfoBase>> to metaData : List<MetaData> in class org.apache.flink.contrib.streaming.state.snapshot.RocksFullSnapshotStrategy.SnapshotAsynchronousPartCallable	From	To
Rename Parameter	6
Rename Parameter snapshotTransformer : StateSnapshotTransformer<S> to stateSnapshotTransformFactory : StateSnapshotTransformFactory<S> in method public updateSnapshotTransformFactory(stateSnapshotTransformFactory StateSnapshotTransformFactory<S>) : void in class org.apache.flink.runtime.state.RegisteredKeyValueStateBackendMetaInfo	From	To
Rename Parameter snapshotFilter : StateSnapshotTransformer<S> to snapshotTransformFactory : StateSnapshotTransformFactory<S> in method package NestedMapsStateTableSnapshot(owningTable NestedMapsStateTable<K,N,S>, snapshotTransformFactory StateSnapshotTransformFactory<S>) in class org.apache.flink.runtime.state.heap.NestedMapsStateTable.NestedMapsStateTableSnapshot	From	To
Rename Parameter snapshotTransformer : StateSnapshotTransformer<SV> to snapshotTransformFactory : StateSnapshotTransformFactory<SEV> in method private tryRegisterKvStateInformation(stateDesc StateDescriptor<S,SV>, namespaceSerializer TypeSerializer<N>, snapshotTransformFactory StateSnapshotTransformFactory<SEV>) : Tuple2<ColumnFamilyHandle,RegisteredKeyValueStateBackendMetaInfo<N,SV>> in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend	From	To
Rename Parameter snapshotTransformer : StateSnapshotTransformer<S> to stateSnapshotTransformFactory : StateSnapshotTransformFactory<S> in method private RegisteredKeyValueStateBackendMetaInfo(stateType StateDescriptor.Type, name String, namespaceSerializerProvider StateSerializerProvider<N>, stateSerializerProvider StateSerializerProvider<S>, stateSnapshotTransformFactory StateSnapshotTransformFactory<S>) in class org.apache.flink.runtime.state.RegisteredKeyValueStateBackendMetaInfo	From	To
Rename Parameter snapshotTransformer : StateSnapshotTransformer<S> to stateSnapshotTransformFactory : StateSnapshotTransformFactory<S> in method public RegisteredKeyValueStateBackendMetaInfo(stateType StateDescriptor.Type, name String, namespaceSerializer TypeSerializer<N>, stateSerializer TypeSerializer<S>, stateSnapshotTransformFactory StateSnapshotTransformFactory<S>) in class org.apache.flink.runtime.state.RegisteredKeyValueStateBackendMetaInfo	From	To
Rename Parameter snapshotTransformer : StateSnapshotTransformer<V> to snapshotTransformFactory : StateSnapshotTransformFactory<V> in method private tryRegisterStateTable(namespaceSerializer TypeSerializer<N>, stateDesc StateDescriptor<?,V>, snapshotTransformFactory StateSnapshotTransformFactory<V>) : StateTable<K,N,V> in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend	From	To

bced96a5a0b8f7b7848add316c12071e0398404a

Files Diff

Link to commit

Third party dependencies:

Refactorings reported: