bb06ba954b8c65407039edd239da973d8e97e75b
Files Diff
- Added: 0
- Removed: 0
- Renamed: 0
- Modified: 15
Refactorings reported:
Refactoring Name | Occurences | ||
---|---|---|---|
Extract Method | 13 | ||
Extract Method private createJobPlanInfo(executionGraph AccessExecutionGraph) : JobPlanInfo extracted from protected handleRequest(request HandlerRequest<EmptyRequestBody,JobMessageParameters>, executionGraph AccessExecutionGraph) : JobPlanInfo in class org.apache.flink.runtime.rest.handler.job.JobPlanHandler | From | To | |
Extract Method private createJobVertexDetailsInfo(jobVertex AccessExecutionJobVertex, jobID JobID, metricFetcher MetricFetcher<?>) : JobVertexDetailsInfo extracted from protected handleRequest(request HandlerRequest<EmptyRequestBody,JobVertexMessageParameters>, executionGraph AccessExecutionGraph) : JobVertexDetailsInfo in class org.apache.flink.runtime.rest.handler.job.JobVertexDetailsHandler | From | To | |
Extract Method private createCheckpointDetails(checkpointStats AbstractCheckpointStats, taskStatistics TaskStateStats) : TaskCheckpointStatisticsWithSubtaskDetails extracted from protected handleCheckpointRequest(request HandlerRequest<EmptyRequestBody,TaskCheckpointMessageParameters>, checkpointStats AbstractCheckpointStats) : TaskCheckpointStatisticsWithSubtaskDetails in class org.apache.flink.runtime.rest.handler.job.checkpoints.TaskCheckpointStatisticDetailsHandler | From | To | |
Extract Method private createJobVertexTaskManagersInfo(jobVertex AccessExecutionJobVertex, jobID JobID, metricFetcher MetricFetcher<?>) : JobVertexTaskManagersInfo extracted from protected handleRequest(request HandlerRequest<EmptyRequestBody,JobVertexMessageParameters>, executionGraph AccessExecutionGraph) : JobVertexTaskManagersInfo in class org.apache.flink.runtime.rest.handler.job.JobVertexTaskManagersHandler | From | To | |
Extract Method private createJobAccumulatorsInfo(graph AccessExecutionGraph, includeSerializedValue boolean) : JobAccumulatorsInfo extracted from protected handleRequest(request HandlerRequest<EmptyRequestBody,JobAccumulatorsMessageParameters>, graph AccessExecutionGraph) : JobAccumulatorsInfo in class org.apache.flink.runtime.rest.handler.job.JobAccumulatorsHandler | From | To | |
Extract Method private createSubtaskTimesInfo(jobVertex AccessExecutionJobVertex) : SubtasksTimesInfo extracted from protected handleRequest(request HandlerRequest<EmptyRequestBody,JobVertexMessageParameters>, jobVertex AccessExecutionJobVertex) : SubtasksTimesInfo in class org.apache.flink.runtime.rest.handler.job.SubtasksTimesHandler | From | To | |
Extract Method private createDetailsInfo(execution AccessExecution, jobID JobID, jobVertexID JobVertexID, metricFetcher MetricFetcher<?>) : SubtaskExecutionAttemptDetailsInfo extracted from protected handleRequest(request HandlerRequest<EmptyRequestBody,SubtaskAttemptMessageParameters>, execution AccessExecution) : SubtaskExecutionAttemptDetailsInfo in class org.apache.flink.runtime.rest.handler.job.SubtaskExecutionAttemptDetailsHandler | From | To | |
Extract Method private createJobExceptionsInfo(executionGraph AccessExecutionGraph) : JobExceptionsInfo extracted from protected handleRequest(request HandlerRequest<EmptyRequestBody,JobMessageParameters>, executionGraph AccessExecutionGraph) : JobExceptionsInfo in class org.apache.flink.runtime.rest.handler.job.JobExceptionsHandler | From | To | |
Extract Method private createAccumulatorInfo(execution AccessExecution) : SubtaskExecutionAttemptAccumulatorsInfo extracted from protected handleRequest(request HandlerRequest<EmptyRequestBody,SubtaskAttemptMessageParameters>, execution AccessExecution) : SubtaskExecutionAttemptAccumulatorsInfo in class org.apache.flink.runtime.rest.handler.job.SubtaskExecutionAttemptAccumulatorsHandler | From | To | |
Extract Method private createCheckpointingStatistics(executionGraph AccessExecutionGraph) : CheckpointingStatistics extracted from protected handleRequest(request HandlerRequest<EmptyRequestBody,JobMessageParameters>, executionGraph AccessExecutionGraph) : CheckpointingStatistics in class org.apache.flink.runtime.rest.handler.job.checkpoints.CheckpointingStatisticsHandler | From | To | |
Extract Method private createJobDetailsInfo(executionGraph AccessExecutionGraph, metricFetcher MetricFetcher<?>) : JobDetailsInfo extracted from protected handleRequest(request HandlerRequest<EmptyRequestBody,JobMessageParameters>, executionGraph AccessExecutionGraph) : JobDetailsInfo in class org.apache.flink.runtime.rest.handler.job.JobDetailsHandler | From | To | |
Extract Method private createJobConfigInfo(executionGraph AccessExecutionGraph) : JobConfigInfo extracted from protected handleRequest(request HandlerRequest<EmptyRequestBody,JobMessageParameters>, executionGraph AccessExecutionGraph) : JobConfigInfo in class org.apache.flink.runtime.rest.handler.job.JobConfigHandler | From | To | |
Extract Method private createCheckpointConfigInfo(executionGraph AccessExecutionGraph) : CheckpointConfigInfo extracted from protected handleRequest(request HandlerRequest<EmptyRequestBody,JobMessageParameters>, executionGraph AccessExecutionGraph) : CheckpointConfigInfo in class org.apache.flink.runtime.rest.handler.job.checkpoints.CheckpointConfigHandler | From | To |