|
Change Parameter Type timerServices : Map<String,HeapInternalTimerService<K,N>> to timerServices : Map<String,HeapInternalTimerService<K,?>> in method public InternalTimerServiceSerializationProxy(timerServices Map<String,HeapInternalTimerService<K,?>>, keyGroupIdx int) in class org.apache.flink.streaming.api.operators.InternalTimerServiceSerializationProxy |
From |
To |
|
Change Parameter Type timerServicesMapToPopulate : Map<String,HeapInternalTimerService<K,N>> to timerServicesMapToPopulate : Map<String,HeapInternalTimerService<K,?>> in method public InternalTimerServiceSerializationProxy(timerServicesMapToPopulate Map<String,HeapInternalTimerService<K,?>>, userCodeClassLoader ClassLoader, totalKeyGroups int, localKeyGroupRange KeyGroupRange, keyContext KeyContext, processingTimeService ProcessingTimeService, keyGroupIdx int) in class org.apache.flink.streaming.api.operators.InternalTimerServiceSerializationProxy |
From |
To |
|
Change Parameter Type internalTimeServiceManager : InternalTimeServiceManager<?,?> to internalTimeServiceManager : InternalTimeServiceManager<?> in method package StreamOperatorStateContextImpl(restored boolean, operatorStateBackend OperatorStateBackend, keyedStateBackend AbstractKeyedStateBackend<?>, internalTimeServiceManager InternalTimeServiceManager<?>, rawOperatorStateInputs CloseableIterable<StatePartitionStreamProvider>, rawKeyedStateInputs CloseableIterable<KeyGroupStatePartitionStreamProvider>) in class org.apache.flink.streaming.api.operators.StreamTaskStateInitializerImpl.StreamOperatorStateContextImpl |
From |
To |
|
Change Variable Type keyedTimeServiceHandler : InternalTimeServiceManager<K,N> to keyedTimeServiceHandler : InternalTimeServiceManager<K> in method public getInternalTimerService(name String, namespaceSerializer TypeSerializer<N>, triggerable Triggerable<K,N>) : InternalTimerService<N> in class org.apache.flink.streaming.api.operators.AbstractStreamOperator |
From |
To |
|
Change Variable Type timeServiceManager : InternalTimeServiceManager<?,?> to timeServiceManager : InternalTimeServiceManager<?> in method public testNoRestore() : void in class org.apache.flink.streaming.api.operators.StreamTaskStateInitializerImplTest |
From |
To |
|
Change Variable Type timeServiceManager : InternalTimeServiceManager<?,?> to timeServiceManager : InternalTimeServiceManager<?> in method public createStreamTaskStateInitializer() : StreamTaskStateInitializer in class org.apache.flink.streaming.runtime.tasks.StreamTaskTest.StateBackendTestSource |
From |
To |
|
Change Variable Type timeServiceManager : InternalTimeServiceManager<?,K> to timeServiceManager : InternalTimeServiceManager<K> in method protected internalTimeServiceManager(keyedStatedBackend AbstractKeyedStateBackend<K>, keyContext KeyContext, rawKeyedStates Iterable<KeyGroupStatePartitionStreamProvider>) : InternalTimeServiceManager<K> in class org.apache.flink.streaming.api.operators.StreamTaskStateInitializerImpl |
From |
To |
|
Change Variable Type timerService : HeapInternalTimerService<K,N> to timerService : HeapInternalTimerService<K,?> in method protected read(in DataInputView, wasVersioned boolean) : void in class org.apache.flink.streaming.api.operators.InternalTimerServiceSerializationProxy |
From |
To |
|
Change Variable Type timeServiceManager : InternalTimeServiceManager<?,?> to timeServiceManager : InternalTimeServiceManager<?> in method public streamOperatorStateContext(operatorID OperatorID, operatorClassName String, keyContext KeyContext, keySerializer TypeSerializer<?>, streamTaskCloseableRegistry CloseableRegistry) : StreamOperatorStateContext in class org.apache.flink.streaming.api.operators.StreamTaskStateInitializerImpl |
From |
To |
|
Change Variable Type timerService : HeapInternalTimerService<K,N> to timerService : HeapInternalTimerService<K,?> in method public write(out DataOutputView) : void in class org.apache.flink.streaming.api.operators.InternalTimerServiceSerializationProxy |
From |
To |
|
Change Variable Type serializationProxy : InternalTimerServiceSerializationProxy<K,N> to serializationProxy : InternalTimerServiceSerializationProxy<K> in method public restoreStateForKeyGroup(stream InputStream, keyGroupIdx int, userCodeClassLoader ClassLoader) : void in class org.apache.flink.streaming.api.operators.InternalTimeServiceManager |
From |
To |
|
Change Variable Type entry : Map.Entry<String,HeapInternalTimerService<K,N>> to entry : Map.Entry<String,HeapInternalTimerService<K,?>> in method public write(out DataOutputView) : void in class org.apache.flink.streaming.api.operators.InternalTimerServiceSerializationProxy |
From |
To |
|
Change Variable Type serializationProxy : InternalTimerServiceSerializationProxy<K,N> to serializationProxy : InternalTimerServiceSerializationProxy<K> in method public snapshotStateForKeyGroup(stream DataOutputView, keyGroupIdx int) : void in class org.apache.flink.streaming.api.operators.InternalTimeServiceManager |
From |
To |
|
Change Variable Type timeServiceManager : InternalTimeServiceManager<?,?> to timeServiceManager : InternalTimeServiceManager<?> in method public testWithRestore() : void in class org.apache.flink.streaming.api.operators.StreamTaskStateInitializerImplTest |
From |
To |
|
Change Attribute Type timerServices : Map<String,HeapInternalTimerService<K,N>> to timerServices : Map<String,HeapInternalTimerService<K,?>> in class org.apache.flink.streaming.api.operators.InternalTimeServiceManager |
From |
To |
|
Change Attribute Type timerServices : Map<String,HeapInternalTimerService<K,N>> to timerServices : Map<String,HeapInternalTimerService<K,?>> in class org.apache.flink.streaming.api.operators.InternalTimerServiceSerializationProxy |
From |
To |
|
Change Attribute Type internalTimeServiceManager : InternalTimeServiceManager<?,?> to internalTimeServiceManager : InternalTimeServiceManager<?> in class org.apache.flink.streaming.api.operators.StreamTaskStateInitializerImpl.StreamOperatorStateContextImpl |
From |
To |
|
Change Attribute Type timeServiceManager : InternalTimeServiceManager<?,?> to timeServiceManager : InternalTimeServiceManager<?> in class org.apache.flink.streaming.api.operators.AbstractStreamOperator |
From |
To |