3446e66aac63a3dfdaf8cfd4a73bd80a7f038379
Files Diff
- Added: 3
- Removed: 0
- Renamed: 0
- Modified: 28
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Method | 1 | ||
| Rename Method public enableSnapshotCheckpointing(interval long, checkpointTimeout long, minPauseBetweenCheckpoints long, maxConcurrentCheckpoints int, externalizeSettings ExternalizedCheckpointSettings, verticesToTrigger List<ExecutionJobVertex>, verticesToWaitFor List<ExecutionJobVertex>, verticesToCommitTo List<ExecutionJobVertex>, checkpointIDCounter CheckpointIDCounter, checkpointStore CompletedCheckpointStore, checkpointDir String, statsTracker CheckpointStatsTracker) : void renamed to public enableCheckpointing(interval long, checkpointTimeout long, minPauseBetweenCheckpoints long, maxConcurrentCheckpoints int, externalizeSettings ExternalizedCheckpointSettings, verticesToTrigger List<ExecutionJobVertex>, verticesToWaitFor List<ExecutionJobVertex>, verticesToCommitTo List<ExecutionJobVertex>, checkpointIDCounter CheckpointIDCounter, checkpointStore CompletedCheckpointStore, checkpointDir String, metadataStore StateBackend, statsTracker CheckpointStatsTracker) : void in class org.apache.flink.runtime.executiongraph.ExecutionGraph | From | To | |
| Change Return Type | 3 | ||
| Change Return Type AbstractStateBackend to StateBackend in method private createStateBackend() : StateBackend in class org.apache.flink.streaming.runtime.tasks.StreamTask | From | To | |
| Change Return Type AbstractStateBackend to RocksDBStateBackend in method public createFromConfig(config Configuration) : RocksDBStateBackend in class org.apache.flink.contrib.streaming.state.RocksDBStateBackendFactory | From | To | |
| Change Return Type AbstractStateBackend to T in method public createFromConfig(config Configuration) : T in class org.apache.flink.runtime.state.StateBackendFactory | From | To | |
| Change Attribute Type | 1 | ||
| Change Attribute Type stateBackend : AbstractStateBackend to stateBackend : StateBackend in class org.apache.flink.streaming.runtime.tasks.StreamTask | From | To | |
| Extract And Move Method | 1 | ||
| Extract And Move Method public loadStateBackendFromConfigOrCreateDefault(config Configuration, classLoader ClassLoader, logger Logger) : StateBackend extracted from private createStateBackend() : AbstractStateBackend in class org.apache.flink.streaming.runtime.tasks.StreamTask & moved to class org.apache.flink.runtime.state.AbstractStateBackend | From | To |