e40cb34868e2c6ff7548653e1e5e2dfbe7d47967
Files Diff
- Added: 3
- Removed: 0
- Renamed: 0
- Modified: 6
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Change Parameter Type | 2 | ||
| Change Parameter Type vertexID : int to operatorId : OperatorID in method public LatencyMarker(markedTime long, operatorId OperatorID, subtaskIndex int) in class org.apache.flink.streaming.runtime.streamrecord.LatencyMarker | From | To | |
| Change Parameter Type vertexID : int to operatorId : OperatorID in method public LatencyMarksEmitter(processingTimeService ProcessingTimeService, output Output<StreamRecord<OUT>>, latencyTrackingInterval long, operatorId OperatorID, subtaskIndex int) in class org.apache.flink.streaming.api.operators.StreamSource.LatencyMarksEmitter | From | To | |
| Rename Attribute | 1 | ||
| Rename Attribute vertexID : int to operatorId : OperatorID in class org.apache.flink.streaming.runtime.streamrecord.LatencyMarker | From | To | |
| Change Attribute Type | 1 | ||
| Change Attribute Type vertexID : int to operatorId : OperatorID in class org.apache.flink.streaming.runtime.streamrecord.LatencyMarker | From | To | |
| Rename Parameter | 3 | ||
| Rename Parameter vertexID : int to operatorId : OperatorID in method public LatencyMarksEmitter(processingTimeService ProcessingTimeService, output Output<StreamRecord<OUT>>, latencyTrackingInterval long, operatorId OperatorID, subtaskIndex int) in class org.apache.flink.streaming.api.operators.StreamSource.LatencyMarksEmitter | From | To | |
| Rename Parameter maker : LatencyMarker to marker : LatencyMarker in method protected reportOrForwardLatencyMarker(marker LatencyMarker) : void in class org.apache.flink.streaming.api.operators.StreamSink | From | To | |
| Rename Parameter vertexID : int to operatorId : OperatorID in method public LatencyMarker(markedTime long, operatorId OperatorID, subtaskIndex int) in class org.apache.flink.streaming.runtime.streamrecord.LatencyMarker | From | To |