c78b3c49e0e82874cbfa71e88bf28b99ed395610
Files Diff
- Added: 4
- Removed: 0
- Renamed: 0
- Modified: 56
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Method | 2 | ||
| Rename Method public getRecordsOutCounter() : Counter renamed to public getNumBytesInRemoteCounter() : Counter in class org.apache.flink.metrics.groups.IOMetricGroup | From | To | |
| Rename Method public getBytesInCounter() : Counter renamed to public getNumBytesInLocalCounter() : Counter in class org.apache.flink.metrics.groups.IOMetricGroup | From | To | |
| Move And Rename Method | 1 | ||
| Move And Rename Method package RecordPusher(dataChannel BlockingQueue<StreamRecord<IN>>, iterationWaitTime long) from class org.apache.flink.streaming.runtime.tasks.StreamIterationTail.RecordPusher to package IterationTailOutput(dataChannel BlockingQueue<StreamRecord<IN>>, iterationWaitTime long) from class org.apache.flink.streaming.runtime.tasks.StreamIterationTail.IterationTailOutput | From | To | |
| Move Attribute | 5 | ||
| Move Attribute private dataChannel : BlockingQueue<StreamRecord<IN>> from class org.apache.flink.streaming.runtime.tasks.StreamIterationTail.RecordPusher to private dataChannel : BlockingQueue<StreamRecord<IN>> from class org.apache.flink.streaming.runtime.tasks.StreamIterationTail.IterationTailOutput | From | To | |
| Move Attribute private iterationWaitTime : long from class org.apache.flink.streaming.runtime.tasks.StreamIterationTail.RecordPusher to private iterationWaitTime : long from class org.apache.flink.streaming.runtime.tasks.StreamIterationTail.IterationTailOutput | From | To | |
| Move Attribute private numRecordsIn : Counter from class org.apache.flink.metrics.groups.IOMetricGroup to private numRecordsIn : Counter from class org.apache.flink.streaming.runtime.io.StreamInputProcessor | From | To | |
| Move Attribute private numRecordsIn : Counter from class org.apache.flink.runtime.io.network.api.serialization.SpillingAdaptiveSpanningRecordDeserializer to private numRecordsIn : Counter from class org.apache.flink.streaming.runtime.io.StreamInputProcessor | From | To | |
| Move Attribute private shouldWait : boolean from class org.apache.flink.streaming.runtime.tasks.StreamIterationTail.RecordPusher to private shouldWait : boolean from class org.apache.flink.streaming.runtime.tasks.StreamIterationTail.IterationTailOutput | From | To | |
| Extract Class | 1 | ||
| Extract Class org.apache.flink.streaming.runtime.tasks.StreamIterationTail.IterationTailOutput from class org.apache.flink.streaming.runtime.tasks.StreamIterationTail.RecordPusher | From | To | |
| Rename Attribute | 2 | ||
| Rename Attribute numBytesIn : Counter to numBytesInLocal : Counter in class org.apache.flink.metrics.groups.IOMetricGroup | From | To | |
| Rename Attribute numRecordsOut : Counter to numBytesInRemote : Counter in class org.apache.flink.metrics.groups.IOMetricGroup | From | To | |
| Extract Variable | 2 | ||
| Extract Variable ctx : RuntimeContext in method public invoke() : void from class org.apache.flink.runtime.operators.DataSinkTask | From | To | |
| Extract Variable ctx : RuntimeContext in method public invoke() : void from class org.apache.flink.runtime.operators.DataSourceTask | From | To | |
| Extract And Move Method | 1 | ||
| Extract And Move Method public run(lockingObject Object) : void extracted from protected run() : void in class org.apache.flink.streaming.runtime.tasks.SourceStreamTask & moved to class org.apache.flink.streaming.api.operators.StreamSource | From | To |