546e2ad73165b00d93c3c460372b9d49a4b5d8b7
Files Diff
- Added: 0
- Removed: 0
- Renamed: 0
- Modified: 5
Refactorings reported:
Refactoring Name | Occurences | ||
---|---|---|---|
Rename Variable | 2 | ||
Rename Variable priorityQueue : PriorityQueue<StreamRecord<IN>> to sortedTimestamps : PriorityQueue<Long> in method public onEventTime(timer InternalTimer<KEY,VoidNamespace>) : void in class org.apache.flink.cep.operator.AbstractKeyedCEPPatternOperator | From | To | |
Rename Variable streamRecord : StreamRecord<IN> to timestamp : long in method public onEventTime(timer InternalTimer<KEY,VoidNamespace>) : void in class org.apache.flink.cep.operator.AbstractKeyedCEPPatternOperator | From | To | |
Inline Method | 1 | ||
Inline Method private updatePriorityQueue(queue PriorityQueue<StreamRecord<IN>>) : void inlined to public onEventTime(timer InternalTimer<KEY,VoidNamespace>) : void in class org.apache.flink.cep.operator.AbstractKeyedCEPPatternOperator | From | To | |
Rename Attribute | 1 | ||
Rename Attribute priorityQueueOperatorState : ValueState<PriorityQueue<StreamRecord<IN>>> to elementQueueState : MapState<Long,List<IN>> in class org.apache.flink.cep.operator.AbstractKeyedCEPPatternOperator | From | To | |
Change Variable Type | 2 | ||
Change Variable Type priorityQueue : PriorityQueue<StreamRecord<IN>> to sortedTimestamps : PriorityQueue<Long> in method public onEventTime(timer InternalTimer<KEY,VoidNamespace>) : void in class org.apache.flink.cep.operator.AbstractKeyedCEPPatternOperator | From | To | |
Change Variable Type streamRecord : StreamRecord<IN> to timestamp : long in method public onEventTime(timer InternalTimer<KEY,VoidNamespace>) : void in class org.apache.flink.cep.operator.AbstractKeyedCEPPatternOperator | From | To | |
Change Attribute Type | 1 | ||
Change Attribute Type priorityQueueOperatorState : ValueState<PriorityQueue<StreamRecord<IN>>> to elementQueueState : MapState<Long,List<IN>> in class org.apache.flink.cep.operator.AbstractKeyedCEPPatternOperator | From | To |