b0522e37181f8485610fd37dda9fc45858b6429e
Files Diff
- Added: 0
- Removed: 0
- Renamed: 0
- Modified: 6
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Change Variable Type | 1 | ||
| Change Variable Type latencyEmitter : LatencyMarksEmitter to latencyEmitter : LatencyMarksEmitter<OUT> in method public run(lockingObject Object, streamStatusMaintainer StreamStatusMaintainer, collector Output<StreamRecord<OUT>>) : void in class org.apache.flink.streaming.api.operators.StreamSource | From | To | |
| Extract Variable | 1 | ||
| Extract Variable latencyTrackingInterval : long in method public run(lockingObject Object, streamStatusMaintainer StreamStatusMaintainer, collector Output<StreamRecord<OUT>>) : void from class org.apache.flink.streaming.api.operators.StreamSource | From | To |