40cec17f4303b43bbf65d8be542f0646eada57e8
Files Diff
- Added: 3
- Removed: 3
- Renamed: 0
- Modified: 17
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Method | 4 | ||
| Rename Method public collect(error Throwable) : void renamed to public completeExceptionally(error Throwable) : void in class org.apache.flink.streaming.api.operators.async.queue.StreamRecordQueueEntry | From | To | |
| Rename Method public collect(result Collection<OUT>) : void renamed to public complete(result Collection<OUT>) : void in class org.apache.flink.streaming.api.operators.async.queue.StreamRecordQueueEntry | From | To | |
| Rename Method public collect(error Throwable) : void renamed to public completeExceptionally(error Throwable) : void in class org.apache.flink.streaming.api.functions.async.ResultFuture | From | To | |
| Rename Method public collect(result Collection<OUT>) : void renamed to public complete(result Collection<OUT>) : void in class org.apache.flink.streaming.api.functions.async.ResultFuture | From | To | |
| Change Parameter Type | 3 | ||
| Change Parameter Type collector : AsyncCollector<String> to resultFuture : ResultFuture<String> in method public asyncInvoke(input Integer, resultFuture ResultFuture<String>) : void in class org.apache.flink.streaming.examples.async.AsyncIOExample.SampleAsyncFunction | From | To | |
| Change Parameter Type collector : AsyncCollector<Integer> to resultFuture : ResultFuture<Integer> in method public asyncInvoke(input Integer, resultFuture ResultFuture<Integer>) : void in class org.apache.flink.streaming.api.operators.async.AsyncWaitOperatorTest.LazyAsyncFunction | From | To | |
| Change Parameter Type collector : AsyncCollector<Integer> to resultFuture : ResultFuture<Integer> in method public asyncInvoke(input Integer, resultFuture ResultFuture<Integer>) : void in class org.apache.flink.streaming.api.operators.async.AsyncWaitOperatorTest.MyAsyncFunction | From | To | |
| Rename Variable | 2 | ||
| Rename Variable collector : AsyncCollector<Integer> to resultFuture : ResultFuture<Integer> in method public testTimeoutCleanup() : void in class org.apache.flink.streaming.api.operators.async.AsyncWaitOperatorTest | From | To | |
| Rename Variable collector : AsyncCollector<Integer> to resultFuture : ResultFuture<Integer> in method public testAsyncWaitOperator() : void in class org.apache.flink.test.streaming.api.StreamingOperatorsITCase | From | To | |
| Move And Rename Class | 1 | ||
| Move And Rename Class org.apache.flink.streaming.api.functions.async.collector.AsyncCollector moved and renamed to org.apache.flink.streaming.api.functions.async.ResultFuture | From | To | |
| Change Variable Type | 2 | ||
| Change Variable Type collector : AsyncCollector<Integer> to resultFuture : ResultFuture<Integer> in method public testAsyncWaitOperator() : void in class org.apache.flink.test.streaming.api.StreamingOperatorsITCase | From | To | |
| Change Variable Type collector : AsyncCollector<Integer> to resultFuture : ResultFuture<Integer> in method public testTimeoutCleanup() : void in class org.apache.flink.streaming.api.operators.async.AsyncWaitOperatorTest | From | To | |
| Rename Parameter | 3 | ||
| Rename Parameter collector : AsyncCollector<Integer> to resultFuture : ResultFuture<Integer> in method public asyncInvoke(input Integer, resultFuture ResultFuture<Integer>) : void in class org.apache.flink.streaming.api.operators.async.AsyncWaitOperatorTest.LazyAsyncFunction | From | To | |
| Rename Parameter collector : AsyncCollector<Integer> to resultFuture : ResultFuture<Integer> in method public asyncInvoke(input Integer, resultFuture ResultFuture<Integer>) : void in class org.apache.flink.streaming.api.operators.async.AsyncWaitOperatorTest.MyAsyncFunction | From | To | |
| Rename Parameter collector : AsyncCollector<String> to resultFuture : ResultFuture<String> in method public asyncInvoke(input Integer, resultFuture ResultFuture<String>) : void in class org.apache.flink.streaming.examples.async.AsyncIOExample.SampleAsyncFunction | From | To |