|
Change Parameter Type kvState : KvState<N> to kvState : InternalKvState<N> in method private getSerializedList(kvState InternalKvState<N>, 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 Parameter Type kvState : KvState<?> 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 : KvState<?> to kvState : InternalKvState<?> in method public AsyncKvStateQueryTask(ctx ChannelHandlerContext, request KvStateRequest, kvState InternalKvState<?>, stats KvStateRequestStats) in class org.apache.flink.runtime.query.netty.KvStateServerHandler.AsyncKvStateQueryTask |
From |
To |
|
Change Parameter Type kvState : KvState<N> to kvState : InternalKvState<N> in method private getSerializedValue(kvState InternalKvState<N>, 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 : KvState<?> 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 Return Type FoldingState<T,ACC> to InternalFoldingState<N,T,ACC> in method protected createFoldingState(namespaceSerializer TypeSerializer<N>, stateDesc FoldingStateDescriptor<T,ACC>) : InternalFoldingState<N,T,ACC> in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend |
From |
To |
|
Change Return Type ListState<T> to InternalListState<N,T> in method public createListState(namespaceSerializer TypeSerializer<N>, stateDesc ListStateDescriptor<T>) : InternalListState<N,T> in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend |
From |
To |
|
Change Return Type ReducingState<T> to InternalReducingState<N,T> in method public createReducingState(namespaceSerializer TypeSerializer<N>, stateDesc ReducingStateDescriptor<T>) : InternalReducingState<N,T> in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend |
From |
To |
|
Change Return Type ValueState<T> to InternalValueState<N,T> in method protected abstract createValueState(namespaceSerializer TypeSerializer<N>, stateDesc ValueStateDescriptor<T>) : InternalValueState<N,T> in class org.apache.flink.runtime.state.AbstractKeyedStateBackend |
From |
To |
|
Change Return Type ReducingState<T> to InternalReducingState<N,T> in method protected abstract createReducingState(namespaceSerializer TypeSerializer<N>, stateDesc ReducingStateDescriptor<T>) : InternalReducingState<N,T> in class org.apache.flink.runtime.state.AbstractKeyedStateBackend |
From |
To |
|
Change Return Type ValueState<T> to InternalValueState<N,T> in method protected createValueState(namespaceSerializer TypeSerializer<N>, stateDesc ValueStateDescriptor<T>) : InternalValueState<N,T> in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend |
From |
To |
|
Change Return Type ListState<T> to InternalListState<N,T> in method protected abstract createListState(namespaceSerializer TypeSerializer<N>, stateDesc ListStateDescriptor<T>) : InternalListState<N,T> in class org.apache.flink.runtime.state.AbstractKeyedStateBackend |
From |
To |
|
Change Return Type KvState<?> to InternalKvState<?> in method public getKvState(kvStateId KvStateID) : InternalKvState<?> in class org.apache.flink.runtime.query.KvStateRegistry |
From |
To |
|
Change Return Type FoldingState<T,ACC> to InternalFoldingState<N,T,ACC> in method protected abstract createFoldingState(namespaceSerializer TypeSerializer<N>, stateDesc FoldingStateDescriptor<T,ACC>) : InternalFoldingState<N,T,ACC> in class org.apache.flink.runtime.state.AbstractKeyedStateBackend |
From |
To |
|
Change Return Type FoldingState<T,ACC> to InternalFoldingState<N,T,ACC> in method protected createFoldingState(namespaceSerializer TypeSerializer<N>, stateDesc FoldingStateDescriptor<T,ACC>) : InternalFoldingState<N,T,ACC> in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend |
From |
To |
|
Change Return Type ListState<T> to InternalListState<N,T> in method protected createListState(namespaceSerializer TypeSerializer<N>, stateDesc ListStateDescriptor<T>) : InternalListState<N,T> in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend |
From |
To |
|
Change Return Type ValueState<V> to InternalValueState<N,V> in method public createValueState(namespaceSerializer TypeSerializer<N>, stateDesc ValueStateDescriptor<V>) : InternalValueState<N,V> in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend |
From |
To |
|
Change Return Type ReducingState<T> to InternalReducingState<N,T> in method protected createReducingState(namespaceSerializer TypeSerializer<N>, stateDesc ReducingStateDescriptor<T>) : InternalReducingState<N,T> in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend |
From |
To |
|
Change Return Type ListState<T> to InternalListState<N,T> in method public createListState(namespaceSerializer TypeSerializer<N>, stateDesc ListStateDescriptor<T>) : InternalListState<N,T> in class org.apache.flink.test.query.KVStateRequestSerializerRocksDBTest.RocksDBKeyedStateBackend2 |
From |
To |
|
Change Variable Type restoredKvState2 : KvState<VoidNamespace> to restoredKvState2 : InternalKvState<VoidNamespace> in method public testReducingState() : void in class org.apache.flink.runtime.state.StateBackendTestBase |
From |
To |
|
Change Variable Type restoredKvState2 : KvState<VoidNamespace> to restoredKvState2 : InternalKvState<VoidNamespace> in method public testFoldingState() : void in class org.apache.flink.runtime.state.StateBackendTestBase |
From |
To |
|
Change Variable Type listState : ListState<Long> to listState : InternalListState<VoidNamespace,Long> in method public testListSerialization() : void in class org.apache.flink.runtime.query.netty.message.KvStateRequestSerializerTest |
From |
To |
|
Change Variable Type kvState : KvState<?> to kvState : InternalKvState<?> in method public testClientServerIntegration() : void in class org.apache.flink.runtime.query.netty.KvStateClientTest |
From |
To |
|
Change Variable Type kvState : KvState<?> to kvState : InternalKvState<?> in method public channelRead(ctx ChannelHandlerContext, msg Object) : void in class org.apache.flink.runtime.query.netty.KvStateServerHandler |
From |
To |
|
Change Variable Type restoredKvState1 : KvState<VoidNamespace> to restoredKvState1 : InternalKvState<VoidNamespace> in method public testListState() : void in class org.apache.flink.runtime.state.StateBackendTestBase |
From |
To |
|
Change Variable Type windowState : ListState<StreamRecord<IN>> to evictingWindowState : InternalListState<W,StreamRecord<IN>> in method public processElement(element StreamRecord<IN>) : void in class org.apache.flink.streaming.runtime.operators.windowing.EvictingWindowOperator |
From |
To |
|
Change Variable Type kvState : KvState<VoidNamespace> to kvState : InternalKvState<VoidNamespace> in method public testReducingState() : void in class org.apache.flink.runtime.state.StateBackendTestBase |
From |
To |
|
Change Variable Type previous : KvState<?> to previous : InternalKvState<?> 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 restoredKvState2 : KvState<VoidNamespace> to restoredKvState2 : InternalKvState<VoidNamespace> in method public testListState() : void in class org.apache.flink.runtime.state.StateBackendTestBase |
From |
To |
|
Change Variable Type restoredKvState1 : KvState<VoidNamespace> to restoredKvState1 : InternalKvState<VoidNamespace> in method public testFoldingState() : void in class org.apache.flink.runtime.state.StateBackendTestBase |
From |
To |
|
Change Variable Type kvState : KvState<VoidNamespace> to kvState : InternalKvState<VoidNamespace> in method public testValueState() : void in class org.apache.flink.runtime.state.StateBackendTestBase |
From |
To |
|
Change Variable Type mergeState : ListState<Tuple2<W,W>> to mergingSetsState : InternalListState<VoidNamespace,Tuple2<W,W>> in method protected getMergingWindowSet() : MergingWindowSet<W> in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperator |
From |
To |
|
Change Variable Type kvState : KvState<?> to kvState : InternalKvState<?> in method public testFailureOnGetSerializedValue() : void in class org.apache.flink.runtime.query.netty.KvStateServerHandlerTest |
From |
To |
|
Change Variable Type kvState : KvState to kvState : InternalKvState<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 : KvState<VoidNamespace> to kvState : InternalKvState<VoidNamespace> in method protected testConcurrentMapIfQueryable() : void in class org.apache.flink.runtime.state.StateBackendTestBase |
From |
To |
|
Change Variable Type listState : ListState<Long> to listState : InternalListState<VoidNamespace,Long> in method public testListSerialization() : void in class org.apache.flink.test.query.KVStateRequestSerializerRocksDBTest |
From |
To |
|
Change Variable Type restoredKvState2 : KvState<VoidNamespace> to restoredKvState2 : InternalKvState<VoidNamespace> in method public testValueState() : void in class org.apache.flink.runtime.state.StateBackendTestBase |
From |
To |
|
Change Variable Type kvState : KvState<Integer> to kvState : InternalKvState<Integer> in method public testValueStateRace() : void in class org.apache.flink.runtime.state.StateBackendTestBase |
From |
To |
|
Change Variable Type restoredKvState1 : KvState<VoidNamespace> to restoredKvState1 : InternalKvState<VoidNamespace> in method public testValueState() : void in class org.apache.flink.runtime.state.StateBackendTestBase |
From |
To |
|
Change Variable Type restoredKvState1 : KvState<VoidNamespace> to restoredKvState1 : InternalKvState<VoidNamespace> in method public testReducingState() : void in class org.apache.flink.runtime.state.StateBackendTestBase |
From |
To |
|
Change Variable Type kvState : KvState<VoidNamespace> to kvState : InternalKvState<VoidNamespace> in method public testListState() : void in class org.apache.flink.runtime.state.StateBackendTestBase |
From |
To |
|
Change Variable Type kvState : KvState<VoidNamespace> to kvState : InternalKvState<VoidNamespace> in method public testFoldingState() : void in class org.apache.flink.runtime.state.StateBackendTestBase |
From |
To |