|
Change Parameter Type states : ArrayList<StateForTask> to taskGroupStates : Map<JobVertexID,TaskState> in method public TestCheckpoint(jobId JobID, checkpointId long, timestamp long, taskGroupStates Map<JobVertexID,TaskState>) in class org.apache.flink.runtime.checkpoint.CompletedCheckpointStoreTest.TestCheckpoint |
From |
To |
|
Change Parameter Type states : ArrayList<StateForTask> to taskStates : Map<JobVertexID,TaskState> in method public CompletedCheckpoint(job JobID, checkpointID long, timestamp long, completionTimestamp long, taskStates Map<JobVertexID,TaskState>) in class org.apache.flink.runtime.checkpoint.CompletedCheckpoint |
From |
To |
|
Rename Variable vertex : ExecutionJobVertex to executionJobVertex : ExecutionJobVertex in method public restoreLatestCheckpointedState(tasks Map<JobVertexID,ExecutionJobVertex>, errorIfNoCheckpoint boolean, allOrNothingState boolean) : boolean in class org.apache.flink.runtime.checkpoint.CheckpointCoordinator |
From |
To |
|
Rename Variable exec : Execution to currentExecutionAttempt : Execution in method public restoreSavepoint(tasks Map<JobVertexID,ExecutionJobVertex>, savepointPath String) : void in class org.apache.flink.runtime.checkpoint.SavepointCoordinator |
From |
To |
|
Rename Variable state : StateForTask to taskState : TaskState in method private dispose(userClassLoader ClassLoader, releaseState boolean) : void in class org.apache.flink.runtime.checkpoint.PendingCheckpoint |
From |
To |
|
Rename Variable expectedOperatorId : JobVertexID to jobVertexID : JobVertexID in method private verifyCompletedCheckpoint(checkpoint CompletedCheckpoint, expectedJobId JobID, expectedCheckpointId long, expectedTimestamp long, expectedVertices ExecutionVertex[]) : void in class org.apache.flink.runtime.checkpoint.SavepointCoordinatorTest |
From |
To |
|
Rename Variable taskStates : ArrayList<StateForTask> to taskGroupStates : Map<JobVertexID,TaskState> in method protected createCheckpoint(id int, numberOfStates int) : TestCheckpoint in class org.apache.flink.runtime.checkpoint.CompletedCheckpointStoreTest |
From |
To |
|
Rename Variable opId : JobVertexID to jobVertexID : JobVertexID in method public onCompletedCheckpoint(checkpoint CompletedCheckpoint) : void in class org.apache.flink.runtime.checkpoint.stats.SimpleCheckpointStatsTracker |
From |
To |
|
Rename Variable exec : Execution to currentExecutionAttempt : Execution in method public restoreLatestCheckpointedState(tasks Map<JobVertexID,ExecutionJobVertex>, errorIfNoCheckpoint boolean, allOrNothingState boolean) : boolean in class org.apache.flink.runtime.checkpoint.CheckpointCoordinator |
From |
To |
|
Rename Variable states : ArrayList<StateForTask> to taskGroupStates : Map<JobVertexID,TaskState> in method private generateRandomCheckpoints(numCheckpoints int) : CompletedCheckpoint[] in class org.apache.flink.runtime.checkpoint.stats.SimpleCheckpointStatsTrackerTest |
From |
To |
|
Change Variable Type state : StateForTask to state : TaskState in method public discard(userClassLoader ClassLoader) : void in class org.apache.flink.runtime.checkpoint.CompletedCheckpoint |
From |
To |
|
Change Variable Type state : StateForTask to taskState : TaskState in method private dispose(userClassLoader ClassLoader, releaseState boolean) : void in class org.apache.flink.runtime.checkpoint.PendingCheckpoint |
From |
To |
|
Change Variable Type states : ArrayList<StateForTask> to taskGroupStates : Map<JobVertexID,TaskState> in method private generateRandomCheckpoints(numCheckpoints int) : CompletedCheckpoint[] in class org.apache.flink.runtime.checkpoint.stats.SimpleCheckpointStatsTrackerTest |
From |
To |
|
Change Variable Type taskStates : ArrayList<StateForTask> to taskGroupStates : Map<JobVertexID,TaskState> in method protected createCheckpoint(id int, numberOfStates int) : TestCheckpoint in class org.apache.flink.runtime.checkpoint.CompletedCheckpointStoreTest |
From |
To |
|
Change Variable Type that : StateForTask to that : SubtaskState in method public equals(o Object) : boolean in class org.apache.flink.runtime.checkpoint.SubtaskState |
From |
To |
|
Rename Parameter states : ArrayList<StateForTask> to taskGroupStates : Map<JobVertexID,TaskState> in method public TestCheckpoint(jobId JobID, checkpointId long, timestamp long, taskGroupStates Map<JobVertexID,TaskState>) in class org.apache.flink.runtime.checkpoint.CompletedCheckpointStoreTest.TestCheckpoint |
From |
To |
|
Rename Parameter states : ArrayList<StateForTask> to taskStates : Map<JobVertexID,TaskState> in method public CompletedCheckpoint(job JobID, checkpointID long, timestamp long, completionTimestamp long, taskStates Map<JobVertexID,TaskState>) in class org.apache.flink.runtime.checkpoint.CompletedCheckpoint |
From |
To |