|
Change Parameter Type dataInputView : ByteArrayDataInputView to dataInputView : DataInputDeserializer in method package RocksDBMapEntry(db RocksDB, userKeyOffset int, rawKeyBytes byte[], rawValueBytes byte[], keySerializer TypeSerializer<UK>, valueSerializer TypeSerializer<UV>, dataInputView DataInputDeserializer, dataOutputView DataOutputSerializer) in class org.apache.flink.contrib.streaming.state.RocksDBMapState.RocksDBMapEntry |
From |
To |
|
Change Parameter Type dataInputView : ByteArrayDataInputView to dataInputView : DataInputDeserializer in method private deserializeUserValue(dataInputView DataInputDeserializer, rawValueBytes byte[], valueSerializer TypeSerializer<UV>) : UV in class org.apache.flink.contrib.streaming.state.RocksDBMapState |
From |
To |
|
Change Parameter Type keySerializationDataOutputView : ByteArrayDataOutputView to keySerializationDataOutputView : DataOutputSerializer in method public writeKey(key K, keySerializer TypeSerializer<K>, keySerializationDataOutputView DataOutputSerializer, ambiguousKeyPossible boolean) : void in class org.apache.flink.contrib.streaming.state.RocksDBKeySerializationUtils |
From |
To |
|
Change Parameter Type keySerializationDataOutputView : ByteArrayDataOutputView to keySerializationDataOutputView : DataOutputSerializer in method protected writeKeyWithGroupAndNamespace(keyGroup int, key K, namespace N, keySerializationDataOutputView DataOutputSerializer) : void in class org.apache.flink.contrib.streaming.state.AbstractRocksDBState |
From |
To |
|
Change Parameter Type keySerializationStream : ByteArrayDataOutputView to keySerializationStream : DataOutputSerializer in method private getPreMergedValue(values List<V>, elementSerializer TypeSerializer<V>, keySerializationStream DataOutputSerializer) : byte[] in class org.apache.flink.contrib.streaming.state.RocksDBListState |
From |
To |
|
Change Parameter Type dataInputView : ByteArrayDataInputView to dataInputView : DataInputDeserializer in method private deserializeUserKey(dataInputView DataInputDeserializer, userKeyOffset int, rawKeyBytes byte[], keySerializer TypeSerializer<UK>) : UK in class org.apache.flink.contrib.streaming.state.RocksDBMapState |
From |
To |
|
Change Parameter Type keySerializationDateDataOutputView : ByteArrayDataOutputView to keySerializationDateDataOutputView : DataOutputSerializer in method private writeLengthFrom(fromPosition int, keySerializationDateDataOutputView DataOutputSerializer) : void in class org.apache.flink.contrib.streaming.state.RocksDBKeySerializationUtils |
From |
To |
|
Change Parameter Type dataOutputView : ByteArrayDataOutputView to dataOutputView : DataOutputSerializer in method private serializeUserValue(userValue UV, valueSerializer TypeSerializer<UV>, dataOutputView DataOutputSerializer) : byte[] in class org.apache.flink.contrib.streaming.state.RocksDBMapState |
From |
To |
|
Change Parameter Type dataOutputView : ByteArrayDataOutputView to dataOutputView : DataOutputSerializer in method package RocksDBMapEntry(db RocksDB, userKeyOffset int, rawKeyBytes byte[], rawValueBytes byte[], keySerializer TypeSerializer<UK>, valueSerializer TypeSerializer<UV>, dataInputView DataInputDeserializer, dataOutputView DataOutputSerializer) in class org.apache.flink.contrib.streaming.state.RocksDBMapState.RocksDBMapEntry |
From |
To |
|
Change Parameter Type readView : ByteArrayDataInputView to readView : DataInputDeserializer in method private deserializeKey(keyBytes byte[], readView DataInputDeserializer) : K in class org.apache.flink.contrib.streaming.state.iterator.RocksStateKeysIterator |
From |
To |
|
Change Parameter Type inputStream : ByteArrayDataInputView to inputStream : DataInputDeserializer in method package RocksDBCachingPriorityQueueSet(keyGroupId int, keyGroupPrefixBytes int, db RocksDB, columnFamilyHandle ColumnFamilyHandle, byteOrderProducingSerializer TypeSerializer<E>, outputStream DataOutputSerializer, inputStream DataInputDeserializer, batchWrapper RocksDBWriteBatchWrapper, orderedByteArraySetCache OrderedByteArraySetCache) in class org.apache.flink.contrib.streaming.state.RocksDBCachingPriorityQueueSet |
From |
To |
|
Change Parameter Type inputView : ByteArrayDataInputView to inputView : DataInputDeserializer in method public readNamespace(namespaceSerializer TypeSerializer<N>, inputView DataInputDeserializer, ambiguousKeyPossible boolean) : N in class org.apache.flink.contrib.streaming.state.RocksDBKeySerializationUtils |
From |
To |
|
Change Parameter Type in : DataInputViewStreamWrapper to in : DataInputDeserializer in method private deserializeNextElement(in DataInputDeserializer, elementSerializer TypeSerializer<V>) : V in class org.apache.flink.contrib.streaming.state.RocksDBListState |
From |
To |
|
Change Parameter Type dataInputView : ByteArrayDataInputView to dataInputView : DataInputDeserializer in method package RocksDBMapIterator(db RocksDB, keyPrefixBytes byte[], keySerializer TypeSerializer<UK>, valueSerializer TypeSerializer<UV>, dataInputView DataInputDeserializer) in class org.apache.flink.contrib.streaming.state.RocksDBMapState.RocksDBMapIterator |
From |
To |
|
Change Parameter Type inputView : ByteArrayDataInputView to inputView : DataInputDeserializer in method public readKey(keySerializer TypeSerializer<K>, inputView DataInputDeserializer, ambiguousKeyPossible boolean) : K in class org.apache.flink.contrib.streaming.state.RocksDBKeySerializationUtils |
From |
To |
|
Change Parameter Type keySerializationDataOutputView : ByteArrayDataOutputView to keySerializationDataOutputView : DataOutputSerializer in method protected writeKeyWithGroupAndNamespace(keyGroup int, key K, keySerializer TypeSerializer<K>, namespace N, namespaceSerializer TypeSerializer<N>, keySerializationDataOutputView DataOutputSerializer) : void in class org.apache.flink.contrib.streaming.state.AbstractRocksDBState |
From |
To |
|
Change Parameter Type keySerializationDataOutputView : ByteArrayDataOutputView to keySerializationDataOutputView : DataOutputSerializer in method public writeNameSpace(namespace N, namespaceSerializer TypeSerializer<N>, keySerializationDataOutputView DataOutputSerializer, ambiguousKeyPossible boolean) : void in class org.apache.flink.contrib.streaming.state.RocksDBKeySerializationUtils |
From |
To |
|
Change Parameter Type outputStream : ByteArrayDataOutputView to outputStream : DataOutputSerializer in method package RocksDBCachingPriorityQueueSet(keyGroupId int, keyGroupPrefixBytes int, db RocksDB, columnFamilyHandle ColumnFamilyHandle, byteOrderProducingSerializer TypeSerializer<E>, outputStream DataOutputSerializer, inputStream DataInputDeserializer, batchWrapper RocksDBWriteBatchWrapper, orderedByteArraySetCache OrderedByteArraySetCache) in class org.apache.flink.contrib.streaming.state.RocksDBCachingPriorityQueueSet |
From |
To |
|
Change Variable Type inputView : ByteArrayDataInputView to inputView : DataInputDeserializer in method public testKeySerializationAndDeserialization() : void in class org.apache.flink.contrib.streaming.state.RocksDBKeySerializationUtilsTest |
From |
To |
|
Change Variable Type inputView : ByteArrayDataInputView to inputView : DataInputDeserializer in method public getSerializedValue(serializedKeyAndNamespace byte[], safeKeySerializer TypeSerializer<K>, safeNamespaceSerializer TypeSerializer<N>, safeValueSerializer TypeSerializer<Map<UK,UV>>) : byte[] in class org.apache.flink.contrib.streaming.state.RocksDBMapState |
From |
To |
|
Change Variable Type inputView : ByteArrayDataInputView to inputView : DataInputDeserializer in method public testNamespaceSerializationAndDeserialization() : void in class org.apache.flink.contrib.streaming.state.RocksDBKeySerializationUtilsTest |
From |
To |
|
Change Variable Type in : ByteArrayDataInputView to in : DataInputDeserializer in method public filterOrTransform(value byte[]) : byte[] in class org.apache.flink.contrib.streaming.state.RocksDBListState.StateSnapshotTransformerWrapper |
From |
To |
|
Change Variable Type outputView : ByteArrayDataOutputView to outputView : DataOutputSerializer in method public testNamespaceSerializationAndDeserialization() : void in class org.apache.flink.contrib.streaming.state.RocksDBKeySerializationUtilsTest |
From |
To |
|
Change Variable Type outputView : ByteArrayDataOutputView to outputView : DataOutputSerializer in method private testClipDBWithKeyGroupRangeHelper(targetGroupRange KeyGroupRange, currentGroupRange KeyGroupRange, keyGroupPrefixBytes int) : void in class org.apache.flink.contrib.streaming.state.RocksDBIncrementalCheckpointUtilsTest |
From |
To |
|
Change Variable Type outputView : ByteArrayDataOutputView to outputView : DataOutputSerializer in method public getSerializedValue(serializedKeyAndNamespace byte[], safeKeySerializer TypeSerializer<K>, safeNamespaceSerializer TypeSerializer<N>, safeValueSerializer TypeSerializer<Map<UK,UV>>) : byte[] in class org.apache.flink.contrib.streaming.state.RocksDBMapState |
From |
To |
|
Change Variable Type outputView : ByteArrayDataOutputView to outputView : DataOutputSerializer in method public testKeySerializationAndDeserialization() : void in class org.apache.flink.contrib.streaming.state.RocksDBKeySerializationUtilsTest |
From |
To |
|
Change Variable Type tmpKeySerializationView : ByteArrayDataOutputView to tmpKeySerializationView : DataOutputSerializer in method public getSerializedValue(serializedKeyAndNamespace byte[], safeKeySerializer TypeSerializer<K>, safeNamespaceSerializer TypeSerializer<N>, safeValueSerializer TypeSerializer<V>) : byte[] in class org.apache.flink.contrib.streaming.state.AbstractRocksDBState |
From |
To |
|
Change Variable Type outputStream : ByteArrayDataOutputView to outputStream : DataOutputSerializer in method package testIteratorHelper(keySerializer TypeSerializer<K>, namespaceSerializer TypeSerializer, maxKeyGroupNumber int, getKeyFunc Function<Integer,K>) : void in class org.apache.flink.contrib.streaming.state.RocksDBRocksStateKeysIteratorTest |
From |
To |
|
Change Variable Type namespaceOutputView : ByteArrayDataOutputView to namespaceOutputView : DataOutputSerializer in method public getKeys(state String, namespace N) : Stream<K> in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend |
From |
To |
|
Change Attribute Type div : ByteArrayDataInputView to div : DataInputDeserializer in class org.apache.flink.contrib.streaming.state.RocksDBMapState.StateSnapshotTransformerWrapper |
From |
To |
|
Change Attribute Type sharedElementOutView : ByteArrayDataOutputView to sharedElementOutView : DataOutputSerializer in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBPriorityQueueSetFactory |
From |
To |
|
Change Attribute Type dataInputView : ByteArrayDataInputView to dataInputView : DataInputDeserializer in class org.apache.flink.contrib.streaming.state.RocksDBMapState.RocksDBMapIterator |
From |
To |
|
Change Attribute Type div : ByteArrayDataInputView to div : DataInputDeserializer in class org.apache.flink.runtime.state.ttl.TtlStateSnapshotTransformer |
From |
To |
|
Change Attribute Type out : ByteArrayDataOutputView to out : DataOutputSerializer in class org.apache.flink.contrib.streaming.state.RocksDBListState.StateSnapshotTransformerWrapper |
From |
To |
|
Change Attribute Type dataInputView : ByteArrayDataInputView to dataInputView : DataInputDeserializer in class org.apache.flink.contrib.streaming.state.RocksDBMapState.RocksDBMapEntry |
From |
To |
|
Change Attribute Type dataOutputView : ByteArrayDataOutputView to dataOutputView : DataOutputSerializer in class org.apache.flink.contrib.streaming.state.RocksDBMapState.RocksDBMapEntry |
From |
To |
|
Change Attribute Type outputView : ByteArrayDataOutputView to outputView : DataOutputSerializer in class org.apache.flink.contrib.streaming.state.RocksDBCachingPriorityQueueSet |
From |
To |
|
Change Attribute Type byteArrayDataInputView : ByteArrayDataInputView to byteArrayDataInputView : DataInputDeserializer in class org.apache.flink.contrib.streaming.state.iterator.RocksStateKeysIterator |
From |
To |
|
Change Attribute Type sharedElementInView : ByteArrayDataInputView to sharedElementInView : DataInputDeserializer in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBPriorityQueueSetFactory |
From |
To |
|
Change Attribute Type inputView : ByteArrayDataInputView to inputView : DataInputDeserializer in class org.apache.flink.contrib.streaming.state.RocksDBCachingPriorityQueueSet |
From |
To |
|
Change Attribute Type dataOutputView : ByteArrayDataOutputView to dataOutputView : DataOutputSerializer in class org.apache.flink.contrib.streaming.state.AbstractRocksDBState |
From |
To |
|
Change Attribute Type dataInputView : ByteArrayDataInputView to dataInputView : DataInputDeserializer in class org.apache.flink.contrib.streaming.state.AbstractRocksDBState |
From |
To |