flink 8330539e4770ce36576149410d66122a81daa03f

8330539e4770ce36576149410d66122a81daa03f

Files Diff

Added: 0
Removed: 0
Renamed: 0
Modified: 5

Link to commit

Dependency Action

Refactorings reported:

	Refactoring Name	Occurences
	Change Parameter Type	2
	Change Parameter Type tasksToWaitFor : ExecutionVertex[] to tasksToWaitFor : List<ExecutionJobVertex> in method private verifySubtaskStats(tracker CheckpointStatsTracker, tasksToWaitFor List<ExecutionJobVertex>, checkpoint CompletedCheckpoint) : void in class org.apache.flink.runtime.checkpoint.stats.SimpleCheckpointStatsTrackerTest	From	To
	Change Parameter Type tasksToWaitFor : ExecutionVertex[] to tasksToWaitFor : List<ExecutionJobVertex> in method public SimpleCheckpointStatsTracker(historySize int, tasksToWaitFor List<ExecutionJobVertex>) in class org.apache.flink.runtime.checkpoint.stats.SimpleCheckpointStatsTracker	From	To
	Rename Variable	1
	Rename Variable operatorId : JobVertexID to vertexId : JobVertexID in method private createTasksToWaitFor(checkpoint CompletedCheckpoint) : List<ExecutionJobVertex> in class org.apache.flink.runtime.checkpoint.stats.SimpleCheckpointStatsTrackerTest	From	To
	Change Return Type	1
	Change Return Type ExecutionVertex[] to List<ExecutionJobVertex> in method private createTasksToWaitFor(checkpoint CompletedCheckpoint) : List<ExecutionJobVertex> in class org.apache.flink.runtime.checkpoint.stats.SimpleCheckpointStatsTrackerTest	From	To
	Change Variable Type	6
	Change Variable Type tasksToWaitFor : ExecutionVertex[] to tasksToWaitFor : List<ExecutionJobVertex> in method public testRandomStats() : void in class org.apache.flink.runtime.checkpoint.stats.SimpleCheckpointStatsTrackerTest	From	To
	Change Variable Type tasksToWaitFor : ExecutionVertex[] to tasksToWaitFor : List<ExecutionJobVertex> in method public testOperatorStateCachedClearedOnNewCheckpoint() : void in class org.apache.flink.runtime.checkpoint.stats.SimpleCheckpointStatsTrackerTest	From	To
	Change Variable Type tasksToWaitFor : ExecutionVertex[] to tasksToWaitFor : List<ExecutionJobVertex> in method public testCompletedCheckpointReordering() : void in class org.apache.flink.runtime.checkpoint.stats.SimpleCheckpointStatsTrackerTest	From	To
	Change Variable Type vertex : ExecutionVertex to vertex : ExecutionJobVertex in method public SimpleCheckpointStatsTracker(historySize int, tasksToWaitFor List<ExecutionJobVertex>) in class org.apache.flink.runtime.checkpoint.stats.SimpleCheckpointStatsTracker	From	To
	Change Variable Type tasksToWaitFor : ExecutionVertex[] to tasksToWaitFor : List<ExecutionJobVertex> in method public testIllegalOperatorId() : void in class org.apache.flink.runtime.checkpoint.stats.SimpleCheckpointStatsTrackerTest	From	To
	Change Variable Type vertex : ExecutionVertex to vertex : ExecutionJobVertex in method private verifySubtaskStats(tracker CheckpointStatsTracker, tasksToWaitFor List<ExecutionJobVertex>, checkpoint CompletedCheckpoint) : void in class org.apache.flink.runtime.checkpoint.stats.SimpleCheckpointStatsTrackerTest	From	To