ffff2997a5c82386a6428744f39b808a3fb49538
Files Diff
- Added: 0
- Removed: 0
- Renamed: 0
- Modified: 20
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Method | 2 | ||
| Rename Method protected getCurrentProcessingTime() : long renamed to protected getTimerService() : TimeServiceProvider in class org.apache.flink.streaming.api.operators.AbstractStreamOperator | From | To | |
| Rename Method public getCurrentProcessingTime() : long renamed to public getTimerService() : TimeServiceProvider in class org.apache.flink.streaming.runtime.tasks.StreamTaskTestHarness | From | To | |
| Change Parameter Type | 4 | ||
| Change Parameter Type src : StreamSource<?,?> to timeService : TimeServiceProvider in method private WatermarkEmittingTask(timeService TimeServiceProvider, lock Object, output Output<StreamRecord<T>>) in class org.apache.flink.streaming.api.operators.StreamSource.AutomaticWatermarkContext.WatermarkEmittingTask | From | To | |
| Change Parameter Type timerService : ScheduledExecutorService to timerService : TimeServiceProvider in method private createMockTaskWithTimer(timerService TimeServiceProvider) : StreamTask<?,?> in class org.apache.flink.streaming.runtime.operators.windowing.AccumulatingAlignedProcessingTimeWindowOperatorTest | From | To | |
| Change Parameter Type timerService : ScheduledExecutorService to timerService : TimeServiceProvider in method private createMockTaskWithTimer(timerService TimeServiceProvider) : StreamTask<?,?> in class org.apache.flink.streaming.runtime.operators.windowing.AggregatingAlignedProcessingTimeWindowOperatorTest | From | To | |
| Change Parameter Type timerService : ScheduledExecutorService to timerService : TimeServiceProvider in method private createMockTaskWithTimer(timerService TimeServiceProvider, lock Object) : StreamTask<?,?> in class org.apache.flink.streaming.util.MockContext | From | To | |
| Change Return Type | 2 | ||
| Change Return Type long to TimeServiceProvider in method protected getTimerService() : TimeServiceProvider in class org.apache.flink.streaming.api.operators.AbstractStreamOperator | From | To | |
| Change Return Type long to TimeServiceProvider in method public getTimerService() : TimeServiceProvider in class org.apache.flink.streaming.runtime.tasks.StreamTaskTestHarness | From | To | |
| Rename Attribute | 1 | ||
| Rename Attribute owner : StreamSource<?,?> to timeService : TimeServiceProvider in class org.apache.flink.streaming.api.operators.StreamSource.AutomaticWatermarkContext.WatermarkEmittingTask | From | To | |
| Change Attribute Type | 1 | ||
| Change Attribute Type owner : StreamSource<?,?> to timeService : TimeServiceProvider in class org.apache.flink.streaming.api.operators.StreamSource.AutomaticWatermarkContext.WatermarkEmittingTask | From | To | |
| Extract And Move Method | 1 | ||
| Extract And Move Method public getTimerService() : TimeServiceProvider extracted from private setupSourceOperator(operator StreamSource<T,?>, timeChar TimeCharacteristic, watermarkInterval long, timeProvider TimeServiceProvider) : void in class org.apache.flink.streaming.runtime.operators.StreamSourceOperatorTest & moved to class org.apache.flink.streaming.runtime.tasks.StreamTask | From | To | |
| Rename Parameter | 1 | ||
| Rename Parameter src : StreamSource<?,?> to timeService : TimeServiceProvider in method private WatermarkEmittingTask(timeService TimeServiceProvider, lock Object, output Output<StreamRecord<T>>) in class org.apache.flink.streaming.api.operators.StreamSource.AutomaticWatermarkContext.WatermarkEmittingTask | From | To |