2dd557fad4a0a205a3e163fa918507d34c933c6a
Files Diff
- Added: 1
- Removed: 0
- Renamed: 0
- Modified: 27
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Method | 3 | ||
| Rename Method public getJobCheckpointingSettings() : JobCheckpointingSettings renamed to public getCheckpointCoordinatorConfiguration() : CheckpointCoordinatorConfiguration in class org.apache.flink.runtime.executiongraph.ExecutionGraph | From | To | |
| Rename Method public getExternalizedCheckpointSettings() : ExternalizedCheckpointSettings renamed to public getCheckpointCoordinatorConfiguration() : CheckpointCoordinatorConfiguration in class org.apache.flink.runtime.jobgraph.tasks.JobCheckpointingSettings | From | To | |
| Rename Method public getJobCheckpointingSettings() : JobCheckpointingSettings renamed to public getCheckpointCoordinatorConfiguration() : CheckpointCoordinatorConfiguration in class org.apache.flink.runtime.executiongraph.AccessExecutionGraph | From | To | |
| Change Parameter Type | 3 | ||
| Change Parameter Type snapshottingSettings : JobCheckpointingSettings to jobCheckpointingConfiguration : CheckpointCoordinatorConfiguration in method public GraphAndSettings(graph AccessExecutionGraph, jobCheckpointingConfiguration CheckpointCoordinatorConfiguration, externalizedSettings ExternalizedCheckpointSettings) in class org.apache.flink.runtime.rest.handler.legacy.checkpoints.CheckpointConfigHandlerTest.GraphAndSettings | From | To | |
| Change Parameter Type jobCheckpointingSettings : JobCheckpointingSettings to jobCheckpointingConfiguration : CheckpointCoordinatorConfiguration in method public CheckpointStatsTracker(numRememberedCheckpoints int, jobVertices List<ExecutionJobVertex>, jobCheckpointingConfiguration CheckpointCoordinatorConfiguration, metricGroup MetricGroup) in class org.apache.flink.runtime.checkpoint.CheckpointStatsTracker | From | To | |
| Change Parameter Type jobCheckpointingSettings : JobCheckpointingSettings to jobCheckpointingConfiguration : CheckpointCoordinatorConfiguration in method public ArchivedExecutionGraph(jobID JobID, jobName String, tasks Map<JobVertexID,ArchivedExecutionJobVertex>, verticesInCreationOrder List<ArchivedExecutionJobVertex>, stateTimestamps long[], state JobStatus, failureCause ErrorInfo, jsonPlan String, archivedUserAccumulators StringifiedAccumulatorResult[], serializedUserAccumulators Map<String,SerializedValue<Object>>, executionConfig ArchivedExecutionConfig, isStoppable boolean, jobCheckpointingConfiguration CheckpointCoordinatorConfiguration, checkpointStatsSnapshot CheckpointStatsSnapshot) in class org.apache.flink.runtime.executiongraph.ArchivedExecutionGraph | From | To | |
| Move Method | 5 | ||
| Move Method public getMinPauseBetweenCheckpoints() : long from class org.apache.flink.runtime.jobgraph.tasks.JobCheckpointingSettings to public getMinPauseBetweenCheckpoints() : long from class org.apache.flink.runtime.jobgraph.tasks.CheckpointCoordinatorConfiguration | From | To | |
| Move Method public getCheckpointInterval() : long from class org.apache.flink.runtime.jobgraph.tasks.JobCheckpointingSettings to public getCheckpointInterval() : long from class org.apache.flink.runtime.jobgraph.tasks.CheckpointCoordinatorConfiguration | From | To | |
| Move Method public isExactlyOnce() : boolean from class org.apache.flink.runtime.jobgraph.tasks.JobCheckpointingSettings to public isExactlyOnce() : boolean from class org.apache.flink.runtime.jobgraph.tasks.CheckpointCoordinatorConfiguration | From | To | |
| Move Method public getMaxConcurrentCheckpoints() : int from class org.apache.flink.runtime.jobgraph.tasks.JobCheckpointingSettings to public getMaxConcurrentCheckpoints() : int from class org.apache.flink.runtime.jobgraph.tasks.CheckpointCoordinatorConfiguration | From | To | |
| Move Method public getCheckpointTimeout() : long from class org.apache.flink.runtime.jobgraph.tasks.JobCheckpointingSettings to public getCheckpointTimeout() : long from class org.apache.flink.runtime.jobgraph.tasks.CheckpointCoordinatorConfiguration | From | To | |
| Rename Variable | 4 | ||
| Rename Variable coord : CheckpointCoordinator to jobCheckpointingConfiguration : CheckpointCoordinatorConfiguration in method public handleRequest(pathParams Map<String,String>, queryParams Map<String,String>, jobManagerGateway JobManagerGateway) : CompletableFuture<FullHttpResponse> in class org.apache.flink.runtime.rest.handler.legacy.JobCancellationWithSavepointHandlers.TriggerHandler | From | To | |
| Rename Variable settings : JobCheckpointingSettings to chkConfig : CheckpointCoordinatorConfiguration in method private createGraphAndSettings(externalized boolean, exactlyOnce boolean) : GraphAndSettings in class org.apache.flink.runtime.rest.handler.legacy.checkpoints.CheckpointConfigHandlerTest | From | To | |
| Rename Variable settings : JobCheckpointingSettings to chkConfig : CheckpointCoordinatorConfiguration in method public testArchiver() : void in class org.apache.flink.runtime.rest.handler.legacy.checkpoints.CheckpointConfigHandlerTest | From | To | |
| Rename Variable settings : JobCheckpointingSettings to chkConfig : CheckpointCoordinatorConfiguration in method public testSimpleConfig() : void in class org.apache.flink.runtime.rest.handler.legacy.checkpoints.CheckpointConfigHandlerTest | From | To | |
| Change Return Type | 3 | ||
| Change Return Type ExternalizedCheckpointSettings to CheckpointCoordinatorConfiguration in method public getCheckpointCoordinatorConfiguration() : CheckpointCoordinatorConfiguration in class org.apache.flink.runtime.jobgraph.tasks.JobCheckpointingSettings | From | To | |
| Change Return Type JobCheckpointingSettings to CheckpointCoordinatorConfiguration in method public getCheckpointCoordinatorConfiguration() : CheckpointCoordinatorConfiguration in class org.apache.flink.runtime.executiongraph.AccessExecutionGraph | From | To | |
| Change Return Type JobCheckpointingSettings to CheckpointCoordinatorConfiguration in method public getCheckpointCoordinatorConfiguration() : CheckpointCoordinatorConfiguration in class org.apache.flink.runtime.executiongraph.ExecutionGraph | From | To | |
| Move Attribute | 6 | ||
| Move Attribute private checkpointInterval : long from class org.apache.flink.runtime.jobgraph.tasks.JobCheckpointingSettings to private checkpointInterval : long from class org.apache.flink.runtime.jobgraph.tasks.CheckpointCoordinatorConfiguration | From | To | |
| Move Attribute private externalizedCheckpointSettings : ExternalizedCheckpointSettings from class org.apache.flink.runtime.jobgraph.tasks.JobCheckpointingSettings to private externalizedCheckpointSettings : ExternalizedCheckpointSettings from class org.apache.flink.runtime.jobgraph.tasks.CheckpointCoordinatorConfiguration | From | To | |
| Move Attribute private minPauseBetweenCheckpoints : long from class org.apache.flink.runtime.jobgraph.tasks.JobCheckpointingSettings to private minPauseBetweenCheckpoints : long from class org.apache.flink.runtime.jobgraph.tasks.CheckpointCoordinatorConfiguration | From | To | |
| Move Attribute private checkpointTimeout : long from class org.apache.flink.runtime.jobgraph.tasks.JobCheckpointingSettings to private checkpointTimeout : long from class org.apache.flink.runtime.jobgraph.tasks.CheckpointCoordinatorConfiguration | From | To | |
| Move Attribute private isExactlyOnce : boolean from class org.apache.flink.runtime.jobgraph.tasks.JobCheckpointingSettings to private isExactlyOnce : boolean from class org.apache.flink.runtime.jobgraph.tasks.CheckpointCoordinatorConfiguration | From | To | |
| Move Attribute private maxConcurrentCheckpoints : int from class org.apache.flink.runtime.jobgraph.tasks.JobCheckpointingSettings to private maxConcurrentCheckpoints : int from class org.apache.flink.runtime.jobgraph.tasks.CheckpointCoordinatorConfiguration | From | To | |
| Extract Class | 1 | ||
| Extract Class org.apache.flink.runtime.jobgraph.tasks.CheckpointCoordinatorConfiguration from class org.apache.flink.runtime.jobgraph.tasks.JobCheckpointingSettings | From | To | |
| Rename Attribute | 4 | ||
| Rename Attribute jobCheckpointingSettings : JobCheckpointingSettings to jobCheckpointingConfiguration : CheckpointCoordinatorConfiguration in class org.apache.flink.runtime.executiongraph.ArchivedExecutionGraph | From | To | |
| Rename Attribute snapshottingSettings : JobCheckpointingSettings to jobCheckpointingConfiguration : CheckpointCoordinatorConfiguration in class org.apache.flink.runtime.rest.handler.legacy.checkpoints.CheckpointConfigHandlerTest.GraphAndSettings | From | To | |
| Rename Attribute jobCheckpointingSettings : JobCheckpointingSettings to jobCheckpointingConfiguration : CheckpointCoordinatorConfiguration in class org.apache.flink.runtime.checkpoint.CheckpointStatsTracker | From | To | |
| Rename Attribute minPauseBetweenCheckpoints : long to checkpointCoordinatorConfiguration : CheckpointCoordinatorConfiguration in class org.apache.flink.runtime.jobgraph.tasks.JobCheckpointingSettings | From | To | |
| Change Variable Type | 4 | ||
| Change Variable Type settings : JobCheckpointingSettings to chkConfig : CheckpointCoordinatorConfiguration in method public testSimpleConfig() : void in class org.apache.flink.runtime.rest.handler.legacy.checkpoints.CheckpointConfigHandlerTest | From | To | |
| Change Variable Type coord : CheckpointCoordinator to jobCheckpointingConfiguration : CheckpointCoordinatorConfiguration in method public handleRequest(pathParams Map<String,String>, queryParams Map<String,String>, jobManagerGateway JobManagerGateway) : CompletableFuture<FullHttpResponse> in class org.apache.flink.runtime.rest.handler.legacy.JobCancellationWithSavepointHandlers.TriggerHandler | From | To | |
| Change Variable Type settings : JobCheckpointingSettings to chkConfig : CheckpointCoordinatorConfiguration in method public testArchiver() : void in class org.apache.flink.runtime.rest.handler.legacy.checkpoints.CheckpointConfigHandlerTest | From | To | |
| Change Variable Type settings : JobCheckpointingSettings to chkConfig : CheckpointCoordinatorConfiguration in method private createGraphAndSettings(externalized boolean, exactlyOnce boolean) : GraphAndSettings in class org.apache.flink.runtime.rest.handler.legacy.checkpoints.CheckpointConfigHandlerTest | From | To | |
| Change Attribute Type | 4 | ||
| Change Attribute Type jobCheckpointingSettings : JobCheckpointingSettings to jobCheckpointingConfiguration : CheckpointCoordinatorConfiguration in class org.apache.flink.runtime.checkpoint.CheckpointStatsTracker | From | To | |
| Change Attribute Type minPauseBetweenCheckpoints : long to checkpointCoordinatorConfiguration : CheckpointCoordinatorConfiguration in class org.apache.flink.runtime.jobgraph.tasks.JobCheckpointingSettings | From | To | |
| Change Attribute Type jobCheckpointingSettings : JobCheckpointingSettings to jobCheckpointingConfiguration : CheckpointCoordinatorConfiguration in class org.apache.flink.runtime.executiongraph.ArchivedExecutionGraph | From | To | |
| Change Attribute Type snapshottingSettings : JobCheckpointingSettings to jobCheckpointingConfiguration : CheckpointCoordinatorConfiguration in class org.apache.flink.runtime.rest.handler.legacy.checkpoints.CheckpointConfigHandlerTest.GraphAndSettings | From | To | |
| Rename Parameter | 3 | ||
| Rename Parameter snapshottingSettings : JobCheckpointingSettings to jobCheckpointingConfiguration : CheckpointCoordinatorConfiguration in method public GraphAndSettings(graph AccessExecutionGraph, jobCheckpointingConfiguration CheckpointCoordinatorConfiguration, externalizedSettings ExternalizedCheckpointSettings) in class org.apache.flink.runtime.rest.handler.legacy.checkpoints.CheckpointConfigHandlerTest.GraphAndSettings | From | To | |
| Rename Parameter jobCheckpointingSettings : JobCheckpointingSettings to jobCheckpointingConfiguration : CheckpointCoordinatorConfiguration in method public ArchivedExecutionGraph(jobID JobID, jobName String, tasks Map<JobVertexID,ArchivedExecutionJobVertex>, verticesInCreationOrder List<ArchivedExecutionJobVertex>, stateTimestamps long[], state JobStatus, failureCause ErrorInfo, jsonPlan String, archivedUserAccumulators StringifiedAccumulatorResult[], serializedUserAccumulators Map<String,SerializedValue<Object>>, executionConfig ArchivedExecutionConfig, isStoppable boolean, jobCheckpointingConfiguration CheckpointCoordinatorConfiguration, checkpointStatsSnapshot CheckpointStatsSnapshot) in class org.apache.flink.runtime.executiongraph.ArchivedExecutionGraph | From | To | |
| Rename Parameter jobCheckpointingSettings : JobCheckpointingSettings to jobCheckpointingConfiguration : CheckpointCoordinatorConfiguration in method public CheckpointStatsTracker(numRememberedCheckpoints int, jobVertices List<ExecutionJobVertex>, jobCheckpointingConfiguration CheckpointCoordinatorConfiguration, metricGroup MetricGroup) in class org.apache.flink.runtime.checkpoint.CheckpointStatsTracker | From | To |