ebc3bc1f9ce9dcbd69fedc2ec79ab03d94d99cef
Files Diff
- Added: 1
- Removed: 0
- Renamed: 0
- Modified: 6
Refactorings reported:
Refactoring Name | Occurences | ||
---|---|---|---|
Change Parameter Type | 3 | ||
Change Parameter Type messageHeaders : MessageHeaders<EmptyRequestBody,JobVertexAccumulatorsInfo,JobMessageParameters> to messageHeaders : MessageHeaders<EmptyRequestBody,JobVertexAccumulatorsInfo,JobVertexMessageParameters> in method public JobVertexAccumulatorsHandler(localRestAddress CompletableFuture<String>, leaderRetriever GatewayRetriever<? extends RestfulGateway>, timeout Time, messageHeaders MessageHeaders<EmptyRequestBody,JobVertexAccumulatorsInfo,JobVertexMessageParameters>, executionGraphCache ExecutionGraphCache, executor Executor) in class org.apache.flink.runtime.rest.handler.job.JobVertexAccumulatorsHandler | From | To | |
Change Parameter Type userAccumulatorList : List<UserAccumulator> to userAccumulatorList : Collection<UserAccumulator> in method public JobVertexAccumulatorsInfo(id String, userAccumulatorList Collection<UserAccumulator>) in class org.apache.flink.runtime.rest.messages.JobVertexAccumulatorsInfo | From | To | |
Change Parameter Type request : HandlerRequest<EmptyRequestBody,JobMessageParameters> to request : HandlerRequest<EmptyRequestBody,JobVertexMessageParameters> in method protected handleRequest(request HandlerRequest<EmptyRequestBody,JobVertexMessageParameters>, executionGraph AccessExecutionGraph) : JobVertexAccumulatorsInfo in class org.apache.flink.runtime.rest.handler.job.JobVertexAccumulatorsHandler | From | To | |
Change Return Type | 1 | ||
Change Return Type JobMessageParameters to JobVertexMessageParameters in method public getUnresolvedMessageParameters() : JobVertexMessageParameters in class org.apache.flink.runtime.rest.messages.JobVertexAccumulatorsHeaders | From | To | |
Rename Attribute | 1 | ||
Rename Attribute JOB_ID : String to KEY : String in class org.apache.flink.runtime.rest.messages.JobIDPathParameter | From | To | |
Change Variable Type | 1 | ||
Change Variable Type userAccumulatorList : List<JobVertexAccumulatorsInfo.UserAccumulator> to userAccumulatorList : ArrayList<JobVertexAccumulatorsInfo.UserAccumulator> in method protected handleRequest(request HandlerRequest<EmptyRequestBody,JobVertexMessageParameters>, executionGraph AccessExecutionGraph) : JobVertexAccumulatorsInfo in class org.apache.flink.runtime.rest.handler.job.JobVertexAccumulatorsHandler | From | To | |
Change Attribute Type | 1 | ||
Change Attribute Type userAccumulatorList : List<UserAccumulator> to userAccumulatorList : Collection<UserAccumulator> in class org.apache.flink.runtime.rest.messages.JobVertexAccumulatorsInfo | From | To |