e7586c3b2d995be164100919d7c04db003a71a90
Files Diff
- Added: 0
- Removed: 0
- Renamed: 0
- Modified: 6
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Change Return Type | 4 | ||
| Change Return Type void to ScheduledFuture<?> in method public registerTimer(time long, target Triggerable) : ScheduledFuture<?> in class org.apache.flink.streaming.connectors.kafka.testutils.MockRuntimeContext | From | To | |
| Change Return Type void to ScheduledFuture<?> in method public registerTimer(timestamp long, target Triggerable) : ScheduledFuture<?> in class org.apache.flink.streaming.runtime.tasks.StreamTask | From | To | |
| Change Return Type void to ScheduledFuture<?> in method protected registerTimer(time long, target Triggerable) : ScheduledFuture<?> in class org.apache.flink.streaming.api.operators.AbstractStreamOperator | From | To | |
| Change Return Type void to ScheduledFuture<?> in method public registerTimer(time long, target Triggerable) : ScheduledFuture<?> in class org.apache.flink.streaming.api.operators.StreamingRuntimeContext | From | To | |
| Change Attribute Type | 1 | ||
| Change Attribute Type timerService : ScheduledExecutorService to timerService : ScheduledThreadPoolExecutor in class org.apache.flink.streaming.runtime.tasks.StreamTask | From | To | |
| Extract Method | 2 | ||
| Extract Method private snapshotTimers(out DataOutputView) : void extracted from public snapshotOperatorState(checkpointId long, timestamp long) : StreamTaskState in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperator | From | To | |
| Extract Method private restoreTimers(in DataInputView) : void extracted from public restoreState(taskState StreamTaskState, recoveryTimestamp long) : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperator | From | To |