|
Change Parameter Type keySerializationStream : ByteArrayOutputStreamWithPos to keySerializationDataOutputView : ByteArrayDataOutputView in method public writeNameSpace(namespace N, namespaceSerializer TypeSerializer<N>, keySerializationDataOutputView ByteArrayDataOutputView, ambiguousKeyPossible boolean) : void in class org.apache.flink.contrib.streaming.state.RocksDBKeySerializationUtils |
From |
To |
|
Change Parameter Type keySerializationStream : ByteArrayOutputStreamWithPos to keySerializationDateDataOutputView : ByteArrayDataOutputView in method private writeLengthFrom(fromPosition int, keySerializationDateDataOutputView ByteArrayDataOutputView) : void in class org.apache.flink.contrib.streaming.state.RocksDBKeySerializationUtils |
From |
To |
|
Change Parameter Type keySerializationDataOutputView : DataOutputView to keySerializationDataOutputView : ByteArrayDataOutputView in method protected writeKeyWithGroupAndNamespace(keyGroup int, key K, keySerializer TypeSerializer<K>, namespace N, namespaceSerializer TypeSerializer<N>, keySerializationDataOutputView ByteArrayDataOutputView) : void in class org.apache.flink.contrib.streaming.state.AbstractRocksDBState |
From |
To |
|
Change Parameter Type inputStream : ByteArrayInputStreamWithPos to inputView : ByteArrayDataInputView in method public readKey(keySerializer TypeSerializer<K>, inputView ByteArrayDataInputView, ambiguousKeyPossible boolean) : K in class org.apache.flink.contrib.streaming.state.RocksDBKeySerializationUtils |
From |
To |
|
Change Parameter Type keySerializationStream : ByteArrayOutputStreamWithPos to keySerializationDataOutputView : ByteArrayDataOutputView in method protected writeKeyWithGroupAndNamespace(keyGroup int, key K, keySerializer TypeSerializer<K>, namespace N, namespaceSerializer TypeSerializer<N>, keySerializationDataOutputView ByteArrayDataOutputView) : void in class org.apache.flink.contrib.streaming.state.AbstractRocksDBState |
From |
To |
|
Change Parameter Type keySerializationStream : ByteArrayOutputStreamWithPos to keySerializationDataOutputView : ByteArrayDataOutputView in method public writeKey(key K, keySerializer TypeSerializer<K>, keySerializationDataOutputView ByteArrayDataOutputView, ambiguousKeyPossible boolean) : void in class org.apache.flink.contrib.streaming.state.RocksDBKeySerializationUtils |
From |
To |
|
Change Parameter Type keySerializationDataOutputView : DataOutputView to keySerializationDataOutputView : ByteArrayDataOutputView in method protected writeKeyWithGroupAndNamespace(keyGroup int, key K, namespace N, keySerializationDataOutputView ByteArrayDataOutputView) : void in class org.apache.flink.contrib.streaming.state.AbstractRocksDBState |
From |
To |
|
Change Parameter Type inputStream : ByteArrayInputStreamWithPos to inputView : ByteArrayDataInputView in method public readNamespace(namespaceSerializer TypeSerializer<N>, inputView ByteArrayDataInputView, ambiguousKeyPossible boolean) : N in class org.apache.flink.contrib.streaming.state.RocksDBKeySerializationUtils |
From |
To |
|
Rename Variable outputStream : ByteArrayOutputStreamWithPos to outputView : ByteArrayDataOutputView in method public testNamespaceSerializationAndDeserialization() : void in class org.apache.flink.contrib.streaming.state.RocksDBKeySerializationUtilsTest |
From |
To |
|
Rename Variable outputStream : ByteArrayOutputStreamWithPos to outputView : ByteArrayDataOutputView 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 |
|
Rename Variable namespaceOutputStream : ByteArrayOutputStreamWithPos to namespaceOutputView : ByteArrayDataOutputView in method public getKeys(state String, namespace N) : Stream<K> in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend |
From |
To |
|
Rename Variable outputStream : ByteArrayOutputStreamWithPos to outputView : ByteArrayDataOutputView in method public testKeySerializationAndDeserialization() : void in class org.apache.flink.contrib.streaming.state.RocksDBKeySerializationUtilsTest |
From |
To |
|
Change Variable Type outputStream : ByteArrayOutputStreamWithPos to outputView : ByteArrayDataOutputView in method public testNamespaceSerializationAndDeserialization() : void in class org.apache.flink.contrib.streaming.state.RocksDBKeySerializationUtilsTest |
From |
To |
|
Change Variable Type outputStream : ByteArrayOutputStreamWithPos to outputView : ByteArrayDataOutputView 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 namespaceOutputStream : ByteArrayOutputStreamWithPos to namespaceOutputView : ByteArrayDataOutputView in method public getKeys(state String, namespace N) : Stream<K> in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend |
From |
To |
|
Change Variable Type outputStream : ByteArrayOutputStreamWithPos to outputView : ByteArrayDataOutputView in method public testKeySerializationAndDeserialization() : void in class org.apache.flink.contrib.streaming.state.RocksDBKeySerializationUtilsTest |
From |
To |
|
Rename Parameter keySerializationStream : ByteArrayOutputStreamWithPos to keySerializationDataOutputView : ByteArrayDataOutputView in method public writeNameSpace(namespace N, namespaceSerializer TypeSerializer<N>, keySerializationDataOutputView ByteArrayDataOutputView, ambiguousKeyPossible boolean) : void in class org.apache.flink.contrib.streaming.state.RocksDBKeySerializationUtils |
From |
To |
|
Rename Parameter keySerializationStream : ByteArrayOutputStreamWithPos to keySerializationDateDataOutputView : ByteArrayDataOutputView in method private writeLengthFrom(fromPosition int, keySerializationDateDataOutputView ByteArrayDataOutputView) : void in class org.apache.flink.contrib.streaming.state.RocksDBKeySerializationUtils |
From |
To |
|
Rename Parameter inputStream : ByteArrayInputStreamWithPos to inputView : ByteArrayDataInputView in method public readKey(keySerializer TypeSerializer<K>, inputView ByteArrayDataInputView, ambiguousKeyPossible boolean) : K in class org.apache.flink.contrib.streaming.state.RocksDBKeySerializationUtils |
From |
To |
|
Rename Parameter keySerializationStream : ByteArrayOutputStreamWithPos to keySerializationDataOutputView : ByteArrayDataOutputView in method protected writeKeyWithGroupAndNamespace(keyGroup int, key K, keySerializer TypeSerializer<K>, namespace N, namespaceSerializer TypeSerializer<N>, keySerializationDataOutputView ByteArrayDataOutputView) : void in class org.apache.flink.contrib.streaming.state.AbstractRocksDBState |
From |
To |
|
Rename Parameter keySerializationStream : ByteArrayOutputStreamWithPos to keySerializationDataOutputView : ByteArrayDataOutputView in method public writeKey(key K, keySerializer TypeSerializer<K>, keySerializationDataOutputView ByteArrayDataOutputView, ambiguousKeyPossible boolean) : void in class org.apache.flink.contrib.streaming.state.RocksDBKeySerializationUtils |
From |
To |
|
Rename Parameter inputStream : ByteArrayInputStreamWithPos to inputView : ByteArrayDataInputView in method public readNamespace(namespaceSerializer TypeSerializer<N>, inputView ByteArrayDataInputView, ambiguousKeyPossible boolean) : N in class org.apache.flink.contrib.streaming.state.RocksDBKeySerializationUtils |
From |
To |