|
Extract And Move Method package getKeyBytes() : byte[] extracted from public add(value V) : void in class org.apache.flink.contrib.streaming.state.RocksDBReducingState & moved to class org.apache.flink.contrib.streaming.state.AbstractRocksDBState |
From |
To |
|
Extract And Move Method public getInternal() : List<V> extracted from public get() : V in class org.apache.flink.contrib.streaming.state.RocksDBReducingState & moved to class org.apache.flink.contrib.streaming.state.RocksDBListState |
From |
To |
|
Extract And Move Method public getInternal() : List<V> extracted from public get() : R in class org.apache.flink.contrib.streaming.state.RocksDBAggregatingState & moved to class org.apache.flink.contrib.streaming.state.RocksDBListState |
From |
To |
|
Extract And Move Method package getKeyBytes() : byte[] extracted from public add(value T) : void in class org.apache.flink.contrib.streaming.state.RocksDBFoldingState & moved to class org.apache.flink.contrib.streaming.state.AbstractRocksDBState |
From |
To |
|
Extract And Move Method package getKeyBytes() : byte[] extracted from public add(value T) : void in class org.apache.flink.contrib.streaming.state.RocksDBAggregatingState & moved to class org.apache.flink.contrib.streaming.state.AbstractRocksDBState |
From |
To |
|
Extract And Move Method public getInternal() : List<V> extracted from public get() : ACC in class org.apache.flink.contrib.streaming.state.RocksDBFoldingState & moved to class org.apache.flink.contrib.streaming.state.RocksDBListState |
From |
To |