55fd5f32d7ef0292a01192ab08456fae49b91791
Files Diff
- Added: 1
- Removed: 0
- Renamed: 0
- Modified: 14
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Method | 4 | ||
| Rename Method public discard(userClassLoader ClassLoader, discardStateHandle boolean) : void renamed to private dispose(userClassLoader ClassLoader, releaseState boolean) : void in class org.apache.flink.runtime.checkpoint.PendingCheckpoint | From | To | |
| Rename Method public startPeriodicCheckpointScheduler(interval long) : void renamed to public startCheckpointScheduler() : void in class org.apache.flink.runtime.checkpoint.CheckpointCoordinator | From | To | |
| Rename Method public createJobStatusListener(actorSystem ActorSystem, checkpointInterval long, leaderSessionID UUID) : ActorGateway renamed to public createActivatorDeactivator(actorSystem ActorSystem, leaderSessionID UUID) : ActorGateway in class org.apache.flink.runtime.checkpoint.CheckpointCoordinator | From | To | |
| Rename Method public stopPeriodicCheckpointScheduler() : void renamed to public stopCheckpointScheduler() : void in class org.apache.flink.runtime.checkpoint.CheckpointCoordinator | From | To | |
| Move Method | 3 | ||
| Move Method public isCheckpointingEnabled() : boolean from class org.apache.flink.streaming.api.graph.StreamGraph to public isCheckpointingEnabled() : boolean from class org.apache.flink.streaming.api.environment.CheckpointConfig | From | To | |
| Move Method public setCheckpointingMode(checkpointingMode CheckpointingMode) : void from class org.apache.flink.streaming.api.graph.StreamGraph to public setCheckpointingMode(checkpointingMode CheckpointingMode) : void from class org.apache.flink.streaming.api.environment.CheckpointConfig | From | To | |
| Move Method public getCheckpointingMode() : CheckpointingMode from class org.apache.flink.streaming.api.graph.StreamGraph to public getCheckpointingMode() : CheckpointingMode from class org.apache.flink.streaming.api.environment.CheckpointConfig | From | To | |
| Move Attribute | 4 | ||
| Move Attribute protected forceCheckpointing : boolean from class org.apache.flink.streaming.api.environment.StreamExecutionEnvironment to private forceCheckpointing : boolean from class org.apache.flink.streaming.api.environment.CheckpointConfig | From | To | |
| Move Attribute private checkpointingMode : CheckpointingMode from class org.apache.flink.streaming.api.graph.StreamGraph to private checkpointingMode : CheckpointingMode from class org.apache.flink.streaming.api.environment.CheckpointConfig | From | To | |
| Move Attribute protected checkpointInterval : long from class org.apache.flink.streaming.api.environment.StreamExecutionEnvironment to private checkpointInterval : long from class org.apache.flink.streaming.api.environment.CheckpointConfig | From | To | |
| Move Attribute protected checkpointingMode : CheckpointingMode from class org.apache.flink.streaming.api.environment.StreamExecutionEnvironment to private checkpointingMode : CheckpointingMode from class org.apache.flink.streaming.api.environment.CheckpointConfig | From | To | |
| Extract Class | 2 | ||
| Extract Class org.apache.flink.streaming.api.environment.CheckpointConfig from class org.apache.flink.streaming.api.environment.StreamExecutionEnvironment | From | To | |
| Extract Class org.apache.flink.streaming.api.environment.CheckpointConfig from class org.apache.flink.streaming.api.graph.StreamGraph | From | To | |
| Replace Variable With Attribute | 1 | ||
| Replace Variable With Attribute interval : long to baseInterval : long in method public startCheckpointScheduler() : void in class org.apache.flink.runtime.checkpoint.CheckpointCoordinator | From | To | |
| Rename Attribute | 1 | ||
| Rename Attribute periodicScheduler : TimerTask to currentPeriodicTrigger : ScheduledTrigger in class org.apache.flink.runtime.checkpoint.CheckpointCoordinator | From | To | |
| Change Attribute Type | 2 | ||
| Change Attribute Type periodicScheduler : TimerTask to currentPeriodicTrigger : ScheduledTrigger in class org.apache.flink.runtime.checkpoint.CheckpointCoordinator | From | To | |
| Change Attribute Type numUnsuccessfulCheckpointsTriggers : AtomicInteger to numUnsuccessfulCheckpointsTriggers : int in class org.apache.flink.runtime.checkpoint.CheckpointCoordinator | From | To | |
| Rename Parameter | 1 | ||
| Rename Parameter discardStateHandle : boolean to releaseState : boolean in method private dispose(userClassLoader ClassLoader, releaseState boolean) : void in class org.apache.flink.runtime.checkpoint.PendingCheckpoint | From | To |