|
Change Parameter Type keySerializerProvider : StateSerializerProvider<K> to keySerializer : TypeSerializer<K> in method public AbstractKeyedStateBackend(kvStateRegistry TaskKvStateRegistry, keySerializer TypeSerializer<K>, userCodeClassLoader ClassLoader, executionConfig ExecutionConfig, ttlTimeProvider TtlTimeProvider, cancelStreamRegistry CloseableRegistry, keyGroupCompressionDecorator StreamCompressionDecorator, keyContext InternalKeyContext<K>) in class org.apache.flink.runtime.state.AbstractKeyedStateBackend |
From |
To |
|
Change Parameter Type keySerializerProvider : StateSerializerProvider<K> to keySerializer : TypeSerializer<K> in method public HeapKeyedStateBackend(kvStateRegistry TaskKvStateRegistry, keySerializer TypeSerializer<K>, userCodeClassLoader ClassLoader, executionConfig ExecutionConfig, ttlTimeProvider TtlTimeProvider, cancelStreamRegistry CloseableRegistry, keyGroupCompressionDecorator StreamCompressionDecorator, registeredKVStates Map<String,StateTable<K,?,?>>, registeredPQStates Map<String,HeapPriorityQueueSnapshotRestoreWrapper>, localRecoveryConfig LocalRecoveryConfig, priorityQueueSetFactory HeapPriorityQueueSetFactory, snapshotStrategy HeapSnapshotStrategy<K>, keyContext InternalKeyContext<K>) in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend |
From |
To |
|
Change Parameter Type keySerializerProvider : StateSerializerProvider<K> to keySerializer : TypeSerializer<K> in method public RocksDBKeyedStateBackend(userCodeClassLoader ClassLoader, instanceBasePath File, dbOptions DBOptions, columnFamilyOptionsFactory Function<String,ColumnFamilyOptions>, kvStateRegistry TaskKvStateRegistry, keySerializer TypeSerializer<K>, executionConfig ExecutionConfig, ttlTimeProvider TtlTimeProvider, db RocksDB, kvStateInformation LinkedHashMap<String,RocksDbKvStateInfo>, keyGroupPrefixBytes int, cancelStreamRegistry CloseableRegistry, keyGroupCompressionDecorator StreamCompressionDecorator, rocksDBResourceGuard ResourceGuard, checkpointSnapshotStrategy RocksDBSnapshotStrategyBase<K>, savepointSnapshotStrategy RocksDBSnapshotStrategyBase<K>, writeBatchWrapper RocksDBWriteBatchWrapper, defaultColumnFamilyHandle ColumnFamilyHandle, nativeMetricMonitor RocksDBNativeMetricMonitor, sharedRocksKeyBuilder RocksDBSerializedCompositeKeyBuilder<K>, priorityQueueFactory PriorityQueueSetFactory, ttlCompactFiltersManager RocksDbTtlCompactFiltersManager, keyContext InternalKeyContext<K>) in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend |
From |
To |
|
Rename Parameter keySerializerProvider : StateSerializerProvider<K> to keySerializer : TypeSerializer<K> in method public HeapKeyedStateBackend(kvStateRegistry TaskKvStateRegistry, keySerializer TypeSerializer<K>, userCodeClassLoader ClassLoader, executionConfig ExecutionConfig, ttlTimeProvider TtlTimeProvider, cancelStreamRegistry CloseableRegistry, keyGroupCompressionDecorator StreamCompressionDecorator, registeredKVStates Map<String,StateTable<K,?,?>>, registeredPQStates Map<String,HeapPriorityQueueSnapshotRestoreWrapper>, localRecoveryConfig LocalRecoveryConfig, priorityQueueSetFactory HeapPriorityQueueSetFactory, snapshotStrategy HeapSnapshotStrategy<K>, keyContext InternalKeyContext<K>) in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend |
From |
To |
|
Rename Parameter keySerializerProvider : StateSerializerProvider<K> to keySerializer : TypeSerializer<K> in method public RocksDBKeyedStateBackend(userCodeClassLoader ClassLoader, instanceBasePath File, dbOptions DBOptions, columnFamilyOptionsFactory Function<String,ColumnFamilyOptions>, kvStateRegistry TaskKvStateRegistry, keySerializer TypeSerializer<K>, executionConfig ExecutionConfig, ttlTimeProvider TtlTimeProvider, db RocksDB, kvStateInformation LinkedHashMap<String,RocksDbKvStateInfo>, keyGroupPrefixBytes int, cancelStreamRegistry CloseableRegistry, keyGroupCompressionDecorator StreamCompressionDecorator, rocksDBResourceGuard ResourceGuard, checkpointSnapshotStrategy RocksDBSnapshotStrategyBase<K>, savepointSnapshotStrategy RocksDBSnapshotStrategyBase<K>, writeBatchWrapper RocksDBWriteBatchWrapper, defaultColumnFamilyHandle ColumnFamilyHandle, nativeMetricMonitor RocksDBNativeMetricMonitor, sharedRocksKeyBuilder RocksDBSerializedCompositeKeyBuilder<K>, priorityQueueFactory PriorityQueueSetFactory, ttlCompactFiltersManager RocksDbTtlCompactFiltersManager, keyContext InternalKeyContext<K>) in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend |
From |
To |
|
Rename Parameter keySerializerProvider : StateSerializerProvider<K> to keySerializer : TypeSerializer<K> in method public AbstractKeyedStateBackend(kvStateRegistry TaskKvStateRegistry, keySerializer TypeSerializer<K>, userCodeClassLoader ClassLoader, executionConfig ExecutionConfig, ttlTimeProvider TtlTimeProvider, cancelStreamRegistry CloseableRegistry, keyGroupCompressionDecorator StreamCompressionDecorator, keyContext InternalKeyContext<K>) in class org.apache.flink.runtime.state.AbstractKeyedStateBackend |
From |
To |