|
Change Variable Type timerService1 : HeapInternalTimerService<Integer,String> to timerService1 : InternalTimerServiceImpl<Integer,String> in method private testSnapshotAndRebalancingRestore(snapshotVersion int) : void in class org.apache.flink.streaming.api.operators.InternalTimerServiceImplTest |
From |
To |
|
Change Variable Type returnElement : T to returnElement : byte[] in method public next() : byte[] in class org.apache.flink.contrib.streaming.state.RocksDBCachingPriorityQueueSet.RocksBytesIterator |
From |
To |
|
Change Variable Type timerService2 : HeapInternalTimerService<Integer,String> to timerService2 : InternalTimerServiceImpl<Integer,String> in method private testSnapshotAndRebalancingRestore(snapshotVersion int) : void in class org.apache.flink.streaming.api.operators.InternalTimerServiceImplTest |
From |
To |
|
Change Variable Type timerService : HeapInternalTimerService<K,N> to timerService : InternalTimerServiceImpl<K,N> in method package registerOrGetTimerService(name String, timerSerializer TimerSerializer<K,N>) : InternalTimerServiceImpl<K,N> in class org.apache.flink.streaming.api.operators.InternalTimeServiceManager |
From |
To |
|
Change Variable Type service : HeapInternalTimerService<?,?> to service : InternalTimerServiceImpl<?,?> in method public advanceWatermark(watermark Watermark) : void in class org.apache.flink.streaming.api.operators.InternalTimeServiceManager |
From |
To |
|
Change Variable Type entry : Map.Entry<String,HeapInternalTimerService<K,?>> to entry : Map.Entry<String,InternalTimerServiceImpl<K,?>> in method public write(out DataOutputView) : void in class org.apache.flink.streaming.api.operators.InternalTimerServiceSerializationProxy |
From |
To |
|
Change Variable Type timerService : HeapInternalTimerService<Integer,String> to timerService : InternalTimerServiceImpl<Integer,String> in method public testCurrentProcessingTime() : void in class org.apache.flink.streaming.api.operators.InternalTimerServiceImplTest |
From |
To |
|
Change Variable Type timerService : HeapInternalTimerService<?,?> to timerService : InternalTimerServiceImpl<?,?> in method public numEventTimeTimers() : int in class org.apache.flink.streaming.api.operators.InternalTimeServiceManager |
From |
To |
|
Change Variable Type timerService : HeapInternalTimerService<Integer,String> to timerService : InternalTimerServiceImpl<Integer,String> in method public testRegisterEarlierProcessingTimerMovesPhysicalProcessingTimer() : void in class org.apache.flink.streaming.api.operators.InternalTimerServiceImplTest |
From |
To |
|
Change Variable Type timerService : HeapInternalTimerService<Integer,String> to timerService : InternalTimerServiceImpl<Integer,String> in method public testSetAndFireEventTimeTimers() : void in class org.apache.flink.streaming.api.operators.InternalTimerServiceImplTest |
From |
To |
|
Change Variable Type timerService : HeapInternalTimerService<Integer,String> to timerService : InternalTimerServiceImpl<Integer,String> in method public testTimerAssignmentToKeyGroups() : void in class org.apache.flink.streaming.api.operators.InternalTimerServiceImplTest |
From |
To |
|
Change Variable Type timerService : HeapInternalTimerService<Integer,String> to timerService : InternalTimerServiceImpl<Integer,String> in method public testCurrentEventTime() : void in class org.apache.flink.streaming.api.operators.InternalTimerServiceImplTest |
From |
To |
|
Change Variable Type timerService : HeapInternalTimerService<Integer,String> to timerService : InternalTimerServiceImpl<Integer,String> in method public testRegisteringProcessingTimeTimerInOnProcessingTimeDoesNotLeakPhysicalTimers() : void in class org.apache.flink.streaming.api.operators.InternalTimerServiceImplTest |
From |
To |
|
Change Variable Type timerService : HeapInternalTimerService<K,N> to timerService : InternalTimerServiceImpl<K,N> in method public getInternalTimerService(name String, timerSerializer TimerSerializer<K,N>, triggerable Triggerable<K,N>) : InternalTimerService<N> in class org.apache.flink.streaming.api.operators.InternalTimeServiceManager |
From |
To |
|
Change Variable Type timerService : HeapInternalTimerService<Integer,String> to timerService : InternalTimerServiceImpl<Integer,String> in method public testOnlySetsOnePhysicalProcessingTimeTimer() : void in class org.apache.flink.streaming.api.operators.InternalTimerServiceImplTest |
From |
To |
|
Change Variable Type registeredTimerServices : Map<String,HeapInternalTimerService<K,?>> to registeredTimerServices : Map<String,InternalTimerServiceImpl<K,?>> in method public write(out DataOutputView) : void in class org.apache.flink.streaming.api.operators.InternalTimerServiceSerializationProxy |
From |
To |
|
Change Variable Type service : HeapInternalTimerService<Integer,String> to service : InternalTimerServiceImpl<Integer,String> in method private restoreTimerService(state Map<Integer,byte[]>, snapshotVersion int, triggerable Triggerable<Integer,String>, keyContext KeyContext, processingTimeService ProcessingTimeService, keyGroupsList KeyGroupRange, priorityQueueSetFactory PriorityQueueSetFactory) : InternalTimerServiceImpl<Integer,String> in class org.apache.flink.streaming.api.operators.InternalTimerServiceImplTest |
From |
To |
|
Change Variable Type timerService : HeapInternalTimerService<K,?> to timerService : InternalTimerServiceImpl<K,?> in method public write(out DataOutputView) : void in class org.apache.flink.streaming.api.operators.InternalTimerServiceSerializationProxy |
From |
To |
|
Change Variable Type timerService : HeapInternalTimerService<Integer,String> to timerService : InternalTimerServiceImpl<Integer,String> in method private testSnapshotAndRebalancingRestore(snapshotVersion int) : void in class org.apache.flink.streaming.api.operators.InternalTimerServiceImplTest |
From |
To |
|
Change Variable Type timerService : HeapInternalTimerService<Integer,String> to timerService : InternalTimerServiceImpl<Integer,String> in method public testDeleteProcessingTimeTimers() : void in class org.apache.flink.streaming.api.operators.InternalTimerServiceImplTest |
From |
To |
|
Change Variable Type service : HeapInternalTimerService<Integer,String> to service : InternalTimerServiceImpl<Integer,String> in method private createAndStartInternalTimerService(triggerable Triggerable<Integer,String>, keyContext KeyContext, processingTimeService ProcessingTimeService, keyGroupList KeyGroupRange, priorityQueueSetFactory PriorityQueueSetFactory) : InternalTimerServiceImpl<Integer,String> in class org.apache.flink.streaming.api.operators.InternalTimerServiceImplTest |
From |
To |
|
Change Variable Type timerService : HeapInternalTimerService<?,?> to timerService : InternalTimerServiceImpl<?,?> in method public numProcessingTimeTimers() : int in class org.apache.flink.streaming.api.operators.InternalTimeServiceManager |
From |
To |
|
Change Variable Type service : HeapInternalTimerService<Integer,String> to service : InternalTimerServiceImpl<Integer,String> in method public testKeyGroupStartIndexSetting() : void in class org.apache.flink.streaming.api.operators.InternalTimerServiceImplTest |
From |
To |
|
Change Variable Type timerService : HeapInternalTimerService<K,?> to timerService : InternalTimerServiceImpl<K,?> in method protected read(in DataInputView, wasVersioned boolean) : void in class org.apache.flink.streaming.api.operators.InternalTimerServiceSerializationProxy |
From |
To |
|
Change Variable Type timerService : HeapInternalTimerService<Integer,String> to timerService : InternalTimerServiceImpl<Integer,String> in method public testSetAndFireProcessingTimeTimers() : void in class org.apache.flink.streaming.api.operators.InternalTimerServiceImplTest |
From |
To |
|
Change Variable Type timerService : HeapInternalTimerService<Integer,String> to timerService : InternalTimerServiceImpl<Integer,String> in method private testSnapshotAndRestore(snapshotVersion int) : void in class org.apache.flink.streaming.api.operators.InternalTimerServiceImplTest |
From |
To |
|
Change Variable Type timerService : HeapInternalTimerService<Integer,String> to timerService : InternalTimerServiceImpl<Integer,String> in method public testDeleteEventTimeTimers() : void in class org.apache.flink.streaming.api.operators.InternalTimerServiceImplTest |
From |
To |
|
Pull Up Method private isValidArraySize(size int) : boolean from class org.apache.flink.runtime.state.heap.HeapPriorityQueue to private isValidArraySize(size int) : boolean from class org.apache.flink.runtime.state.heap.AbstractHeapPriorityQueue |
From |
To |
|
Pull Up Method public size() : int from class org.apache.flink.runtime.state.heap.HeapPriorityQueue to public size() : int from class org.apache.flink.runtime.state.heap.AbstractHeapPriorityQueue |
From |
To |
|
Pull Up Method public isEmpty() : boolean from class org.apache.flink.runtime.state.heap.HeapPriorityQueue to public isEmpty() : boolean from class org.apache.flink.runtime.state.heap.AbstractHeapPriorityQueue |
From |
To |
|
Pull Up Method public toArray(out O[]) : O[] from class org.apache.flink.runtime.state.heap.HeapPriorityQueue to public toArray(out O[]) : O[] from class org.apache.flink.runtime.state.heap.AbstractHeapPriorityQueue |
From |
To |
|
Pull Up Method public clear() : void from class org.apache.flink.runtime.state.heap.HeapPriorityQueue to public clear() : void from class org.apache.flink.runtime.state.heap.AbstractHeapPriorityQueue |
From |
To |
|
Pull Up Method public add(toAdd T) : boolean from class org.apache.flink.runtime.state.heap.HeapPriorityQueue to public add(toAdd T) : boolean from class org.apache.flink.runtime.state.heap.AbstractHeapPriorityQueue |
From |
To |
|
Pull Up Method public iterator() : CloseableIterator<T> from class org.apache.flink.runtime.state.heap.HeapPriorityQueue to public iterator() : CloseableIterator<T> from class org.apache.flink.runtime.state.heap.AbstractHeapPriorityQueue |
From |
To |
|
Pull Up Method private resizeQueueArray(desiredSize int, minRequiredSize int) : void from class org.apache.flink.runtime.state.heap.HeapPriorityQueue to protected resizeQueueArray(desiredSize int, minRequiredSize int) : void from class org.apache.flink.runtime.state.heap.AbstractHeapPriorityQueue |
From |
To |
|
Pull Up Method private moveElementToIdx(element T, idx int) : void from class org.apache.flink.runtime.state.heap.HeapPriorityQueue to protected moveElementToIdx(element T, idx int) : void from class org.apache.flink.runtime.state.heap.AbstractHeapPriorityQueue |
From |
To |
|
Pull Up Method public poll() : T from class org.apache.flink.runtime.state.heap.HeapPriorityQueue to public poll() : T from class org.apache.flink.runtime.state.heap.AbstractHeapPriorityQueue |
From |
To |
|
Pull Up Method private resizeForBulkLoad(totalSize int) : void from class org.apache.flink.runtime.state.heap.HeapPriorityQueue to protected resizeForBulkLoad(totalSize int) : void from class org.apache.flink.runtime.state.heap.AbstractHeapPriorityQueue |
From |
To |
|
Pull Up Method public peek() : T from class org.apache.flink.runtime.state.heap.HeapPriorityQueue to public peek() : T from class org.apache.flink.runtime.state.heap.AbstractHeapPriorityQueue |
From |
To |
|
Pull Up Method private removeInternal(elementToRemove T) : boolean from class org.apache.flink.runtime.state.heap.HeapPriorityQueue to public remove(toRemove T) : boolean from class org.apache.flink.runtime.state.heap.AbstractHeapPriorityQueue |
From |
To |
|
Pull Up Method public addAll(restoredElements Collection<? extends T>) : void from class org.apache.flink.runtime.state.heap.HeapPriorityQueue to public addAll(toAdd Collection<? extends T>) : void from class org.apache.flink.runtime.state.heap.AbstractHeapPriorityQueue |
From |
To |
|
Pull Up Method public remove(toRemove T) : boolean from class org.apache.flink.runtime.state.heap.HeapPriorityQueue to public remove(toRemove T) : boolean from class org.apache.flink.runtime.state.heap.AbstractHeapPriorityQueue |
From |
To |
|
Change Return Type HeapInternalTimerService<K,N> to InternalTimerServiceImpl<K,N> in method private registerOrGetTimerService(serviceName String, restoredTimersSnapshot InternalTimersSnapshot<?,?>) : InternalTimerServiceImpl<K,N> in class org.apache.flink.streaming.api.operators.InternalTimerServiceSerializationProxy |
From |
To |
|
Change Return Type HeapInternalTimerService<Integer,String> to InternalTimerServiceImpl<Integer,String> in method private createAndStartInternalTimerService(triggerable Triggerable<Integer,String>, keyContext KeyContext, processingTimeService ProcessingTimeService, keyGroupList KeyGroupRange, priorityQueueSetFactory PriorityQueueSetFactory) : InternalTimerServiceImpl<Integer,String> in class org.apache.flink.streaming.api.operators.InternalTimerServiceImplTest |
From |
To |
|
Change Return Type boolean to void in method protected addInternal(element T) : void in class org.apache.flink.runtime.state.heap.HeapPriorityQueue |
From |
To |
|
Change Return Type T to byte[] in method public next() : byte[] in class org.apache.flink.contrib.streaming.state.RocksDBCachingPriorityQueueSet.RocksBytesIterator |
From |
To |
|
Change Return Type Map<String,HeapInternalTimerService<K,?>> to Map<String,InternalTimerServiceImpl<K,?>> in method package getRegisteredTimerServices() : Map<String,InternalTimerServiceImpl<K,?>> in class org.apache.flink.streaming.api.operators.InternalTimeServiceManager |
From |
To |
|
Change Return Type HeapInternalTimerService<Integer,String> to InternalTimerServiceImpl<Integer,String> in method private restoreTimerService(state Map<Integer,byte[]>, snapshotVersion int, triggerable Triggerable<Integer,String>, keyContext KeyContext, processingTimeService ProcessingTimeService, keyGroupsList KeyGroupRange, priorityQueueSetFactory PriorityQueueSetFactory) : InternalTimerServiceImpl<Integer,String> in class org.apache.flink.streaming.api.operators.InternalTimerServiceImplTest |
From |
To |
|
Change Return Type HeapInternalTimerService<K,N> to InternalTimerServiceImpl<K,N> in method package registerOrGetTimerService(name String, timerSerializer TimerSerializer<K,N>) : InternalTimerServiceImpl<K,N> in class org.apache.flink.streaming.api.operators.InternalTimeServiceManager |
From |
To |
|
Change Return Type HeapInternalTimerService<K,N> to InternalTimerServiceImpl<K,N> in method private createInternalTimerService(keyGroupsList KeyGroupRange, keyContext KeyContext, processingTimeService ProcessingTimeService, keySerializer TypeSerializer<K>, namespaceSerializer TypeSerializer<N>, priorityQueueSetFactory PriorityQueueSetFactory) : InternalTimerServiceImpl<K,N> in class org.apache.flink.streaming.api.operators.InternalTimerServiceImplTest |
From |
To |