ad603d59ec17a07adef995c2f1fd58fb8571a3d8
Files Diff
- Added: 16
- Removed: 7
- Renamed: 0
- Modified: 13
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Method | 2 | ||
| Rename Method private testRun(mode AsyncDataStream.OutputMode) : void renamed to private testProcessingTime(mode AsyncDataStream.OutputMode) : void in class org.apache.flink.streaming.api.operators.async.AsyncWaitOperatorTest | From | To | |
| Rename Method private testWithWatermark(mode AsyncDataStream.OutputMode) : void renamed to private testEventTime(mode AsyncDataStream.OutputMode) : void in class org.apache.flink.streaming.api.operators.async.AsyncWaitOperatorTest | From | To | |
| Push Down Method | 3 | ||
| Push Down Method public getIterationAggregator(name String) : T from class org.apache.flink.streaming.api.functions.async.RichAsyncFunction.RichAsyncFunctionRuntimeContext to public getIterationAggregator(name String) : T from class org.apache.flink.streaming.api.functions.async.RichAsyncFunction.RichAsyncFunctionIterationRuntimeContext | From | To | |
| Push Down Method public getSuperstepNumber() : int from class org.apache.flink.streaming.api.functions.async.RichAsyncFunction.RichAsyncFunctionRuntimeContext to public getSuperstepNumber() : int from class org.apache.flink.streaming.api.functions.async.RichAsyncFunction.RichAsyncFunctionIterationRuntimeContext | From | To | |
| Push Down Method public getPreviousIterationAggregate(name String) : T from class org.apache.flink.streaming.api.functions.async.RichAsyncFunction.RichAsyncFunctionRuntimeContext to public getPreviousIterationAggregate(name String) : T from class org.apache.flink.streaming.api.functions.async.RichAsyncFunction.RichAsyncFunctionIterationRuntimeContext | From | To | |
| Extract Subclass | 1 | ||
| Extract Subclass org.apache.flink.streaming.api.functions.async.RichAsyncFunction.RichAsyncFunctionIterationRuntimeContext from class org.apache.flink.streaming.api.functions.async.RichAsyncFunction.RichAsyncFunctionRuntimeContext | From | To | |
| Rename Variable | 4 | ||
| Rename Variable counter : IntCounter to superstepNumber : int in method public testIterationRuntimeContext() : void in class org.apache.flink.streaming.api.functions.async.RichAsyncFunctionTest | From | To | |
| Rename Variable collector : AsyncCollector<OUT> to streamRecordBufferEntry : StreamRecordQueueEntry<OUT> in method public processElement(element StreamRecord<IN>) : void in class org.apache.flink.streaming.api.operators.async.AsyncWaitOperator | From | To | |
| Rename Variable context : IterationRuntimeContext to mockedIterationRuntimeContext : IterationRuntimeContext in method public testIterationRuntimeContext() : void in class org.apache.flink.streaming.api.functions.async.RichAsyncFunctionTest | From | To | |
| Rename Variable counter : IntCounter to taskName : String in method public testRuntimeContext() : void in class org.apache.flink.streaming.api.functions.async.RichAsyncFunctionTest | From | To | |
| Move Attribute | 1 | ||
| Move Attribute private checkpointLock : Object from class org.apache.flink.streaming.api.operators.async.AsyncWaitOperator to private checkpointLock : Object from class org.apache.flink.streaming.api.operators.async.Emitter | From | To | |
| Move Class | 1 | ||
| Move Class org.apache.flink.streaming.runtime.operators.StreamSourceOperatorTest.CollectorOutput moved to org.apache.flink.streaming.util.CollectorOutput | From | To | |
| Rename Attribute | 2 | ||
| Rename Attribute bufferSize : int to capacity : int in class org.apache.flink.streaming.api.operators.async.AsyncWaitOperator | From | To | |
| Rename Attribute idx : int to key : int in class org.apache.flink.test.streaming.api.StreamingOperatorsITCase.MemorySinkFunction | From | To | |
| Extract Variable | 1 | ||
| Extract Variable mockedRuntimeContext : RuntimeContext in method public testRuntimeContext() : void from class org.apache.flink.streaming.api.functions.async.RichAsyncFunctionTest | From | To | |
| Change Variable Type | 5 | ||
| Change Variable Type sleep : int to sleep : long in method public run() : void in class org.apache.flink.streaming.examples.async.AsyncIOExample.SampleAsyncFunction.asyncInvoke.submit | From | To | |
| Change Variable Type counter : IntCounter to taskName : String in method public testRuntimeContext() : void in class org.apache.flink.streaming.api.functions.async.RichAsyncFunctionTest | From | To | |
| Change Variable Type counter : IntCounter to superstepNumber : int in method public testIterationRuntimeContext() : void in class org.apache.flink.streaming.api.functions.async.RichAsyncFunctionTest | From | To | |
| Change Variable Type collector : AsyncCollector<OUT> to streamRecordBufferEntry : StreamRecordQueueEntry<OUT> in method public processElement(element StreamRecord<IN>) : void in class org.apache.flink.streaming.api.operators.async.AsyncWaitOperator | From | To | |
| Change Variable Type sleep : int to sleep : long in method public asyncInvoke(input Integer, collector AsyncCollector<String>) : void in class org.apache.flink.streaming.examples.async.AsyncIOExample.SampleAsyncFunction | From | To | |
| Extract Method | 1 | ||
| Extract Method private freeExecutor() : void extracted from public close() : void in class org.apache.flink.streaming.api.operators.async.AsyncWaitOperatorTest.MyAsyncFunction | From | To | |
| Inline Variable | 1 | ||
| Inline Variable ret : List<String> in method public run() : void from class org.apache.flink.streaming.examples.async.AsyncIOExample.SampleAsyncFunction.asyncInvoke.submit | From | To | |
| Rename Parameter | 4 | ||
| Rename Parameter idx : int to key : int in method public MemorySinkFunction(key int) in class org.apache.flink.test.streaming.api.StreamingOperatorsITCase.MemorySinkFunction | From | To | |
| Rename Parameter mode : AsyncDataStream.OutputMode to outputMode : AsyncDataStream.OutputMode in method public AsyncWaitOperator(asyncFunction AsyncFunction<IN,OUT>, capacity int, outputMode AsyncDataStream.OutputMode) in class org.apache.flink.streaming.api.operators.async.AsyncWaitOperator | From | To | |
| Rename Parameter t : RuntimeContext to runtimeContext : RuntimeContext in method public setRuntimeContext(runtimeContext RuntimeContext) : void in class org.apache.flink.streaming.api.functions.async.RichAsyncFunction | From | To | |
| Rename Parameter bufferSize : int to capacity : int in method public AsyncWaitOperator(asyncFunction AsyncFunction<IN,OUT>, capacity int, outputMode AsyncDataStream.OutputMode) in class org.apache.flink.streaming.api.operators.async.AsyncWaitOperator | From | To |