|
Rename Method private createTimerService(triggerable Triggerable<Integer,String>, keyContext KeyContext, processingTimeService ProcessingTimeService, keyGroupList KeyGroupRange, maxParallelism int) : HeapInternalTimerService<Integer,String> renamed to private createAndStartInternalTimerService(triggerable Triggerable<Integer,String>, keyContext KeyContext, processingTimeService ProcessingTimeService, keyGroupList KeyGroupRange, priorityQueueSetFactory PriorityQueueSetFactory) : HeapInternalTimerService<Integer,String> in class org.apache.flink.streaming.api.operators.HeapInternalTimerServiceTest |
From |
To |
|
Rename Method private isElementLessThen(a T, b T) : boolean renamed to private isElementPriorityLessThen(a T, b T) : boolean in class org.apache.flink.runtime.state.heap.HeapPriorityQueue |
From |
To |
|
Rename Method public compare(o1 Q, o2 Q) : int renamed to public comparePriority(o1 Q, o2 Q) : int in class org.apache.flink.runtime.state.heap.KeyGroupPartitionedPriorityQueue.InternalPriorityQueueComparator |
From |
To |
|
Change Parameter Type timerServices : Map<String,HeapInternalTimerService<K,?>> to timerServicesManager : InternalTimeServiceManager<K> in method public InternalTimerServiceSerializationProxy(timerServicesManager InternalTimeServiceManager<K>, keyGroupIdx int) in class org.apache.flink.streaming.api.operators.InternalTimerServiceSerializationProxy |
From |
To |
|
Change Parameter Type elementComparator : Comparator<T> to elementPriorityComparator : PriorityComparator<T> in method public HeapPriorityQueue(elementPriorityComparator PriorityComparator<T>, minimumCapacity int) in class org.apache.flink.runtime.state.heap.HeapPriorityQueue |
From |
To |
|
Change Parameter Type elementComparator : Comparator<T> to elementPriorityComparator : PriorityComparator<T> in method public KeyGroupPartitionedPriorityQueue(keyExtractor KeyExtractorFunction<T>, elementPriorityComparator PriorityComparator<T>, orderedCacheFactory PartitionQueueSetFactory<T,PQ>, keyGroupRange KeyGroupRange, totalKeyGroups int) in class org.apache.flink.runtime.state.heap.KeyGroupPartitionedPriorityQueue |
From |
To |
|
Change Parameter Type maxParallelism : int to priorityQueueSetFactory : PriorityQueueSetFactory in method private createAndStartInternalTimerService(triggerable Triggerable<Integer,String>, keyContext KeyContext, processingTimeService ProcessingTimeService, keyGroupList KeyGroupRange, priorityQueueSetFactory PriorityQueueSetFactory) : HeapInternalTimerService<Integer,String> in class org.apache.flink.streaming.api.operators.HeapInternalTimerServiceTest |
From |
To |
|
Change Parameter Type elementComparator : Comparator<T> to elementPriorityComparator : PriorityComparator<T> in method public HeapPriorityQueueSet(elementPriorityComparator PriorityComparator<T>, keyExtractor KeyExtractorFunction<T>, minimumCapacity int, keyGroupRange KeyGroupRange, totalNumberOfKeyGroups int) in class org.apache.flink.runtime.state.heap.HeapPriorityQueueSet |
From |
To |
|
Change Parameter Type elementComparator : Comparator<T> to elementPriorityComparator : PriorityComparator<T> in method package InternalPriorityQueueComparator(elementPriorityComparator PriorityComparator<T>) in class org.apache.flink.runtime.state.heap.KeyGroupPartitionedPriorityQueue.InternalPriorityQueueComparator |
From |
To |
|
Change Attribute Type eventTimeTimersQueue : HeapPriorityQueueSet<TimerHeapInternalTimer<K,N>> to eventTimeTimersQueue : KeyGroupedInternalPriorityQueue<TimerHeapInternalTimer<K,N>> in class org.apache.flink.streaming.api.operators.HeapInternalTimerService |
From |
To |
|
Change Attribute Type elementComparator : Comparator<T> to elementPriorityComparator : PriorityComparator<T> in class org.apache.flink.runtime.state.heap.HeapPriorityQueue |
From |
To |
|
Change Attribute Type elementComparator : Comparator<T> to elementPriorityComparator : PriorityComparator<T> in class org.apache.flink.runtime.state.heap.KeyGroupPartitionedPriorityQueue.InternalPriorityQueueComparator |
From |
To |
|
Change Attribute Type processingTimeTimersQueue : HeapPriorityQueueSet<TimerHeapInternalTimer<K,N>> to processingTimeTimersQueue : KeyGroupedInternalPriorityQueue<TimerHeapInternalTimer<K,N>> in class org.apache.flink.streaming.api.operators.HeapInternalTimerService |
From |
To |
|
Rename Parameter elementComparator : Comparator<T> to elementPriorityComparator : PriorityComparator<T> in method public HeapPriorityQueue(elementPriorityComparator PriorityComparator<T>, minimumCapacity int) in class org.apache.flink.runtime.state.heap.HeapPriorityQueue |
From |
To |
|
Rename Parameter elementComparator : Comparator<T> to elementPriorityComparator : PriorityComparator<T> in method public KeyGroupPartitionedPriorityQueue(keyExtractor KeyExtractorFunction<T>, elementPriorityComparator PriorityComparator<T>, orderedCacheFactory PartitionQueueSetFactory<T,PQ>, keyGroupRange KeyGroupRange, totalKeyGroups int) in class org.apache.flink.runtime.state.heap.KeyGroupPartitionedPriorityQueue |
From |
To |
|
Rename Parameter timerServices : Map<String,HeapInternalTimerService<K,?>> to timerServicesManager : InternalTimeServiceManager<K> in method public InternalTimerServiceSerializationProxy(timerServicesManager InternalTimeServiceManager<K>, keyGroupIdx int) in class org.apache.flink.streaming.api.operators.InternalTimerServiceSerializationProxy |
From |
To |
|
Rename Parameter maxParallelism : int to priorityQueueSetFactory : PriorityQueueSetFactory in method private createAndStartInternalTimerService(triggerable Triggerable<Integer,String>, keyContext KeyContext, processingTimeService ProcessingTimeService, keyGroupList KeyGroupRange, priorityQueueSetFactory PriorityQueueSetFactory) : HeapInternalTimerService<Integer,String> in class org.apache.flink.streaming.api.operators.HeapInternalTimerServiceTest |
From |
To |
|
Rename Parameter elementComparator : Comparator<T> to elementPriorityComparator : PriorityComparator<T> in method public HeapPriorityQueueSet(elementPriorityComparator PriorityComparator<T>, keyExtractor KeyExtractorFunction<T>, minimumCapacity int, keyGroupRange KeyGroupRange, totalNumberOfKeyGroups int) in class org.apache.flink.runtime.state.heap.HeapPriorityQueueSet |
From |
To |
|
Rename Parameter keyGroupIdx : int to keyGroupId : int in method private getDedupMapForKeyGroup(keyGroupId int) : HashMap<T,T> in class org.apache.flink.runtime.state.heap.HeapPriorityQueueSet |
From |
To |
|
Rename Parameter elementComparator : Comparator<T> to elementPriorityComparator : PriorityComparator<T> in method package InternalPriorityQueueComparator(elementPriorityComparator PriorityComparator<T>) in class org.apache.flink.runtime.state.heap.KeyGroupPartitionedPriorityQueue.InternalPriorityQueueComparator |
From |
To |