a552d6746636e26c634c86d6a11732ea9d2f239e
Files Diff
- Added: 7
- Removed: 0
- Renamed: 0
- Modified: 36
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Method | 3 | ||
| Rename Method private writeResponse(checkpoint AbstractCheckpointStats, vertexId JobVertexID) : String renamed to private createSubtaskCheckpointDetailsJson(checkpoint AbstractCheckpointStats, taskStats TaskStateStats) : String in class org.apache.flink.runtime.webmonitor.handlers.checkpoints.CheckpointStatsDetailsSubtasksHandler | From | To | |
| Rename Method private generateSingleJobDetails(details JobDetails, gen JsonGenerator, now long) : void renamed to public writeJobDetailOverviewAsJson(details JobDetails, gen JsonGenerator, now long) : void in class org.apache.flink.runtime.webmonitor.handlers.CurrentJobsOverviewHandler | From | To | |
| Rename Method private writeResponse(checkpoint AbstractCheckpointStats) : String renamed to public createCheckpointDetailsJson(checkpoint AbstractCheckpointStats) : String in class org.apache.flink.runtime.webmonitor.handlers.checkpoints.CheckpointStatsDetailsHandler | From | To | |
| Change Parameter Type | 1 | ||
| Change Parameter Type vertexId : JobVertexID to taskStats : TaskStateStats in method private createSubtaskCheckpointDetailsJson(checkpoint AbstractCheckpointStats, taskStats TaskStateStats) : String in class org.apache.flink.runtime.webmonitor.handlers.checkpoints.CheckpointStatsDetailsSubtasksHandler | From | To | |
| Rename Variable | 1 | ||
| Rename Variable timeZome : TimeZone to timeZone : TimeZone in method public createConfigJson(refreshInterval long) : String in class org.apache.flink.runtime.webmonitor.handlers.DashboardConfigHandler | From | To | |
| Change Variable Type | 1 | ||
| Change Variable Type entry : Entry<String,List<AccessExecutionVertex>> to entry : Map.Entry<String,List<AccessExecutionVertex>> in method public createVertexDetailsByTaskManagerJson(jobVertex AccessExecutionJobVertex, jobID String, fetcher MetricFetcher) : String in class org.apache.flink.runtime.webmonitor.handlers.JobVertexTaskManagersHandler | From | To | |
| Extract Method | 14 | ||
| Extract Method public createJobExceptionsJson(graph AccessExecutionGraph) : String extracted from public handleRequest(graph AccessExecutionGraph, params Map<String,String>) : String in class org.apache.flink.runtime.webmonitor.handlers.JobExceptionsHandler | From | To | |
| Extract Method public createVertexDetailsJson(jobVertex AccessExecutionJobVertex, jobID String, fetcher MetricFetcher) : String extracted from public handleRequest(jobVertex AccessExecutionJobVertex, params Map<String,String>) : String in class org.apache.flink.runtime.webmonitor.handlers.JobVertexDetailsHandler | From | To | |
| Extract Method public createSubtaskTimesJson(jobVertex AccessExecutionJobVertex) : String extracted from public handleRequest(jobVertex AccessExecutionJobVertex, params Map<String,String>) : String in class org.apache.flink.runtime.webmonitor.handlers.SubtasksTimesHandler | From | To | |
| Extract Method public createAttemptDetailsJson(execAttempt AccessExecution, jobID String, vertexID String, fetcher MetricFetcher) : String extracted from public handleRequest(execAttempt AccessExecution, params Map<String,String>) : String in class org.apache.flink.runtime.webmonitor.handlers.SubtaskExecutionAttemptDetailsHandler | From | To | |
| Extract Method public createJobDetailsJson(graph AccessExecutionGraph, fetcher MetricFetcher) : String extracted from public handleRequest(graph AccessExecutionGraph, params Map<String,String>) : String in class org.apache.flink.runtime.webmonitor.handlers.JobDetailsHandler | From | To | |
| Extract Method public createConfigJson(refreshInterval long) : String extracted from public DashboardConfigHandler(refreshInterval long) in class org.apache.flink.runtime.webmonitor.handlers.DashboardConfigHandler | From | To | |
| Extract Method private createCheckpointConfigJson(graph AccessExecutionGraph) : String extracted from public handleRequest(graph AccessExecutionGraph, params Map<String,String>) : String in class org.apache.flink.runtime.webmonitor.handlers.checkpoints.CheckpointConfigHandler | From | To | |
| Extract Method public createJobAccumulatorsJson(graph AccessExecutionGraph) : String extracted from public handleRequest(graph AccessExecutionGraph, params Map<String,String>) : String in class org.apache.flink.runtime.webmonitor.handlers.JobAccumulatorsHandler | From | To | |
| Extract Method public createJobConfigJson(graph AccessExecutionGraph) : String extracted from public handleRequest(graph AccessExecutionGraph, params Map<String,String>) : String in class org.apache.flink.runtime.webmonitor.handlers.JobConfigHandler | From | To | |
| Extract Method public createVertexDetailsByTaskManagerJson(jobVertex AccessExecutionJobVertex, jobID String, fetcher MetricFetcher) : String extracted from public handleRequest(jobVertex AccessExecutionJobVertex, params Map<String,String>) : String in class org.apache.flink.runtime.webmonitor.handlers.JobVertexTaskManagersHandler | From | To | |
| Extract Method public createSubtasksAccumulatorsJson(jobVertex AccessExecutionJobVertex) : String extracted from public handleRequest(jobVertex AccessExecutionJobVertex, params Map<String,String>) : String in class org.apache.flink.runtime.webmonitor.handlers.SubtasksAllAccumulatorsHandler | From | To | |
| Extract Method public createVertexAccumulatorsJson(jobVertex AccessExecutionJobVertex) : String extracted from public handleRequest(jobVertex AccessExecutionJobVertex, params Map<String,String>) : String in class org.apache.flink.runtime.webmonitor.handlers.JobVertexAccumulatorsHandler | From | To | |
| Extract Method public createAttemptAccumulatorsJson(execAttempt AccessExecution) : String extracted from public handleRequest(execAttempt AccessExecution, params Map<String,String>) : String in class org.apache.flink.runtime.webmonitor.handlers.SubtaskExecutionAttemptAccumulatorsHandler | From | To | |
| Extract Method private createCheckpointStatsJson(graph AccessExecutionGraph) : String extracted from public handleRequest(graph AccessExecutionGraph, params Map<String,String>) : String in class org.apache.flink.runtime.webmonitor.handlers.checkpoints.CheckpointStatsHandler | From | To | |
| Rename Parameter | 1 | ||
| Rename Parameter vertexId : JobVertexID to taskStats : TaskStateStats in method private createSubtaskCheckpointDetailsJson(checkpoint AbstractCheckpointStats, taskStats TaskStateStats) : String in class org.apache.flink.runtime.webmonitor.handlers.checkpoints.CheckpointStatsDetailsSubtasksHandler | From | To |