flink 21d1d8b49337e734ce3defb5f1b9344f748cb49e

21d1d8b49337e734ce3defb5f1b9344f748cb49e

Files Diff

Added: 9
Removed: 0
Renamed: 0
Modified: 16

Link to commit

Dependency Action

Refactorings reported:

Refactoring Name	Occurences
Move And Rename Method	1
Move And Rename Method public JavaSerializer(userClassLoader ClassLoader) from class org.apache.flink.runtime.state.JavaSerializer to package StateMetaInfo(userClassLoader ClassLoader) from class org.apache.flink.runtime.state.KeyedBackendSerializationProxy.StateMetaInfo	From	To
Change Parameter Type	6
Change Parameter Type stateSerializer : TypeSerializer<ST> to metaInfo : RegisteredBackendStateMetaInfo<N,ST> in method public StateTable(metaInfo RegisteredBackendStateMetaInfo<N,ST>, keyGroupRange KeyGroupRange) in class org.apache.flink.runtime.state.heap.StateTable	From	To
Change Parameter Type stateDesc : ListStateDescriptor<T> to newMetaInfo : RegisteredBackendStateMetaInfo<N,V> in method private tryRegisterStateTable(stateTable StateTable<K,N,V>, newMetaInfo RegisteredBackendStateMetaInfo<N,V>) : StateTable<K,N,V> in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend	From	To
Change Parameter Type stateDesc : FoldingStateDescriptor<T,ACC> to newMetaInfo : RegisteredBackendStateMetaInfo<N,V> in method private tryRegisterStateTable(stateTable StateTable<K,N,V>, newMetaInfo RegisteredBackendStateMetaInfo<N,V>) : StateTable<K,N,V> in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend	From	To
Change Parameter Type stateDesc : ValueStateDescriptor<V> to newMetaInfo : RegisteredBackendStateMetaInfo<N,V> in method private tryRegisterStateTable(stateTable StateTable<K,N,V>, newMetaInfo RegisteredBackendStateMetaInfo<N,V>) : StateTable<K,N,V> in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend	From	To
Change Parameter Type descriptor : StateDescriptor<?,?> to descriptor : StateDescriptor<?,S> in method protected getColumnFamily(descriptor StateDescriptor<?,S>, namespaceSerializer TypeSerializer<N>) : ColumnFamilyHandle in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend	From	To
Change Parameter Type stateDesc : ReducingStateDescriptor<T> to newMetaInfo : RegisteredBackendStateMetaInfo<N,V> in method private tryRegisterStateTable(stateTable StateTable<K,N,V>, newMetaInfo RegisteredBackendStateMetaInfo<N,V>) : StateTable<K,N,V> in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend	From	To
Rename Variable	2
Rename Variable namespaceSerializer : TypeSerializer<?> to metaInfo : RegisteredBackendStateMetaInfo<?,?> in method public snapshot(checkpointId long, timestamp long, streamFactory CheckpointStreamFactory) : RunnableFuture<KeyGroupsStateHandle> in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend	From	To
Rename Variable stateDescriptor : StateDescriptor<?,?> to stateMetaInfo : RegisteredBackendStateMetaInfo<?,?> in method private restoreKVStateMetaData() : void in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBRestoreOperation	From	To
Move Attribute	2
Move Attribute private userClassLoader : ClassLoader from class org.apache.flink.runtime.state.JavaSerializer to private userClassLoader : ClassLoader from class org.apache.flink.runtime.state.KeyedBackendSerializationProxy.StateMetaInfo	From	To
Move Attribute protected namespaceSerializer : TypeSerializer<N> from class org.apache.flink.runtime.state.heap.StateTable to private namespaceSerializer : TypeSerializer<N> from class org.apache.flink.runtime.state.RegisteredBackendStateMetaInfo	From	To
Extract Class	1
Extract Class org.apache.flink.runtime.state.RegisteredBackendStateMetaInfo from class org.apache.flink.runtime.state.heap.StateTable	From	To
Merge Variable	1
Merge Variable [stateSerializer : TypeSerializer<?>, namespaceSerializer : TypeSerializer<?>] to registeredBackendStateMetaInfo : RegisteredBackendStateMetaInfo<?,?> in method private restorePartitionedState(state Collection<KeyGroupsStateHandle>) : void in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend	From	To
Rename Attribute	1
Rename Attribute stateSerializer : TypeSerializer<ST> to metaInfo : RegisteredBackendStateMetaInfo<N,ST> in class org.apache.flink.runtime.state.heap.StateTable	From	To
Extract Variable	3
Extract Variable rawAccess : Map in method protected getColumnFamily(descriptor StateDescriptor<?,S>, namespaceSerializer TypeSerializer<N>) : ColumnFamilyHandle from class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend	From	To
Extract Variable name : String in method private tryRegisterStateTable(namespaceSerializer TypeSerializer<N>, stateDesc StateDescriptor<?,V>) : StateTable<K,N,V> from class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend	From	To
Extract Variable name : String in method public createListState(namespaceSerializer TypeSerializer<N>, stateDesc ListStateDescriptor<T>) : ListState<T> from class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend	From	To
Change Variable Type	8
Change Variable Type column : Map.Entry<String,Tuple2<ColumnFamilyHandle,StateDescriptor<?,?>>> to column : Map.Entry<String,Tuple2<ColumnFamilyHandle,RegisteredBackendStateMetaInfo<?,?>>> in method private writeKVStateMetaData() : void in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBSnapshotOperation	From	To
Change Variable Type column : Tuple2<ColumnFamilyHandle,StateDescriptor<?,?>> to column : Tuple2<ColumnFamilyHandle,RegisteredBackendStateMetaInfo<?,?>> in method public dispose() : void in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend	From	To
Change Variable Type stateInfo : Tuple2<ColumnFamilyHandle,StateDescriptor<?,?>> to stateInfo : Tuple2<ColumnFamilyHandle,RegisteredBackendStateMetaInfo<?,?>> in method protected getColumnFamily(descriptor StateDescriptor<?,S>, namespaceSerializer TypeSerializer<N>) : ColumnFamilyHandle in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend	From	To
Change Variable Type stateDescriptor : StateDescriptor<?,?> to stateMetaInfo : RegisteredBackendStateMetaInfo<?,?> in method private restoreKVStateMetaData() : void in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBRestoreOperation	From	To
Change Variable Type stateTable : StateTable<K,N,T> to stateTable : StateTable<K,N,V> in method private tryRegisterStateTable(namespaceSerializer TypeSerializer<N>, stateDesc StateDescriptor<?,V>) : StateTable<K,N,V> in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend	From	To
Change Variable Type columnFamily : Tuple2<ColumnFamilyHandle,StateDescriptor<?,?>> to columnFamily : Tuple2<ColumnFamilyHandle,RegisteredBackendStateMetaInfo<?,?>> in method private restoreKVStateMetaData() : void in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBRestoreOperation	From	To
Change Variable Type stateTable : StateTable<K,N,ACC> to stateTable : StateTable<K,N,V> in method private tryRegisterStateTable(namespaceSerializer TypeSerializer<N>, stateDesc StateDescriptor<?,V>) : StateTable<K,N,V> in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend	From	To
Change Variable Type namespaceSerializer : TypeSerializer<?> to metaInfo : RegisteredBackendStateMetaInfo<?,?> in method public snapshot(checkpointId long, timestamp long, streamFactory CheckpointStreamFactory) : RunnableFuture<KeyGroupsStateHandle> in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend	From	To
Extract Method	7
Extract Method private tryRegisterStateTable(stateTable StateTable<K,N,V>, newMetaInfo RegisteredBackendStateMetaInfo<N,V>) : StateTable<K,N,V> extracted from public createValueState(namespaceSerializer TypeSerializer<N>, stateDesc ValueStateDescriptor<V>) : ValueState<V> in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend	From	To
Extract Method private tryRegisterStateTable(stateTable StateTable<K,N,V>, newMetaInfo RegisteredBackendStateMetaInfo<N,V>) : StateTable<K,N,V> extracted from public createReducingState(namespaceSerializer TypeSerializer<N>, stateDesc ReducingStateDescriptor<T>) : ReducingState<T> in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend	From	To
Extract Method private tryRegisterStateTable(stateTable StateTable<K,N,V>, newMetaInfo RegisteredBackendStateMetaInfo<N,V>) : StateTable<K,N,V> extracted from public createListState(namespaceSerializer TypeSerializer<N>, stateDesc ListStateDescriptor<T>) : ListState<T> in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend	From	To
Extract Method private tryRegisterStateTable(namespaceSerializer TypeSerializer<N>, stateDesc StateDescriptor<?,V>) : StateTable<K,N,V> extracted from public createValueState(namespaceSerializer TypeSerializer<N>, stateDesc ValueStateDescriptor<V>) : ValueState<V> in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend	From	To
Extract Method private tryRegisterStateTable(namespaceSerializer TypeSerializer<N>, stateDesc StateDescriptor<?,V>) : StateTable<K,N,V> extracted from protected createFoldingState(namespaceSerializer TypeSerializer<N>, stateDesc FoldingStateDescriptor<T,ACC>) : FoldingState<T,ACC> in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend	From	To
Extract Method private tryRegisterStateTable(stateTable StateTable<K,N,V>, newMetaInfo RegisteredBackendStateMetaInfo<N,V>) : StateTable<K,N,V> extracted from protected createFoldingState(namespaceSerializer TypeSerializer<N>, stateDesc FoldingStateDescriptor<T,ACC>) : FoldingState<T,ACC> in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend	From	To
Extract Method private tryRegisterStateTable(namespaceSerializer TypeSerializer<N>, stateDesc StateDescriptor<?,V>) : StateTable<K,N,V> extracted from public createReducingState(namespaceSerializer TypeSerializer<N>, stateDesc ReducingStateDescriptor<T>) : ReducingState<T> in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend	From	To
Change Attribute Type	2
Change Attribute Type kvStateInformation : Map<String,Tuple2<ColumnFamilyHandle,StateDescriptor<?,?>>> to kvStateInformation : Map<String,Tuple2<ColumnFamilyHandle,RegisteredBackendStateMetaInfo<?,?>>> in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend	From	To
Change Attribute Type stateSerializer : TypeSerializer<ST> to metaInfo : RegisteredBackendStateMetaInfo<N,ST> in class org.apache.flink.runtime.state.heap.StateTable	From	To
Rename Parameter	5
Rename Parameter stateDesc : ListStateDescriptor<T> to newMetaInfo : RegisteredBackendStateMetaInfo<N,V> in method private tryRegisterStateTable(stateTable StateTable<K,N,V>, newMetaInfo RegisteredBackendStateMetaInfo<N,V>) : StateTable<K,N,V> in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend	From	To
Rename Parameter stateDesc : ReducingStateDescriptor<T> to newMetaInfo : RegisteredBackendStateMetaInfo<N,V> in method private tryRegisterStateTable(stateTable StateTable<K,N,V>, newMetaInfo RegisteredBackendStateMetaInfo<N,V>) : StateTable<K,N,V> in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend	From	To
Rename Parameter stateDesc : FoldingStateDescriptor<T,ACC> to newMetaInfo : RegisteredBackendStateMetaInfo<N,V> in method private tryRegisterStateTable(stateTable StateTable<K,N,V>, newMetaInfo RegisteredBackendStateMetaInfo<N,V>) : StateTable<K,N,V> in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend	From	To
Rename Parameter stateDesc : ValueStateDescriptor<V> to newMetaInfo : RegisteredBackendStateMetaInfo<N,V> in method private tryRegisterStateTable(stateTable StateTable<K,N,V>, newMetaInfo RegisteredBackendStateMetaInfo<N,V>) : StateTable<K,N,V> in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend	From	To
Rename Parameter stateSerializer : TypeSerializer<ST> to metaInfo : RegisteredBackendStateMetaInfo<N,ST> in method public StateTable(metaInfo RegisteredBackendStateMetaInfo<N,ST>, keyGroupRange KeyGroupRange) in class org.apache.flink.runtime.state.heap.StateTable	From	To

21d1d8b49337e734ce3defb5f1b9344f748cb49e

Files Diff

Link to commit

Third party dependencies:

Refactorings reported: