821da81fe6bee4c5a33be19c08064491fd6280de
Files Diff
- Added: 0
- Removed: 0
- Renamed: 0
- Modified: 4
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Change Return Type | 1 | ||
| Change Return Type Map<ExecutionAttemptID,Execution> to Tuple2<ExecutionGraph,Map<ExecutionAttemptID,Execution>> in method private setupExecution(v1 JobVertex, dop1 int, v2 JobVertex, dop2 int) : Tuple2<ExecutionGraph,Map<ExecutionAttemptID,Execution>> in class org.apache.flink.runtime.executiongraph.ExecutionGraphDeploymentTest | From | To | |
| Extract Method | 4 | ||
| Extract Method private deserializeAccumulators(state TaskExecutionState) : Map<String,Accumulator<?,?>> extracted from public updateState(state TaskExecutionState) : boolean in class org.apache.flink.runtime.executiongraph.ExecutionGraph | From | To | |
| Extract Method private updateAccumulatorsAndMetrics(userAccumulators Map<String,Accumulator<?,?>>, metrics IOMetrics) : void extracted from package markFinished(userAccumulators Map<String,Accumulator<?,?>>, metrics IOMetrics) : void in class org.apache.flink.runtime.executiongraph.Execution | From | To | |
| Extract Method package cancelingComplete(userAccumulators Map<String,Accumulator<?,?>>, metrics IOMetrics) : void extracted from package cancelingComplete() : void in class org.apache.flink.runtime.executiongraph.Execution | From | To | |
| Extract Method private processFail(t Throwable, isCallback boolean, userAccumulators Map<String,Accumulator<?,?>>, metrics IOMetrics) : boolean extracted from private processFail(t Throwable, isCallback boolean) : boolean in class org.apache.flink.runtime.executiongraph.Execution | From | To |