|
Push Down Attribute protected numberOfKeyGroups : int from class org.apache.flink.runtime.state.KeyedStateBackend to protected numberOfKeyGroups : int from class org.apache.flink.runtime.state.AbstractKeyedStateBackend |
From |
To |
|
Push Down Attribute protected keyGroupRange : KeyGroupRange from class org.apache.flink.runtime.state.KeyedStateBackend to protected keyGroupRange : KeyGroupRange from class org.apache.flink.runtime.state.AbstractKeyedStateBackend |
From |
To |
|
Push Down Attribute private currentKeyGroup : int from class org.apache.flink.runtime.state.KeyedStateBackend to private currentKeyGroup : int from class org.apache.flink.runtime.state.AbstractKeyedStateBackend |
From |
To |
|
Push Down Attribute private lastName : String from class org.apache.flink.runtime.state.KeyedStateBackend to private lastName : String from class org.apache.flink.runtime.state.AbstractKeyedStateBackend |
From |
To |
|
Push Down Attribute protected keyValueStatesByName : HashMap<String,KvState<?>> from class org.apache.flink.runtime.state.KeyedStateBackend to protected keyValueStatesByName : HashMap<String,KvState<?>> from class org.apache.flink.runtime.state.AbstractKeyedStateBackend |
From |
To |
|
Push Down Attribute protected keySerializer : TypeSerializer<K> from class org.apache.flink.runtime.state.KeyedStateBackend to protected keySerializer : TypeSerializer<K> from class org.apache.flink.runtime.state.AbstractKeyedStateBackend |
From |
To |
|
Push Down Attribute private lastState : KvState from class org.apache.flink.runtime.state.KeyedStateBackend to private lastState : KvState from class org.apache.flink.runtime.state.AbstractKeyedStateBackend |
From |
To |
|
Push Down Attribute protected kvStateRegistry : TaskKvStateRegistry from class org.apache.flink.runtime.state.KeyedStateBackend to protected kvStateRegistry : TaskKvStateRegistry from class org.apache.flink.runtime.state.AbstractKeyedStateBackend |
From |
To |
|
Push Down Attribute protected userCodeClassLoader : ClassLoader from class org.apache.flink.runtime.state.KeyedStateBackend to protected userCodeClassLoader : ClassLoader from class org.apache.flink.runtime.state.AbstractKeyedStateBackend |
From |
To |
|
Push Down Attribute protected currentKey : K from class org.apache.flink.runtime.state.KeyedStateBackend to protected currentKey : K from class org.apache.flink.runtime.state.AbstractKeyedStateBackend |
From |
To |
|
Change Variable Type backend : KeyedStateBackend<Integer> to backend : AbstractKeyedStateBackend<Integer> in method public testValueStateNullUpdate() : void in class org.apache.flink.runtime.state.StateBackendTestBase |
From |
To |
|
Change Variable Type backend : KeyedStateBackend<Integer> to backend : AbstractKeyedStateBackend<Integer> in method public testClientServerIntegration() : void in class org.apache.flink.runtime.query.netty.KvStateClientTest |
From |
To |
|
Change Variable Type backend : KeyedStateBackend<Integer> to backend : AbstractKeyedStateBackend<Integer> in method public testQueryableStateRegistration() : void in class org.apache.flink.runtime.state.StateBackendTestBase |
From |
To |
|
Change Variable Type backend : KeyedStateBackend<Integer> to backend : AbstractKeyedStateBackend<Integer> in method public testListStateRestoreWithWrongSerializers() : void in class org.apache.flink.runtime.state.StateBackendTestBase |
From |
To |
|
Change Variable Type operatorChain : OperatorChain<Integer> to operatorChain : OperatorChain<Integer,StreamMap<Integer,Integer>> in method private testMultiChaining(env StreamExecutionEnvironment) : void in class org.apache.flink.streaming.runtime.operators.StreamOperatorChainingTest |
From |
To |
|
Change Variable Type typedBackend : KeyedStateBackend<K> to typedBackend : AbstractKeyedStateBackend<K> in method public createKeyedStateBackend(keySerializer TypeSerializer<K>, numberOfKeyGroups int, keyGroupRange KeyGroupRange) : AbstractKeyedStateBackend<K> in class org.apache.flink.streaming.runtime.tasks.StreamTask |
From |
To |
|
Change Variable Type backend : KeyedStateBackend<Integer> to backend : AbstractKeyedStateBackend<Integer> in method public testCopyDefaultValue() : void in class org.apache.flink.runtime.state.StateBackendTestBase |
From |
To |
|
Change Variable Type backend : KeyedStateBackend<Integer> to backend : AbstractKeyedStateBackend<Integer> in method public testChunkedResponse() : void in class org.apache.flink.runtime.query.netty.KvStateServerHandlerTest |
From |
To |
|
Change Variable Type operatorChain : OperatorChain<Integer> to operatorChain : OperatorChain<Integer,StreamMap<Integer,Integer>> in method private testMultiChainingWithSplit(env StreamExecutionEnvironment) : void in class org.apache.flink.streaming.runtime.operators.StreamOperatorChainingTest |
From |
To |
|
Change Variable Type backend : KeyedStateBackend<Integer> to backend : AbstractKeyedStateBackend<Integer> in method public testValueStateRestoreWithWrongSerializers() : void in class org.apache.flink.runtime.state.StateBackendTestBase |
From |
To |
|
Change Variable Type backend : KeyedStateBackend<Integer> to backend : AbstractKeyedStateBackend<Integer> in method public testKeyGroupSnapshotRestore() : void in class org.apache.flink.runtime.state.StateBackendTestBase |
From |
To |
|
Change Variable Type firstHalfBackend : KeyedStateBackend<Integer> to firstHalfBackend : AbstractKeyedStateBackend<Integer> in method public testKeyGroupSnapshotRestore() : void in class org.apache.flink.runtime.state.StateBackendTestBase |
From |
To |
|
Change Variable Type backend : KeyedStateBackend<Integer> to backend : AbstractKeyedStateBackend<Integer> in method public testEmptyStateCheckpointing() : void in class org.apache.flink.runtime.state.StateBackendTestBase |
From |
To |
|
Change Variable Type rawBackend : KeyedStateBackend to rawBackend : AbstractKeyedStateBackend in method public setKeyContext(key Object) : void in class org.apache.flink.streaming.api.operators.AbstractStreamOperator |
From |
To |
|
Change Variable Type keyGroup : int to list : List<? extends Serializable> in method public serializeTogetherAndTrackOffsets(serializables List<List<? extends Serializable>>) : Tuple2<byte[],List<long[]>> in class org.apache.flink.runtime.checkpoint.CheckpointCoordinatorTest |
From |
To |
|
Change Variable Type backend : KeyedStateBackend<Integer> to backend : AbstractKeyedStateBackend<Integer> in method public testReducingStateRestoreWithWrongSerializers() : void in class org.apache.flink.runtime.state.StateBackendTestBase |
From |
To |
|
Change Variable Type backend : KeyedStateBackend<Integer> to backend : AbstractKeyedStateBackend<Integer> in method public answer(invocationOnMock InvocationOnMock) : ListState<String> in class org.apache.flink.streaming.api.operators.StreamingRuntimeContextTest.createPlainMockOp.thenAnswer |
From |
To |
|
Change Variable Type backend : KeyedStateBackend<Integer> to backend : AbstractKeyedStateBackend<Integer> in method public testSerializerMismatch() : void in class org.apache.flink.runtime.query.netty.KvStateServerHandlerTest |
From |
To |
|
Change Variable Type backend : KeyedStateBackend<Integer> to backend : AbstractKeyedStateBackend<Integer> in method public testSimpleRequest() : void in class org.apache.flink.runtime.query.netty.KvStateServerTest |
From |
To |
|
Change Variable Type columnFamily : Tuple2<ColumnFamilyHandle,StateDescriptor> to columnFamily : Tuple2<ColumnFamilyHandle,StateDescriptor<?,?>> in method private restoreKVStateMetaData() : void in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBRestoreOperation |
From |
To |
|
Change Variable Type backend : KeyedStateBackend<Integer> to backend : AbstractKeyedStateBackend<Integer> in method public testFoldingState() : void in class org.apache.flink.runtime.state.StateBackendTestBase |
From |
To |
|
Change Variable Type backend : KeyedStateBackend<Integer> to backend : AbstractKeyedStateBackend<Integer> in method public testRequireNonNullNamespace() : void in class org.apache.flink.runtime.state.StateBackendTestBase |
From |
To |
|
Change Variable Type column : Tuple2<ColumnFamilyHandle,StateDescriptor> to column : Tuple2<ColumnFamilyHandle,StateDescriptor<?,?>> in method public dispose() : void in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend |
From |
To |
|
Change Variable Type backend : KeyedStateBackend<Integer> to backend : AbstractKeyedStateBackend<Integer> in method public testListState() : void in class org.apache.flink.runtime.state.StateBackendTestBase |
From |
To |
|
Change Variable Type backend : KeyedStateBackend<Integer> to backend : AbstractKeyedStateBackend<Integer> in method public testMultipleValueStates() : void in class org.apache.flink.runtime.state.StateBackendTestBase |
From |
To |
|
Change Variable Type backend : KeyedStateBackend<Integer> to backend : AbstractKeyedStateBackend<Integer> in method public testReducingState() : void in class org.apache.flink.runtime.state.StateBackendTestBase |
From |
To |
|
Change Variable Type keyedStateBackend : KeyedStateBackend<Integer> to keyedStateBackend : AbstractKeyedStateBackend<Integer> in method public testIntegrationWithKvStateServer() : void in class org.apache.flink.runtime.query.QueryableStateClientTest |
From |
To |
|
Change Variable Type stateInfo : Tuple2<ColumnFamilyHandle,StateDescriptor> to stateInfo : Tuple2<ColumnFamilyHandle,StateDescriptor<?,?>> in method protected getColumnFamily(descriptor StateDescriptor<?,?>) : ColumnFamilyHandle in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend |
From |
To |
|
Change Variable Type stateDescriptor : StateDescriptor to stateDescriptor : StateDescriptor<?,?> in method private restoreKVStateMetaData() : void in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBRestoreOperation |
From |
To |
|
Change Variable Type backend : KeyedStateBackend<Integer> to backend : AbstractKeyedStateBackend<Integer> in method protected testConcurrentMapIfQueryable() : void in class org.apache.flink.runtime.state.StateBackendTestBase |
From |
To |
|
Change Variable Type column : Map.Entry<String,Tuple2<ColumnFamilyHandle,StateDescriptor>> to column : Map.Entry<String,Tuple2<ColumnFamilyHandle,StateDescriptor<?,?>>> in method private writeKVStateMetaData() : void in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBSnapshotOperation |
From |
To |
|
Change Variable Type backend : KeyedStateBackend<Integer> to backend : AbstractKeyedStateBackend<Integer> in method public testValueState() : void in class org.apache.flink.runtime.state.StateBackendTestBase |
From |
To |
|
Change Variable Type backend : KeyedStateBackend<Integer> to backend : AbstractKeyedStateBackend<Integer> in method public testSimpleQuery() : void in class org.apache.flink.runtime.query.netty.KvStateServerHandlerTest |
From |
To |
|
Change Variable Type secondHalfBackend : KeyedStateBackend<Integer> to secondHalfBackend : AbstractKeyedStateBackend<Integer> in method public testKeyGroupSnapshotRestore() : void in class org.apache.flink.runtime.state.StateBackendTestBase |
From |
To |
|
Push Down Method public close() : void from class org.apache.flink.runtime.state.KeyedStateBackend to public close() : void from class org.apache.flink.runtime.state.AbstractKeyedStateBackend |
From |
To |
|
Push Down Method protected abstract createFoldingState(namespaceSerializer TypeSerializer<N>, stateDesc FoldingStateDescriptor<T,ACC>) : FoldingState<T,ACC> from class org.apache.flink.runtime.state.KeyedStateBackend to protected abstract createFoldingState(namespaceSerializer TypeSerializer<N>, stateDesc FoldingStateDescriptor<T,ACC>) : FoldingState<T,ACC> from class org.apache.flink.runtime.state.AbstractKeyedStateBackend |
From |
To |
|
Push Down Method public getCurrentKey() : K from class org.apache.flink.runtime.state.KeyedStateBackend to public getCurrentKey() : K from class org.apache.flink.runtime.state.AbstractKeyedStateBackend |
From |
To |
|
Push Down Method public KeyedStateBackend(kvStateRegistry TaskKvStateRegistry, keySerializer TypeSerializer<K>, userCodeClassLoader ClassLoader, numberOfKeyGroups int, keyGroupRange KeyGroupRange) from class org.apache.flink.runtime.state.KeyedStateBackend to public AbstractKeyedStateBackend(kvStateRegistry TaskKvStateRegistry, keySerializer TypeSerializer<K>, userCodeClassLoader ClassLoader, numberOfKeyGroups int, keyGroupRange KeyGroupRange) from class org.apache.flink.runtime.state.AbstractKeyedStateBackend |
From |
To |
|
Push Down Method protected abstract createReducingState(namespaceSerializer TypeSerializer<N>, stateDesc ReducingStateDescriptor<T>) : ReducingState<T> from class org.apache.flink.runtime.state.KeyedStateBackend to protected abstract createReducingState(namespaceSerializer TypeSerializer<N>, stateDesc ReducingStateDescriptor<T>) : ReducingState<T> from class org.apache.flink.runtime.state.AbstractKeyedStateBackend |
From |
To |
|
Push Down Method public getCurrentKeyGroupIndex() : int from class org.apache.flink.runtime.state.KeyedStateBackend to public getCurrentKeyGroupIndex() : int from class org.apache.flink.runtime.state.AbstractKeyedStateBackend |
From |
To |
|
Push Down Method protected abstract createListState(namespaceSerializer TypeSerializer<N>, stateDesc ListStateDescriptor<T>) : ListState<T> from class org.apache.flink.runtime.state.KeyedStateBackend to protected abstract createListState(namespaceSerializer TypeSerializer<N>, stateDesc ListStateDescriptor<T>) : ListState<T> from class org.apache.flink.runtime.state.AbstractKeyedStateBackend |
From |
To |
|
Push Down Method public getPartitionedState(namespace N, namespaceSerializer TypeSerializer<N>, stateDescriptor StateDescriptor<S,?>) : S from class org.apache.flink.runtime.state.KeyedStateBackend to public getPartitionedState(namespace N, namespaceSerializer TypeSerializer<N>, stateDescriptor StateDescriptor<S,?>) : S from class org.apache.flink.runtime.state.AbstractKeyedStateBackend |
From |
To |
|
Push Down Method public mergePartitionedStates(target N, sources Collection<N>, namespaceSerializer TypeSerializer<N>, stateDescriptor StateDescriptor<S,?>) : void from class org.apache.flink.runtime.state.KeyedStateBackend to public mergePartitionedStates(target N, sources Collection<N>, namespaceSerializer TypeSerializer<N>, stateDescriptor StateDescriptor<S,?>) : void from class org.apache.flink.runtime.state.AbstractKeyedStateBackend |
From |
To |
|
Push Down Method protected abstract createValueState(namespaceSerializer TypeSerializer<N>, stateDesc ValueStateDescriptor<T>) : ValueState<T> from class org.apache.flink.runtime.state.KeyedStateBackend to protected abstract createValueState(namespaceSerializer TypeSerializer<N>, stateDesc ValueStateDescriptor<T>) : ValueState<T> from class org.apache.flink.runtime.state.AbstractKeyedStateBackend |
From |
To |
|
Push Down Method public getNumberOfKeyGroups() : int from class org.apache.flink.runtime.state.KeyedStateBackend to public getNumberOfKeyGroups() : int from class org.apache.flink.runtime.state.AbstractKeyedStateBackend |
From |
To |
|
Push Down Method public getKeyGroupRange() : KeyGroupRange from class org.apache.flink.runtime.state.KeyedStateBackend to public getKeyGroupRange() : KeyGroupRange from class org.apache.flink.runtime.state.AbstractKeyedStateBackend |
From |
To |
|
Push Down Method public setCurrentKey(newKey K) : void from class org.apache.flink.runtime.state.KeyedStateBackend to public setCurrentKey(newKey K) : void from class org.apache.flink.runtime.state.AbstractKeyedStateBackend |
From |
To |
|
Push Down Method public getKeySerializer() : TypeSerializer<K> from class org.apache.flink.runtime.state.KeyedStateBackend to public getKeySerializer() : TypeSerializer<K> from class org.apache.flink.runtime.state.AbstractKeyedStateBackend |
From |
To |
|
Change Return Type Long to List<Long> in method public snapshotState(checkpointId long, timestamp long) : List<Long> in class org.apache.flink.test.checkpointing.UdfStreamOperatorCheckpointingITCase.OnceFailingIdentityMapFunction |
From |
To |
|
Change Return Type KeyedStateBackend<K> to AbstractKeyedStateBackend<K> in method protected createKeyedBackend(keySerializer TypeSerializer<K>, env Environment) : AbstractKeyedStateBackend<K> in class org.apache.flink.runtime.state.StateBackendTestBase |
From |
To |
|
Change Return Type KeyedStateBackend<K> to AbstractKeyedStateBackend<K> in method public restoreKeyedStateBackend(env Environment, jobID JobID, operatorIdentifier String, keySerializer TypeSerializer<K>, numberOfKeyGroups int, keyGroupRange KeyGroupRange, restoredState List<KeyGroupsStateHandle>, kvStateRegistry TaskKvStateRegistry) : AbstractKeyedStateBackend<K> in class org.apache.flink.test.streaming.runtime.StateBackendITCase.FailingStateBackend |
From |
To |
|
Change Return Type KeyedStateBackend<K> to AbstractKeyedStateBackend<K> in method protected restoreKeyedBackend(keySerializer TypeSerializer<K>, state KeyGroupsStateHandle) : AbstractKeyedStateBackend<K> in class org.apache.flink.runtime.state.StateBackendTestBase |
From |
To |
|
Change Return Type KeyedStateBackend<K> to AbstractKeyedStateBackend<K> in method public createKeyedStateBackend(env Environment, jobID JobID, operatorIdentifier String, keySerializer TypeSerializer<K>, numberOfKeyGroups int, keyGroupRange KeyGroupRange, kvStateRegistry TaskKvStateRegistry) : AbstractKeyedStateBackend<K> in class org.apache.flink.runtime.state.memory.MemoryStateBackend |
From |
To |
|
Change Return Type KeyedStateBackend<K> to AbstractKeyedStateBackend<K> in method public abstract createKeyedStateBackend(env Environment, jobID JobID, operatorIdentifier String, keySerializer TypeSerializer<K>, numberOfKeyGroups int, keyGroupRange KeyGroupRange, kvStateRegistry TaskKvStateRegistry) : AbstractKeyedStateBackend<K> in class org.apache.flink.runtime.state.AbstractStateBackend |
From |
To |
|
Change Return Type KeyedStateBackend<K> to AbstractKeyedStateBackend<K> in method public createKeyedStateBackend(env Environment, jobID JobID, operatorIdentifier String, keySerializer TypeSerializer<K>, numberOfKeyGroups int, keyGroupRange KeyGroupRange, kvStateRegistry TaskKvStateRegistry) : AbstractKeyedStateBackend<K> in class org.apache.flink.contrib.streaming.state.RocksDBStateBackend |
From |
To |
|
Change Return Type KeyedStateBackend<K> to AbstractKeyedStateBackend<K> in method public restoreKeyedStateBackend(env Environment, jobID JobID, operatorIdentifier String, keySerializer TypeSerializer<K>, numberOfKeyGroups int, keyGroupRange KeyGroupRange, restoredState List<KeyGroupsStateHandle>, kvStateRegistry TaskKvStateRegistry) : AbstractKeyedStateBackend<K> in class org.apache.flink.runtime.state.memory.MemoryStateBackend |
From |
To |
|
Change Return Type KeyedStateBackend<K> to AbstractKeyedStateBackend<K> in method protected restoreKeyedBackend(keySerializer TypeSerializer<K>, numberOfKeyGroups int, keyGroupRange KeyGroupRange, state List<KeyGroupsStateHandle>, env Environment) : AbstractKeyedStateBackend<K> in class org.apache.flink.runtime.state.StateBackendTestBase |
From |
To |
|
Change Return Type ChainedStateHandle<StreamStateHandle> to CheckpointStateHandles in method public getCheckpointStateHandles() : CheckpointStateHandles in class org.apache.flink.runtime.messages.checkpoint.AcknowledgeCheckpoint |
From |
To |
|
Change Return Type KeyedStateBackend<K> to AbstractKeyedStateBackend<K> in method protected createKeyedBackend(keySerializer TypeSerializer<K>, numberOfKeyGroups int, keyGroupRange KeyGroupRange, env Environment) : AbstractKeyedStateBackend<K> in class org.apache.flink.runtime.state.StateBackendTestBase |
From |
To |
|
Change Return Type Serializable to void in method public prepareSnapshot(checkpointId long, timestamp long) : void in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerBase |
From |
To |
|
Change Return Type KeyedStateBackend<K> to AbstractKeyedStateBackend<K> in method protected createKeyedBackend(keySerializer TypeSerializer<K>) : AbstractKeyedStateBackend<K> in class org.apache.flink.runtime.state.StateBackendTestBase |
From |
To |
|
Change Return Type KeyedStateBackend<K> to AbstractKeyedStateBackend<K> in method public abstract restoreKeyedStateBackend(env Environment, jobID JobID, operatorIdentifier String, keySerializer TypeSerializer<K>, numberOfKeyGroups int, keyGroupRange KeyGroupRange, restoredState List<KeyGroupsStateHandle>, kvStateRegistry TaskKvStateRegistry) : AbstractKeyedStateBackend<K> in class org.apache.flink.runtime.state.AbstractStateBackend |
From |
To |
|
Change Return Type KeyedStateBackend<K> to AbstractKeyedStateBackend<K> in method protected restoreKeyedBackend(keySerializer TypeSerializer<K>, state KeyGroupsStateHandle, env Environment) : AbstractKeyedStateBackend<K> in class org.apache.flink.runtime.state.StateBackendTestBase |
From |
To |
|
Change Return Type KeyedStateBackend<K> to AbstractKeyedStateBackend<K> in method public restoreKeyedStateBackend(env Environment, jobID JobID, operatorIdentifier String, keySerializer TypeSerializer<K>, numberOfKeyGroups int, keyGroupRange KeyGroupRange, restoredState List<KeyGroupsStateHandle>, kvStateRegistry TaskKvStateRegistry) : AbstractKeyedStateBackend<K> in class org.apache.flink.contrib.streaming.state.RocksDBStateBackend |
From |
To |
|
Change Return Type KeyedStateBackend<K> to AbstractKeyedStateBackend<K> in method public createKeyedStateBackend(env Environment, jobID JobID, operatorIdentifier String, keySerializer TypeSerializer<K>, numberOfKeyGroups int, keyGroupRange KeyGroupRange, kvStateRegistry TaskKvStateRegistry) : AbstractKeyedStateBackend<K> in class org.apache.flink.test.streaming.runtime.StateBackendITCase.FailingStateBackend |
From |
To |
|
Change Return Type Serializable to void in method public prepareSnapshot(checkpointId long, timestamp long) : void in class org.apache.flink.streaming.connectors.kafka.AtLeastOnceProducerTest.TestingKafkaProducer |
From |
To |
|
Change Return Type KeyedStateBackend<K> to AbstractKeyedStateBackend<K> in method public createKeyedStateBackend(env Environment, jobID JobID, operatorIdentifier String, keySerializer TypeSerializer<K>, numberOfKeyGroups int, keyGroupRange KeyGroupRange, kvStateRegistry TaskKvStateRegistry) : AbstractKeyedStateBackend<K> in class org.apache.flink.runtime.state.filesystem.FsStateBackend |
From |
To |
|
Change Return Type KeyedStateBackend<K> to AbstractKeyedStateBackend<K> in method public restoreKeyedStateBackend(env Environment, jobID JobID, operatorIdentifier String, keySerializer TypeSerializer<K>, numberOfKeyGroups int, keyGroupRange KeyGroupRange, restoredState List<KeyGroupsStateHandle>, kvStateRegistry TaskKvStateRegistry) : AbstractKeyedStateBackend<K> in class org.apache.flink.runtime.state.filesystem.FsStateBackend |
From |
To |
|
Change Return Type KeyedStateBackend<K> to AbstractKeyedStateBackend<K> in method public createKeyedStateBackend(keySerializer TypeSerializer<K>, numberOfKeyGroups int, keyGroupRange KeyGroupRange) : AbstractKeyedStateBackend<K> in class org.apache.flink.streaming.runtime.tasks.StreamTask |
From |
To |
|
Change Attribute Type kvStateInformation : Map<String,Tuple2<ColumnFamilyHandle,StateDescriptor>> to kvStateInformation : Map<String,Tuple2<ColumnFamilyHandle,StateDescriptor<?,?>>> in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend |
From |
To |
|
Change Attribute Type cancelables : Set<Closeable> to cancelables : ClosableRegistry in class org.apache.flink.streaming.runtime.tasks.StreamTask.AsyncCheckpointRunnable |
From |
To |
|
Change Attribute Type keyedStateBackend : KeyedStateBackend<?> to keyedStateBackend : AbstractKeyedStateBackend<?> in class org.apache.flink.streaming.util.KeyedOneInputStreamOperatorTestHarness |
From |
To |
|
Change Attribute Type keyedStateBackend : KeyedStateBackend<?> to keyedStateBackend : AbstractKeyedStateBackend<?> in class org.apache.flink.streaming.api.operators.AbstractStreamOperator |
From |
To |
|
Change Attribute Type cancelables : Set<Closeable> to cancelables : ClosableRegistry in class org.apache.flink.streaming.runtime.tasks.StreamTask |
From |
To |
|
Change Attribute Type headOperator : Operator to headOperator : OP in class org.apache.flink.streaming.runtime.tasks.StreamTask |
From |
To |
|
Change Attribute Type keyedStateBackend : KeyedStateBackend<?> to keyedStateBackend : AbstractKeyedStateBackend<?> in class org.apache.flink.streaming.runtime.tasks.StreamTask |
From |
To |
|
Change Attribute Type operatorChain : OperatorChain<OUT> to operatorChain : OperatorChain<OUT,OP> in class org.apache.flink.streaming.runtime.tasks.StreamTask |
From |
To |
|
Change Attribute Type keyGroupsStateHandle : List<KeyGroupsStateHandle> to checkpointStateHandles : CheckpointStateHandles in class org.apache.flink.runtime.messages.checkpoint.AcknowledgeCheckpoint |
From |
To |