0bf0fdc26ea86020929fa64d083dce02ba2a2ae2
Files Diff
- Added: 2
- Removed: 2
- Renamed: 0
- Modified: 50
Refactorings reported:
Refactoring Name | Occurences | ||
---|---|---|---|
Move Source Folder | 1 | ||
Move Source Folder flink-runtime/src/test to flink-runtime/src/main | From | To | |
Extract Variable | 2 | ||
Extract Variable ioMetricGroup : OperatorIOMetricGroup in method public invoke() : void from class org.apache.flink.runtime.operators.DataSourceTask | From | To | |
Extract Variable ioMetricGroup : OperatorIOMetricGroup in method public ChainingOutput(operator OneInputStreamOperator<T,?>, streamStatusProvider StreamStatusProvider, outputTag OutputTag<T>) from class org.apache.flink.streaming.runtime.tasks.OperatorChain.ChainingOutput | From | To | |
Change Attribute Type | 1 | ||
Change Attribute Type metrics : MetricGroup to metrics : OperatorMetricGroup in class org.apache.flink.streaming.api.operators.AbstractStreamOperator | From | To |