|
Push Down Method public getKey() : K from class org.apache.flink.streaming.api.operators.InternalTimer to public getKey() : K from class org.apache.flink.streaming.api.operators.TimerHeapInternalTimer |
From |
To |
|
Push Down Method public hashCode() : int from class org.apache.flink.streaming.api.operators.InternalTimer to public hashCode() : int from class org.apache.flink.streaming.api.operators.TimerHeapInternalTimer |
From |
To |
|
Push Down Method public equals(o Object) : boolean from class org.apache.flink.streaming.api.operators.InternalTimer to public equals(o Object) : boolean from class org.apache.flink.streaming.api.operators.TimerHeapInternalTimer |
From |
To |
|
Push Down Method public getTimestamp() : long from class org.apache.flink.streaming.api.operators.InternalTimer to public getTimestamp() : long from class org.apache.flink.streaming.api.operators.TimerHeapInternalTimer |
From |
To |
|
Push Down Method public InternalTimer(timestamp long, key K, namespace N) from class org.apache.flink.streaming.api.operators.InternalTimer to package TimerHeapInternalTimer(timestamp long, key K, namespace N) from class org.apache.flink.streaming.api.operators.TimerHeapInternalTimer |
From |
To |
|
Push Down Method public toString() : String from class org.apache.flink.streaming.api.operators.InternalTimer to public toString() : String from class org.apache.flink.streaming.api.operators.TimerHeapInternalTimer |
From |
To |
|
Push Down Method public getNamespace() : N from class org.apache.flink.streaming.api.operators.InternalTimer to public getNamespace() : N from class org.apache.flink.streaming.api.operators.TimerHeapInternalTimer |
From |
To |
|
Change Parameter Type localKeyGroupRange : KeyGroupsList to localKeyGroupRange : KeyGroupRange in method package HeapInternalTimerService(totalKeyGroups int, localKeyGroupRange KeyGroupRange, keyContext KeyContext, processingTimeService ProcessingTimeService) in class org.apache.flink.streaming.api.operators.HeapInternalTimerService |
From |
To |
|
Change Parameter Type keyGroupList : KeyGroupsList to keyGroupList : KeyGroupRange in method private createTimerService(triggerable Triggerable<Integer,String>, keyContext KeyContext, processingTimeService ProcessingTimeService, keyGroupList KeyGroupRange, maxParallelism int) : HeapInternalTimerService<Integer,String> in class org.apache.flink.streaming.api.operators.HeapInternalTimerServiceTest |
From |
To |
|
Change Parameter Type keyGroupsList : KeyGroupsList to keyGroupsList : KeyGroupRange in method private restoreTimerService(state Map<Integer,byte[]>, snapshotVersion int, triggerable Triggerable<Integer,String>, keyContext KeyContext, processingTimeService ProcessingTimeService, keyGroupsList KeyGroupRange, maxParallelism int) : HeapInternalTimerService<Integer,String> in class org.apache.flink.streaming.api.operators.HeapInternalTimerServiceTest |
From |
To |
|
Change Parameter Type localKeyGroupRange : KeyGroupsList to localKeyGroupRange : KeyGroupRange in method package InternalTimeServiceManager(totalKeyGroups int, localKeyGroupRange KeyGroupRange, keyContext KeyContext, processingTimeService ProcessingTimeService) in class org.apache.flink.streaming.api.operators.InternalTimeServiceManager |
From |
To |
|
Change Parameter Type localKeyGroupRange : KeyGroupsList to localKeyGroupRange : KeyGroupRange in method public InternalTimerServiceSerializationProxy(timerServicesMapToPopulate Map<String,HeapInternalTimerService<K,N>>, userCodeClassLoader ClassLoader, totalKeyGroups int, localKeyGroupRange KeyGroupRange, keyContext KeyContext, processingTimeService ProcessingTimeService, keyGroupIdx int) in class org.apache.flink.streaming.api.operators.InternalTimerServiceSerializationProxy |
From |
To |
|
Change Variable Type timerSerializer : InternalTimer.TimerSerializer<K,N> to timerSerializer : TimerHeapInternalTimer.TimerSerializer<K,N> in method public readTimersSnapshot(in DataInputView) : InternalTimersSnapshot<K,N> in class org.apache.flink.streaming.api.operators.InternalTimersSnapshotReaderWriters.AbstractInternalTimersSnapshotReader |
From |
To |
|
Change Variable Type timerSerializer : InternalTimer.TimerSerializer<K,N> to timerSerializer : TimerHeapInternalTimer.TimerSerializer<K,N> in method public writeTimersSnapshot(out DataOutputView) : void in class org.apache.flink.streaming.api.operators.InternalTimersSnapshotReaderWriters.AbstractInternalTimersSnapshotWriter |
From |
To |
|
Change Variable Type eventTimeTimers : Set<InternalTimer<Integer,String>>[] to eventTimeTimers : List<Set<InternalTimer<Integer,String>>> in method public testTimerAssignmentToKeyGroups() : void in class org.apache.flink.streaming.api.operators.HeapInternalTimerServiceTest |
From |
To |
|
Change Variable Type timer : InternalTimer<Integer,String> to timer : TimerHeapInternalTimer<Integer,String> in method public testTimerAssignmentToKeyGroups() : void in class org.apache.flink.streaming.api.operators.HeapInternalTimerServiceTest |
From |
To |
|
Change Variable Type testKeyGroupList : KeyGroupsList to testKeyGroupList : KeyGroupRange in method public testKeyGroupStartIndexSetting() : void in class org.apache.flink.streaming.api.operators.HeapInternalTimerServiceTest |
From |
To |
|
Change Variable Type processingTimeTimers : Set<InternalTimer<Integer,String>>[] to processingTimeTimers : List<Set<InternalTimer<Integer,String>>> in method public testTimerAssignmentToKeyGroups() : void in class org.apache.flink.streaming.api.operators.HeapInternalTimerServiceTest |
From |
To |
|
Change Attribute Type eventTimeTimersQueue : PriorityQueue<InternalTimer<K,N>> to eventTimeTimersQueue : InternalTimerHeap<K,N> in class org.apache.flink.streaming.api.operators.HeapInternalTimerService |
From |
To |
|
Change Attribute Type localKeyGroupRange : KeyGroupsList to localKeyGroupRange : KeyGroupRange in class org.apache.flink.streaming.api.operators.InternalTimeServiceManager |
From |
To |
|
Change Attribute Type localKeyGroupRange : KeyGroupsList to localKeyGroupRange : KeyGroupRange in class org.apache.flink.streaming.api.operators.HeapInternalTimerService |
From |
To |
|
Change Attribute Type localKeyGroupRange : KeyGroupsList to localKeyGroupRange : KeyGroupRange in class org.apache.flink.streaming.api.operators.InternalTimerServiceSerializationProxy |
From |
To |
|
Change Attribute Type processingTimeTimersQueue : PriorityQueue<InternalTimer<K,N>> to processingTimeTimersQueue : InternalTimerHeap<K,N> in class org.apache.flink.streaming.api.operators.HeapInternalTimerService |
From |
To |