|
Change Parameter Type mapState : InternalMapState<VoidNamespace,Long,String> to mapState : InternalMapState<Long,VoidNamespace,Long,String,M> in method public testMapSerialization(key long, mapState InternalMapState<Long,VoidNamespace,Long,String,M>) : void in class org.apache.flink.queryablestate.network.KvStateRequestSerializerTest |
From |
To |
|
Change Parameter Type kvState : InternalKvState<N> to kvState : InternalKvState<K,N,V> in method protected getSerializedValue(kvState InternalKvState<K,N,V>, key K, keySerializer TypeSerializer<K>, namespace N, namespaceSerializer TypeSerializer<N>, valueSerializer TypeSerializer<V>) : V in class org.apache.flink.runtime.state.StateBackendTestBase |
From |
To |
|
Change Parameter Type kvState : InternalKvState<N> to kvState : InternalKvState<K,N,Map<UK,UV>> in method private getSerializedMap(kvState InternalKvState<K,N,Map<UK,UV>>, key K, keySerializer TypeSerializer<K>, namespace N, namespaceSerializer TypeSerializer<N>, userKeySerializer TypeSerializer<UK>, userValueSerializer TypeSerializer<UV>) : Map<UK,UV> in class org.apache.flink.runtime.state.StateBackendTestBase |
From |
To |
|
Change Parameter Type listState : InternalListState<VoidNamespace,Long> to listState : InternalListState<Long,VoidNamespace,Long> in method public testListSerialization(key long, listState InternalListState<Long,VoidNamespace,Long>) : void in class org.apache.flink.queryablestate.network.KvStateRequestSerializerTest |
From |
To |
|
Change Parameter Type kvState : InternalKvState<?> to kvState : InternalKvState<?,?,?> in method public registerKvState(keyGroupRange KeyGroupRange, registrationName String, kvState InternalKvState<?,?,?>) : void in class org.apache.flink.runtime.query.TaskKvStateRegistry |
From |
To |
|
Change Parameter Type kvState : InternalKvState<?> to kvState : InternalKvState<?,?,?> in method public registerKvState(jobId JobID, jobVertexId JobVertexID, keyGroupRange KeyGroupRange, registrationName String, kvState InternalKvState<?,?,?>) : KvStateID in class org.apache.flink.runtime.query.KvStateRegistry |
From |
To |
|
Change Parameter Type kvState : InternalKvState<N> to kvState : InternalKvState<K,N,V> in method private getSerializedList(kvState InternalKvState<K,N,V>, key K, keySerializer TypeSerializer<K>, namespace N, namespaceSerializer TypeSerializer<N>, valueSerializer TypeSerializer<V>) : List<V> in class org.apache.flink.runtime.state.StateBackendTestBase |
From |
To |
|
Change Return Type InternalValueState<N,V> to InternalValueState<K,N,V> in method public createValueState(namespaceSerializer TypeSerializer<N>, stateDesc ValueStateDescriptor<V>) : InternalValueState<K,N,V> in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend |
From |
To |
|
Change Return Type InternalListState<N,T> to InternalListState<K,N,T> in method protected createListState(namespaceSerializer TypeSerializer<N>, stateDesc ListStateDescriptor<T>) : InternalListState<K,N,T> in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend |
From |
To |
|
Change Return Type InternalListState<N,T> to InternalListState<K,N,T> in method public createListState(namespaceSerializer TypeSerializer<N>, stateDesc ListStateDescriptor<T>) : InternalListState<K,N,T> in class org.apache.flink.queryablestate.network.KVStateRequestSerializerRocksDBTest.RocksDBKeyedStateBackend2 |
From |
To |
|
Change Return Type InternalMapState<N,UK,UV> to InternalMapState<K,N,UK,UV,? extends Map<UK,UV>> in method protected abstract createMapState(namespaceSerializer TypeSerializer<N>, stateDesc MapStateDescriptor<UK,UV>) : InternalMapState<K,N,UK,UV,? extends Map<UK,UV>> in class org.apache.flink.runtime.state.AbstractKeyedStateBackend |
From |
To |
|
Change Return Type InternalValueState<N,T> to InternalValueState<K,N,T> in method protected abstract createValueState(namespaceSerializer TypeSerializer<N>, stateDesc ValueStateDescriptor<T>) : InternalValueState<K,N,T> in class org.apache.flink.runtime.state.AbstractKeyedStateBackend |
From |
To |
|
Change Return Type InternalFoldingState<N,T,ACC> to InternalFoldingState<K,N,T,ACC> in method protected createFoldingState(namespaceSerializer TypeSerializer<N>, stateDesc FoldingStateDescriptor<T,ACC>) : InternalFoldingState<K,N,T,ACC> in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend |
From |
To |
|
Change Return Type InternalAggregatingState<N,T,R> to InternalAggregatingState<K,N,T,ACC,R> in method public createAggregatingState(namespaceSerializer TypeSerializer<N>, stateDesc AggregatingStateDescriptor<T,ACC,R>) : InternalAggregatingState<K,N,T,ACC,R> in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend |
From |
To |
|
Change Return Type InternalMapState<N,UK,UV> to InternalMapState<K,N,UK,UV,? extends Map<UK,UV>> in method protected createMapState(namespaceSerializer TypeSerializer<N>, stateDesc MapStateDescriptor<UK,UV>) : InternalMapState<K,N,UK,UV,? extends Map<UK,UV>> in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend |
From |
To |
|
Change Return Type InternalReducingState<N,T> to InternalReducingState<K,N,T> in method protected createReducingState(namespaceSerializer TypeSerializer<N>, stateDesc ReducingStateDescriptor<T>) : InternalReducingState<K,N,T> in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend |
From |
To |
|
Change Return Type InternalAggregatingState<N,T,R> to InternalAggregatingState<K,N,T,ACC,R> in method protected abstract createAggregatingState(namespaceSerializer TypeSerializer<N>, stateDesc AggregatingStateDescriptor<T,ACC,R>) : InternalAggregatingState<K,N,T,ACC,R> in class org.apache.flink.runtime.state.AbstractKeyedStateBackend |
From |
To |
|
Change Return Type InternalReducingState<N,T> to InternalReducingState<K,N,T> in method protected abstract createReducingState(namespaceSerializer TypeSerializer<N>, stateDesc ReducingStateDescriptor<T>) : InternalReducingState<K,N,T> in class org.apache.flink.runtime.state.AbstractKeyedStateBackend |
From |
To |
|
Change Return Type InternalListState<N,T> to InternalListState<K,N,T> in method protected abstract createListState(namespaceSerializer TypeSerializer<N>, stateDesc ListStateDescriptor<T>) : InternalListState<K,N,T> in class org.apache.flink.runtime.state.AbstractKeyedStateBackend |
From |
To |
|
Change Return Type InternalValueState<N,T> to InternalValueState<K,N,T> in method protected createValueState(namespaceSerializer TypeSerializer<N>, stateDesc ValueStateDescriptor<T>) : InternalValueState<K,N,T> in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend |
From |
To |
|
Change Return Type InternalKvState<?> to KvStateEntry<?,?,?> in method public getKvState(kvStateId KvStateID) : KvStateEntry<?,?,?> in class org.apache.flink.runtime.query.KvStateRegistry |
From |
To |
|
Change Return Type InternalListState<N,T> to InternalListState<K,N,T> in method public createListState(namespaceSerializer TypeSerializer<N>, stateDesc ListStateDescriptor<T>) : InternalListState<K,N,T> in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend |
From |
To |
|
Change Return Type InternalReducingState<N,T> to InternalReducingState<K,N,T> in method public createReducingState(namespaceSerializer TypeSerializer<N>, stateDesc ReducingStateDescriptor<T>) : InternalReducingState<K,N,T> in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend |
From |
To |
|
Change Return Type InternalAggregatingState<N,T,R> to InternalAggregatingState<K,N,T,ACC,R> in method protected createAggregatingState(namespaceSerializer TypeSerializer<N>, stateDesc AggregatingStateDescriptor<T,ACC,R>) : InternalAggregatingState<K,N,T,ACC,R> in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend |
From |
To |
|
Change Return Type InternalMapState<N,UK,UV> to InternalMapState<K,N,UK,UV,? extends Map<UK,UV>> in method protected createMapState(namespaceSerializer TypeSerializer<N>, stateDesc MapStateDescriptor<UK,UV>) : InternalMapState<K,N,UK,UV,? extends Map<UK,UV>> in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend |
From |
To |
|
Change Return Type InternalFoldingState<N,T,ACC> to InternalFoldingState<K,N,T,ACC> in method protected abstract createFoldingState(namespaceSerializer TypeSerializer<N>, stateDesc FoldingStateDescriptor<T,ACC>) : InternalFoldingState<K,N,T,ACC> in class org.apache.flink.runtime.state.AbstractKeyedStateBackend |
From |
To |
|
Change Return Type InternalFoldingState<N,T,ACC> to InternalFoldingState<K,N,T,ACC> in method public createFoldingState(namespaceSerializer TypeSerializer<N>, stateDesc FoldingStateDescriptor<T,ACC>) : InternalFoldingState<K,N,T,ACC> in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend |
From |
To |
|
Change Variable Type kvState : InternalKvState<N> to kvState : InternalKvState<K,N,?> in method public getPartitionedState(namespace N, namespaceSerializer TypeSerializer<N>, stateDescriptor StateDescriptor<S,?>) : S in class org.apache.flink.runtime.state.AbstractKeyedStateBackend |
From |
To |
|
Change Variable Type kvState : InternalKvState<?> to kvState : KvStateEntry<?,?,?> in method public handleRequest(requestId long, request KvStateInternalRequest) : CompletableFuture<KvStateResponse> in class org.apache.flink.queryablestate.server.KvStateServerHandler |
From |
To |
|
Change Variable Type restoredKvState2 : InternalKvState<VoidNamespace> to restoredKvState2 : InternalKvState<Integer,VoidNamespace,String> in method public testFoldingState() : void in class org.apache.flink.runtime.state.StateBackendTestBase |
From |
To |
|
Change Variable Type valueState : InternalValueState<VoidNamespace,Integer> to valueState : InternalValueState<Integer,VoidNamespace,Integer> in method public testAsyncSnapshot() : void in class org.apache.flink.runtime.state.StateBackendTestBase |
From |
To |
|
Change Variable Type restoredKvState1 : InternalKvState<VoidNamespace> to restoredKvState1 : InternalKvState<Integer,VoidNamespace,Map<Integer,String>> in method public testMapState() : void in class org.apache.flink.runtime.state.StateBackendTestBase |
From |
To |
|
Change Variable Type state : InternalListState<Integer,Long> to state : InternalListState<String,Integer,Long> in method public testRestore1_2ToMaster() : void in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackendSnapshotMigrationTest |
From |
To |
|
Change Variable Type restoredKvState2 : InternalKvState<VoidNamespace> to restoredKvState2 : InternalKvState<Integer,VoidNamespace,String> in method public testValueState() : void in class org.apache.flink.runtime.state.StateBackendTestBase |
From |
To |
|
Change Variable Type kvState : InternalKvState<VoidNamespace> to kvState : InternalKvState<Integer,VoidNamespace,String> in method public testFoldingState() : void in class org.apache.flink.runtime.state.StateBackendTestBase |
From |
To |
|
Change Variable Type restoredKvState1 : InternalKvState<VoidNamespace> to restoredKvState1 : InternalKvState<Integer,VoidNamespace,String> in method public testFoldingState() : void in class org.apache.flink.runtime.state.StateBackendTestBase |
From |
To |
|
Change Variable Type state : InternalAggregatingState<Integer,Long,Long> to state : InternalAggregatingState<String,Integer,Long,Long,Long> in method public testAggregatingStateMergingWithImmutableAccumulator() : void in class org.apache.flink.runtime.state.StateBackendTestBase |
From |
To |
|
Change Variable Type kvState : InternalKvState<VoidNamespace> to kvState : InternalKvState<Integer,VoidNamespace,Integer> in method protected testConcurrentMapIfQueryable() : void in class org.apache.flink.runtime.state.StateBackendTestBase |
From |
To |
|
Change Variable Type kvState : InternalKvState<VoidNamespace> to kvState : InternalKvState<Integer,VoidNamespace,String> in method public testListState() : void in class org.apache.flink.runtime.state.StateBackendTestBase |
From |
To |
|
Change Variable Type kvState : InternalKvState<VoidNamespace> to kvState : InternalKvState<Integer,VoidNamespace,String> in method public testValueState() : void in class org.apache.flink.runtime.state.StateBackendTestBase |
From |
To |
|
Change Variable Type mergingState : InternalMergingState<W,?,?> to mergingState : InternalMergingState<K,W,?,?,?> in method public mergePartitionedState(stateDescriptor StateDescriptor<S,?>) : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperator.Context |
From |
To |
|
Change Variable Type serializer : TypeSerializer to safeValueSerializer : TypeSerializer<SV> in method public getSerializedValue(serializedKeyAndNamespace byte[], safeKeySerializer TypeSerializer<K>, safeNamespaceSerializer TypeSerializer<N>, safeValueSerializer TypeSerializer<SV>) : byte[] in class org.apache.flink.runtime.state.heap.AbstractHeapState |
From |
To |
|
Change Variable Type restoredKvState2 : InternalKvState<VoidNamespace> to restoredKvState2 : InternalKvState<Integer,VoidNamespace,Map<Integer,String>> in method public testMapState() : void in class org.apache.flink.runtime.state.StateBackendTestBase |
From |
To |
|
Change Variable Type mapState : InternalMapState<VoidNamespace,Long,String> to mapState : InternalMapState<Long,VoidNamespace,Long,String,Map<Long,String>> in method public testMapSerialization() : void in class org.apache.flink.queryablestate.network.KVStateRequestSerializerRocksDBTest |
From |
To |
|
Change Variable Type kvState : InternalKvState<VoidNamespace> to kvState : InternalKvState<Integer,VoidNamespace,String> in method public testReducingState() : void in class org.apache.flink.runtime.state.StateBackendTestBase |
From |
To |
|
Change Variable Type restoredKvState1 : InternalKvState<VoidNamespace> to restoredKvState1 : InternalKvState<Integer,VoidNamespace,String> in method public testValueState() : void in class org.apache.flink.runtime.state.StateBackendTestBase |
From |
To |
|
Change Variable Type existing : InternalKvState<?> to existing : InternalKvState<K,?,?> in method public getOrCreateKeyedState(namespaceSerializer TypeSerializer<N>, stateDescriptor StateDescriptor<S,V>) : S in class org.apache.flink.runtime.state.AbstractKeyedStateBackend |
From |
To |
|
Change Variable Type valueState : InternalValueState<VoidNamespace,Integer> to valueState : InternalValueState<Integer,VoidNamespace,Integer> in method public testParallelAsyncSnapshots() : void in class org.apache.flink.runtime.state.StateBackendTestBase |
From |
To |
|
Change Variable Type restoredKvState2 : InternalKvState<VoidNamespace> to restoredKvState2 : InternalKvState<Integer,VoidNamespace,String> in method public testListState() : void in class org.apache.flink.runtime.state.StateBackendTestBase |
From |
To |
|
Change Variable Type listState : InternalListState<VoidNamespace,Long> to listState : InternalListState<Long,VoidNamespace,Long> in method public testListSerialization() : void in class org.apache.flink.queryablestate.network.KvStateRequestSerializerTest |
From |
To |
|
Change Variable Type restoredKvState1 : InternalKvState<VoidNamespace> to restoredKvState1 : InternalKvState<Integer,VoidNamespace,String> in method public testReducingState() : void in class org.apache.flink.runtime.state.StateBackendTestBase |
From |
To |
|
Change Variable Type state : InternalReducingState<Integer,Long> to state : InternalReducingState<String,Integer,Long> in method public testReducingStateMerging() : void in class org.apache.flink.runtime.state.StateBackendTestBase |
From |
To |
|
Change Variable Type valueState : InternalValueState<VoidNamespace,Integer> to valueState : InternalValueState<Integer,VoidNamespace,Integer> in method public testAsyncSnapshotCancellation() : void in class org.apache.flink.runtime.state.StateBackendTestBase |
From |
To |
|
Change Variable Type kvState : InternalKvState<N> to kvState : InternalKvState<K,N,?> in method public getOrCreateKeyedState(namespaceSerializer TypeSerializer<N>, stateDescriptor StateDescriptor<S,V>) : S in class org.apache.flink.runtime.state.AbstractKeyedStateBackend |
From |
To |
|
Change Variable Type state : InternalAggregatingState<Integer,Long,Long> to state : InternalAggregatingState<String,Integer,Long,Long,Long> in method public testAggregatingStateMergingWithMutableAccumulator() : void in class org.apache.flink.runtime.state.StateBackendTestBase |
From |
To |
|
Change Variable Type kvState : InternalKvState<?> to kvState : InternalKvState<Integer,?,Integer> in method public testClientServerIntegration() : void in class org.apache.flink.queryablestate.network.ClientTest |
From |
To |
|
Change Variable Type previous : InternalKvState<?> to previous : InternalKvState<K,?,?> in method public getPartitionedState(namespace N, namespaceSerializer TypeSerializer<N>, stateDescriptor StateDescriptor<S,?>) : S in class org.apache.flink.runtime.state.AbstractKeyedStateBackend |
From |
To |
|
Change Variable Type mapState : InternalMapState<VoidNamespace,Long,String> to mapState : InternalMapState<Long,VoidNamespace,Long,String,HashMap<Long,String>> in method public testMapSerialization() : void in class org.apache.flink.queryablestate.network.KvStateRequestSerializerTest |
From |
To |
|
Change Variable Type restoredKvState2 : InternalKvState<VoidNamespace> to restoredKvState2 : InternalKvState<Integer,VoidNamespace,String> in method public testReducingState() : void in class org.apache.flink.runtime.state.StateBackendTestBase |
From |
To |
|
Change Variable Type state : InternalListState<Integer,Long> to state : InternalListState<String,Integer,Long> in method public testListStateMerging() : void in class org.apache.flink.runtime.state.StateBackendTestBase |
From |
To |
|
Change Variable Type restoredKvState1 : InternalKvState<VoidNamespace> to restoredKvState1 : InternalKvState<Integer,VoidNamespace,String> in method public testListState() : void in class org.apache.flink.runtime.state.StateBackendTestBase |
From |
To |
|
Change Variable Type state : InternalValueState<VoidNamespace,String> to state : InternalValueState<String,VoidNamespace,String> in method private snapshotRestoreRoundtrip(useCompression boolean) : void in class org.apache.flink.runtime.state.StateSnapshotCompressionTest |
From |
To |
|
Change Variable Type kvState : InternalKvState<VoidNamespace> to kvState : InternalKvState<Integer,VoidNamespace,Map<Integer,String>> in method public testMapState() : void in class org.apache.flink.runtime.state.StateBackendTestBase |
From |
To |
|
Change Variable Type listState : InternalListState<VoidNamespace,Long> to listState : InternalListState<Long,VoidNamespace,Long> in method public testListSerialization() : void in class org.apache.flink.queryablestate.network.KVStateRequestSerializerRocksDBTest |
From |
To |
|
Change Variable Type kvState : InternalKvState<Integer> to kvState : InternalKvState<Integer,Integer,String> in method public testValueStateRace() : void in class org.apache.flink.runtime.state.StateBackendTestBase |
From |
To |
|
Change Variable Type mergingState : InternalMergingState<W,?,?> to mergingState : InternalMergingState<K,W,?,?,?> in method public mergePartitionedState(stateDescriptor StateDescriptor<S,?>) : void in class org.apache.flink.streaming.runtime.operators.windowing.TriggerTestHarness.TestOnMergeContext |
From |
To |