6c5a8711d80dfcea20967aea009bac51122d5094
Files Diff
- Added: 0
- Removed: 0
- Renamed: 0
- Modified: 18
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Method | 1 | ||
| Rename Method public unorderedWait(in DataStream<IN>, func AsyncFunction<IN,OUT>) : SingleOutputStreamOperator<OUT> renamed to public orderedWait(in DataStream<IN>, func AsyncFunction<IN,OUT>, timeout long, timeUnit TimeUnit, capacity int) : SingleOutputStreamOperator<OUT> in class org.apache.flink.streaming.api.datastream.AsyncDataStream | From | To | |
| Move Attribute | 1 | ||
| Move Attribute private TIMEOUT : long from class org.apache.flink.streaming.api.operators.async.AsyncWaitOperatorTest.MyAsyncFunction to private TIMEOUT : long from class org.apache.flink.streaming.api.operators.async.AsyncWaitOperatorTest | From | To | |
| Rename Attribute | 1 | ||
| Rename Attribute TIMEOUT : long to TERMINATION_TIMEOUT : long in class org.apache.flink.streaming.api.operators.async.AsyncWaitOperatorTest.MyAsyncFunction | From | To | |
| Rename Parameter | 1 | ||
| Rename Parameter bufSize : int to capacity : int in method public unorderedWait(in DataStream<IN>, func AsyncFunction<IN,OUT>, timeout long, timeUnit TimeUnit, capacity int) : SingleOutputStreamOperator<OUT> in class org.apache.flink.streaming.api.datastream.AsyncDataStream | From | To |