acfeeaf5e337e56300d10a3a991e79edc827ac7a
Files Diff
- Added: 1
- Removed: 0
- Renamed: 0
- Modified: 34
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Change Parameter Type | 1 | ||
| Change Parameter Type latest : CompletedCheckpoint to taskStates : Map<JobVertexID,TaskState> in method public StateAssignmentOperation(logger Logger, tasks Map<JobVertexID,ExecutionJobVertex>, taskStates Map<JobVertexID,TaskState>, allowNonRestoredState boolean) in class org.apache.flink.runtime.checkpoint.StateAssignmentOperation | From | To | |
| Rename Variable | 2 | ||
| Rename Variable maxP : int to configuredMaxParallelism : int in method public ExecutionJobVertex(graph ExecutionGraph, jobVertex JobVertex, defaultParallelism int, timeout Time, createTimestamp long) in class org.apache.flink.runtime.executiongraph.ExecutionJobVertex | From | To | |
| Rename Variable maxParallelism : int to globalMaxParallelismFromConfig : int in method private transform(transform StreamTransformation<?>) : Collection<Integer> in class org.apache.flink.streaming.api.graph.StreamGraphGenerator | From | To | |
| Change Attribute Type | 1 | ||
| Change Attribute Type stateMonitor : SerializableObject to stateMonitor : Object in class org.apache.flink.runtime.executiongraph.ExecutionJobVertex | From | To | |
| Extract Method | 3 | ||
| Extract Method private assignTaskStatesToOperatorInstances(taskState TaskState, executionJobVertex ExecutionJobVertex) : void extracted from public assignStates() : boolean in class org.apache.flink.runtime.checkpoint.StateAssignmentOperation | From | To | |
| Extract Method private canBeParallel() : boolean extracted from public setParallelism(parallelism int) : SingleOutputStreamOperator<T> in class org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator | From | To | |
| Extract Method private checkParallelismPreconditions(taskState TaskState, executionJobVertex ExecutionJobVertex) : void extracted from public assignStates() : boolean in class org.apache.flink.runtime.checkpoint.StateAssignmentOperation | From | To | |
| Rename Parameter | 1 | ||
| Rename Parameter latest : CompletedCheckpoint to taskStates : Map<JobVertexID,TaskState> in method public StateAssignmentOperation(logger Logger, tasks Map<JobVertexID,ExecutionJobVertex>, taskStates Map<JobVertexID,TaskState>, allowNonRestoredState boolean) in class org.apache.flink.runtime.checkpoint.StateAssignmentOperation | From | To |