|
Rename Variable metaInfoTypeSerializer : TypeSerializer<?> to previousElementSerializer : TypeSerializer<T> in method private tryRegisterPriorityQueueMetaInfo(stateName String, byteOrderedElementSerializer TypeSerializer<T>) : Tuple2<ColumnFamilyHandle,RegisteredStateMetaInfoBase> in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend |
From |
To |
|
Rename Variable columnFamily : ColumnFamilyHandle to newColumnFamily : ColumnFamilyHandle in method private tryRegisterKvStateInformation(stateDesc StateDescriptor<S,SV>, namespaceSerializer TypeSerializer<N>, snapshotTransformer StateSnapshotTransformer<SV>) : Tuple2<ColumnFamilyHandle,RegisteredKeyValueStateBackendMetaInfo<N,SV>> in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend |
From |
To |
|
Rename Variable stateInfo : Tuple2<ColumnFamilyHandle,RegisteredStateMetaInfoBase> to oldStateInfo : Tuple2<ColumnFamilyHandle,RegisteredStateMetaInfoBase> in method private tryRegisterKvStateInformation(stateDesc StateDescriptor<S,SV>, namespaceSerializer TypeSerializer<N>, snapshotTransformer StateSnapshotTransformer<SV>) : Tuple2<ColumnFamilyHandle,RegisteredKeyValueStateBackendMetaInfo<N,SV>> in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend |
From |
To |