|
Change Parameter Type metaDataCopy : List<Tuple2<ColumnFamilyHandle,RegisteredStateMetaInfoBase>> to metaDataCopy : List<RocksDbKvStateInfo> in method package SnapshotAsynchronousPartCallable(checkpointStreamSupplier SupplierWithException<CheckpointStreamWithResultProvider,Exception>, dbLease ResourceGuard.Lease, snapshot Snapshot, stateMetaInfoSnapshots List<StateMetaInfoSnapshot>, metaDataCopy List<RocksDbKvStateInfo>, logPathString String) in class org.apache.flink.contrib.streaming.state.snapshot.RocksFullSnapshotStrategy.SnapshotAsynchronousPartCallable |
From |
To |
|
Change Parameter Type kvStateInformation : LinkedHashMap<String,Tuple2<ColumnFamilyHandle,RegisteredStateMetaInfoBase>> to kvStateInformation : LinkedHashMap<String,RocksDbKvStateInfo> in method public RocksIncrementalSnapshotStrategy(db RocksDB, rocksDBResourceGuard ResourceGuard, keySerializer TypeSerializer<K>, kvStateInformation LinkedHashMap<String,RocksDbKvStateInfo>, keyGroupRange KeyGroupRange, keyGroupPrefixBytes int, localRecoveryConfig LocalRecoveryConfig, cancelStreamRegistry CloseableRegistry, instanceBasePath File, backendUID UUID, materializedSstFiles SortedMap<Long,Set<StateHandleID>>, lastCompletedCheckpointId long, numberOfTransferingThreads int) in class org.apache.flink.contrib.streaming.state.snapshot.RocksIncrementalSnapshotStrategy |
From |
To |
|
Change Parameter Type registeredColumn : Tuple2<ColumnFamilyHandle,RegisteredStateMetaInfoBase> to stateInfo : RocksDbKvStateInfo in method private registerKvStateInformation(columnFamilyName String, stateInfo RocksDbKvStateInfo) : void in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend |
From |
To |
|
Change Parameter Type metaDataCopy : List<Tuple2<ColumnFamilyHandle,RegisteredStateMetaInfoBase>> to metaDataCopy : List<RocksDbKvStateInfo> in method private fillMetaData(metaDataCopy List<RocksDbKvStateInfo>) : List<MetaData> in class org.apache.flink.contrib.streaming.state.snapshot.RocksFullSnapshotStrategy |
From |
To |
|
Change Parameter Type kvStateInformation : LinkedHashMap<String,Tuple2<ColumnFamilyHandle,RegisteredStateMetaInfoBase>> to kvStateInformation : LinkedHashMap<String,RocksDbKvStateInfo> in method public RocksDBSnapshotStrategyBase(description String, db RocksDB, rocksDBResourceGuard ResourceGuard, keySerializer TypeSerializer<K>, kvStateInformation LinkedHashMap<String,RocksDbKvStateInfo>, keyGroupRange KeyGroupRange, keyGroupPrefixBytes int, localRecoveryConfig LocalRecoveryConfig, cancelStreamRegistry CloseableRegistry) in class org.apache.flink.contrib.streaming.state.snapshot.RocksDBSnapshotStrategyBase |
From |
To |
|
Change Parameter Type kvStateInformation : LinkedHashMap<String,Tuple2<ColumnFamilyHandle,RegisteredStateMetaInfoBase>> to kvStateInformation : LinkedHashMap<String,RocksDbKvStateInfo> in method public RocksFullSnapshotStrategy(db RocksDB, rocksDBResourceGuard ResourceGuard, keySerializer TypeSerializer<K>, kvStateInformation LinkedHashMap<String,RocksDbKvStateInfo>, keyGroupRange KeyGroupRange, keyGroupPrefixBytes int, localRecoveryConfig LocalRecoveryConfig, cancelStreamRegistry CloseableRegistry, keyGroupCompressionDecorator StreamCompressionDecorator) in class org.apache.flink.contrib.streaming.state.snapshot.RocksFullSnapshotStrategy |
From |
To |
|
Change Variable Type stateMetaInfoEntry : Map.Entry<String,Tuple2<ColumnFamilyHandle,RegisteredStateMetaInfoBase>> to stateMetaInfoEntry : Map.Entry<String,RocksDbKvStateInfo> in method private snapshotMetaData(checkpointId long, stateMetaInfoSnapshots List<StateMetaInfoSnapshot>) : Set<StateHandleID> in class org.apache.flink.contrib.streaming.state.snapshot.RocksIncrementalSnapshotStrategy |
From |
To |
|
Change Variable Type metaInfoTuple : Tuple2<ColumnFamilyHandle,RegisteredStateMetaInfoBase> to stateInfo : RocksDbKvStateInfo in method public create(stateName String, byteOrderedElementSerializer TypeSerializer<T>) : KeyGroupedInternalPriorityQueue<T> in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBPriorityQueueSetFactory |
From |
To |
|
Change Variable Type metaDataCopy : List<Tuple2<ColumnFamilyHandle,RegisteredStateMetaInfoBase>> to metaDataCopy : List<RocksDbKvStateInfo> in method public doSnapshot(checkpointId long, timestamp long, primaryStreamFactory CheckpointStreamFactory, checkpointOptions CheckpointOptions) : RunnableFuture<SnapshotResult<KeyedStateHandle>> in class org.apache.flink.contrib.streaming.state.snapshot.RocksFullSnapshotStrategy |
From |
To |
|
Change Variable Type registeredStateMetaInfoEntry : Tuple2<ColumnFamilyHandle,RegisteredStateMetaInfoBase> to registeredStateMetaInfoEntry : RocksDbKvStateInfo in method private getOrRegisterColumnFamilyHandle(columnFamilyDescriptor ColumnFamilyDescriptor, columnFamilyHandle ColumnFamilyHandle, stateMetaInfoSnapshot StateMetaInfoSnapshot) : ColumnFamilyHandle in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBIncrementalRestoreOperation |
From |
To |
|
Change Variable Type columnInfo : Tuple2<ColumnFamilyHandle,RegisteredStateMetaInfoBase> to columnInfo : RocksDbKvStateInfo in method public getKeys(state String, namespace N) : Stream<K> in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend |
From |
To |
|
Change Variable Type handle : ColumnFamilyHandle to stateInfo : RocksDbKvStateInfo in method private restoreKVStateData() : void in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBFullRestoreOperation |
From |
To |
|
Change Variable Type columnMetaData : Tuple2<ColumnFamilyHandle,RegisteredStateMetaInfoBase> to kvStateInfo : RocksDbKvStateInfo in method public dispose() : void in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend |
From |
To |
|
Change Variable Type metaInfoTuple : Tuple2<ColumnFamilyHandle,RegisteredStateMetaInfoBase> to stateInfo : RocksDbKvStateInfo in method private tryRegisterPriorityQueueMetaInfo(stateName String, byteOrderedElementSerializer TypeSerializer<T>) : RocksDbKvStateInfo in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend |
From |
To |
|
Change Variable Type metaInfo : Tuple2<ColumnFamilyHandle,RegisteredStateMetaInfoBase> to rocksDbKvStateInfo : RocksDbKvStateInfo in method private fillMetaData(metaDataCopy List<RocksDbKvStateInfo>) : List<MetaData> in class org.apache.flink.contrib.streaming.state.snapshot.RocksFullSnapshotStrategy |
From |
To |
|
Change Variable Type tuple2 : Tuple2<ColumnFamilyHandle,RegisteredStateMetaInfoBase> to stateInfo : RocksDbKvStateInfo in method public doSnapshot(checkpointId long, timestamp long, primaryStreamFactory CheckpointStreamFactory, checkpointOptions CheckpointOptions) : RunnableFuture<SnapshotResult<KeyedStateHandle>> in class org.apache.flink.contrib.streaming.state.snapshot.RocksFullSnapshotStrategy |
From |
To |
|
Change Variable Type registeredColumn : Tuple2<ColumnFamilyHandle,RegisteredStateMetaInfoBase> to registeredColumn : RocksDbKvStateInfo in method private restoreKVStateMetaData() : void in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBFullRestoreOperation |
From |
To |
|
Change Variable Type columnInfo : Tuple2<ColumnFamilyHandle,?> to columnInfo : RocksDbKvStateInfo in method package getColumnFamilyHandle(state String) : ColumnFamilyHandle in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend |
From |
To |
|
Change Variable Type column : Tuple2<ColumnFamilyHandle,RegisteredStateMetaInfoBase> to metaInfo : RocksDbKvStateInfo in method public numKeyValueStateEntries() : int in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend |
From |
To |
|
Change Variable Type newColumnFamily : ColumnFamilyHandle to newRocksStateInfo : RocksDbKvStateInfo 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 |
|
Change Variable Type oldStateInfo : Tuple2<ColumnFamilyHandle,RegisteredStateMetaInfoBase> to oldStateInfo : RocksDbKvStateInfo 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 metaInfoTuple : Tuple2<ColumnFamilyHandle,RegisteredStateMetaInfoBase> to stateInfo : RocksDbKvStateInfo in method public create(stateName String, byteOrderedElementSerializer TypeSerializer<T>) : KeyGroupedInternalPriorityQueue<T> in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBPriorityQueueSetFactory |
From |
To |
|
Rename Variable metaInfo : Tuple2<ColumnFamilyHandle,RegisteredStateMetaInfoBase> to rocksDbKvStateInfo : RocksDbKvStateInfo in method private fillMetaData(metaDataCopy List<RocksDbKvStateInfo>) : List<MetaData> in class org.apache.flink.contrib.streaming.state.snapshot.RocksFullSnapshotStrategy |
From |
To |
|
Rename Variable tuple2 : Tuple2<ColumnFamilyHandle,RegisteredStateMetaInfoBase> to stateInfo : RocksDbKvStateInfo in method public doSnapshot(checkpointId long, timestamp long, primaryStreamFactory CheckpointStreamFactory, checkpointOptions CheckpointOptions) : RunnableFuture<SnapshotResult<KeyedStateHandle>> in class org.apache.flink.contrib.streaming.state.snapshot.RocksFullSnapshotStrategy |
From |
To |
|
Rename Variable columnFamilyDescriptors : List<ColumnFamilyDescriptor> to descriptors : List<ColumnFamilyDescriptor> in method package restoreWithoutRescaling(rawStateHandle KeyedStateHandle) : void in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBIncrementalRestoreOperation |
From |
To |
|
Rename Variable column : Tuple2<ColumnFamilyHandle,RegisteredStateMetaInfoBase> to metaInfo : RocksDbKvStateInfo in method public numKeyValueStateEntries() : int in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend |
From |
To |
|
Rename Variable newColumnFamily : ColumnFamilyHandle to newRocksStateInfo : RocksDbKvStateInfo 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 stateMetaInfo : RegisteredStateMetaInfoBase to metaInfoBase : RegisteredStateMetaInfoBase in method private restoreKVStateMetaData() : void in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBFullRestoreOperation |
From |
To |
|
Rename Variable columnFamilyDescriptors : List<ColumnFamilyDescriptor> to descriptors : List<ColumnFamilyDescriptor> in method private restoreDBInstanceFromStateHandle(restoreStateHandle IncrementalKeyedStateHandle, temporaryRestoreInstancePath Path, registerTtlCompactFilter boolean) : RestoredDBInstance in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBIncrementalRestoreOperation |
From |
To |
|
Rename Variable handle : ColumnFamilyHandle to stateInfo : RocksDbKvStateInfo in method private restoreKVStateData() : void in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBFullRestoreOperation |
From |
To |
|
Rename Variable columnMetaData : Tuple2<ColumnFamilyHandle,RegisteredStateMetaInfoBase> to kvStateInfo : RocksDbKvStateInfo in method public dispose() : void in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend |
From |
To |
|
Rename Variable metaInfoTuple : Tuple2<ColumnFamilyHandle,RegisteredStateMetaInfoBase> to stateInfo : RocksDbKvStateInfo in method private tryRegisterPriorityQueueMetaInfo(stateName String, byteOrderedElementSerializer TypeSerializer<T>) : RocksDbKvStateInfo in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend |
From |
To |
|
Change Return Type void to StateDescriptor<S,Object> in method protected initTest(ttlConfig StateTtlConfig) : StateDescriptor<S,Object> in class org.apache.flink.runtime.state.ttl.TtlStateTestBase |
From |
To |
|
Change Return Type MonotonicTTLTimeProvider to void in method private setBackendWithCustomTTLTimeProvider(env StreamExecutionEnvironment) : void in class org.apache.flink.streaming.tests.DataStreamStateTTLTestProgram |
From |
To |
|
Change Return Type Tuple2<ColumnFamilyHandle,RegisteredStateMetaInfoBase> to RocksDbKvStateInfo in method private tryRegisterPriorityQueueMetaInfo(stateName String, byteOrderedElementSerializer TypeSerializer<T>) : RocksDbKvStateInfo in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend |
From |
To |
|
Change Return Type void to StateDescriptor<S,Object> in method private createState() : StateDescriptor<S,Object> in class org.apache.flink.runtime.state.ttl.TtlStateTestBase |
From |
To |
|
Change Attribute Type registeredStateMetaInfoBase : RegisteredStateMetaInfoBase to rocksDbKvStateInfo : RocksDbKvStateInfo in class org.apache.flink.contrib.streaming.state.snapshot.RocksFullSnapshotStrategy.MetaData |
From |
To |
|
Change Attribute Type kvStateInformation : LinkedHashMap<String,Tuple2<ColumnFamilyHandle,RegisteredStateMetaInfoBase>> to kvStateInformation : LinkedHashMap<String,RocksDbKvStateInfo> in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend |
From |
To |
|
Change Attribute Type kvStateInformation : LinkedHashMap<String,Tuple2<ColumnFamilyHandle,RegisteredStateMetaInfoBase>> to kvStateInformation : LinkedHashMap<String,RocksDbKvStateInfo> in class org.apache.flink.contrib.streaming.state.snapshot.RocksDBSnapshotStrategyBase |
From |
To |
|
Change Attribute Type currentStateHandleKVStateColumnFamilies : List<ColumnFamilyHandle> to currentKvStates : List<RocksDbKvStateInfo> in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBFullRestoreOperation |
From |
To |