c1280a5056196e2c20e50dc6c3631ca93c877e58
Files Diff
- Added: 4
- Removed: 1
- Renamed: 0
- Modified: 22
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Change Parameter Type | 3 | ||
| Change Parameter Type endTimestamp : long to endTimestamp : Long in method public JobVertexBackPressureInfo(status VertexBackPressureStatus, backpressureLevel VertexBackPressureLevel, endTimestamp Long, subtasks List<SubtaskBackPressureInfo>) in class org.apache.flink.runtime.rest.messages.JobVertexBackPressureInfo | From | To | |
| Change Parameter Type leaderRetriever : GatewayRetriever<DispatcherGateway> to leaderRetriever : GatewayRetriever<? extends RestfulGateway> in method public JobVertexBackPressureHandler(localRestAddress CompletableFuture<String>, leaderRetriever GatewayRetriever<? extends RestfulGateway>, timeout Time, responseHeaders Map<String,String>, messageHeaders MessageHeaders<EmptyRequestBody,JobVertexBackPressureInfo,JobVertexMessageParameters>) in class org.apache.flink.runtime.rest.handler.job.JobVertexBackPressureHandler | From | To | |
| Change Parameter Type gateway : DispatcherGateway to gateway : RestfulGateway in method protected handleRequest(request HandlerRequest<EmptyRequestBody,JobVertexMessageParameters>, gateway RestfulGateway) : CompletableFuture<JobVertexBackPressureInfo> in class org.apache.flink.runtime.rest.handler.job.JobVertexBackPressureHandler | From | To | |
| Rename Variable | 2 | ||
| Rename Variable jobVertexID : JobVertexID to jobVertexId : JobVertexID in method protected handleRequest(request HandlerRequest<EmptyRequestBody,JobVertexMessageParameters>, gateway RestfulGateway) : CompletableFuture<JobVertexBackPressureInfo> in class org.apache.flink.runtime.rest.handler.job.JobVertexBackPressureHandler | From | To | |
| Rename Variable buffer : Buffer to bufferBuilder : BufferBuilder in method public invoke() : void in class org.apache.flink.runtime.rest.handler.legacy.backpressure.BackPressureStatsTrackerITCase.BackPressuredTask | From | To | |
| Change Variable Type | 1 | ||
| Change Variable Type buffer : Buffer to bufferBuilder : BufferBuilder in method public invoke() : void in class org.apache.flink.runtime.rest.handler.legacy.backpressure.BackPressureStatsTrackerITCase.BackPressuredTask | From | To | |
| Extract Variable | 1 | ||
| Extract Variable stats : OperatorBackPressureStats in method public getOperatorBackPressureStats(vertex ExecutionJobVertex) : Optional<OperatorBackPressureStats> from class org.apache.flink.runtime.rest.handler.legacy.backpressure.BackPressureStatsTracker | From | To | |
| Change Attribute Type | 1 | ||
| Change Attribute Type endTimestamp : long to endTimestamp : Long in class org.apache.flink.runtime.rest.messages.JobVertexBackPressureInfo | From | To | |
| Extract Method | 1 | ||
| Extract Method package triggerStackTraceSampleInternal(vertex ExecutionJobVertex) : boolean extracted from public triggerStackTraceSample(vertex ExecutionJobVertex) : boolean in class org.apache.flink.runtime.rest.handler.legacy.backpressure.BackPressureStatsTracker | From | To |