|
Rename Method public disposeState(path String) : void renamed to public disposeSavepoint(path String, classLoader ClassLoader) : void in class org.apache.flink.runtime.checkpoint.savepoint.SavepointStore |
From |
To |
|
Rename Method public getState(path String) : T renamed to public loadSavepoint(path String) : Savepoint in class org.apache.flink.runtime.checkpoint.savepoint.SavepointStore |
From |
To |
|
Rename Method public createCompletedCheckpoints(jobId JobID, userClassLoader ClassLoader) : CompletedCheckpointStore renamed to public createCheckpointStore(jobId JobID, userClassLoader ClassLoader) : CompletedCheckpointStore in class org.apache.flink.runtime.jobmanager.JobManagerHARecoveryTest.MyCheckpointRecoveryFactory |
From |
To |
|
Rename Method public createCompletedCheckpoints(jobId JobID, userClassLoader ClassLoader) : CompletedCheckpointStore renamed to public createCheckpointStore(jobId JobID, userClassLoader ClassLoader) : CompletedCheckpointStore in class org.apache.flink.runtime.checkpoint.StandaloneCheckpointRecoveryFactory |
From |
To |
|
Rename Method public disposeState(path String) : void renamed to public disposeSavepoint(path String, classLoader ClassLoader) : void in class org.apache.flink.runtime.checkpoint.savepoint.HeapSavepointStore |
From |
To |
|
Rename Method public toCompletedCheckpoint() : CompletedCheckpoint renamed to public finalizeCheckpoint() : CompletedCheckpoint in class org.apache.flink.runtime.checkpoint.PendingCheckpoint |
From |
To |
|
Rename Method public getState(path String) : T renamed to public loadSavepoint(path String) : Savepoint in class org.apache.flink.runtime.checkpoint.savepoint.HeapSavepointStore |
From |
To |
|
Rename Method public createCompletedCheckpoints(jobId JobID, userClassLoader ClassLoader) : CompletedCheckpointStore renamed to public createCheckpointStore(jobId JobID, userClassLoader ClassLoader) : CompletedCheckpointStore in class org.apache.flink.runtime.checkpoint.ZooKeeperCheckpointRecoveryFactory |
From |
To |
|
Rename Method public createCompletedCheckpoints(jobId JobID, userClassLoader ClassLoader) : CompletedCheckpointStore renamed to public createCheckpointStore(jobId JobID, userClassLoader ClassLoader) : CompletedCheckpointStore in class org.apache.flink.runtime.checkpoint.CheckpointRecoveryFactory |
From |
To |
|
Change Parameter Type savepointStore : StateStore<CompletedCheckpoint> to savepointStore : SavepointStore in method public SavepointCoordinator(jobId JobID, baseInterval long, checkpointTimeout long, numberKeyGroups int, tasksToTrigger ExecutionVertex[], tasksToWaitFor ExecutionVertex[], tasksToCommitTo ExecutionVertex[], userClassLoader ClassLoader, checkpointIDCounter CheckpointIDCounter, savepointStore SavepointStore, statsTracker CheckpointStatsTracker) in class org.apache.flink.runtime.checkpoint.savepoint.SavepointCoordinator |
From |
To |
|
Change Parameter Type savepointStore : StateStore<CompletedCheckpoint> to savepointStore : SavepointStore in method public enableSnapshotCheckpointing(interval long, checkpointTimeout long, minPauseBetweenCheckpoints long, maxConcurrentCheckpoints int, numberKeyGroups int, verticesToTrigger List<ExecutionJobVertex>, verticesToWaitFor List<ExecutionJobVertex>, verticesToCommitTo List<ExecutionJobVertex>, actorSystem ActorSystem, leaderSessionID UUID, checkpointIDCounter CheckpointIDCounter, checkpointStore CompletedCheckpointStore, recoveryMode RecoveryMode, savepointStore SavepointStore, statsTracker CheckpointStatsTracker) : void in class org.apache.flink.runtime.executiongraph.ExecutionGraph |
From |
To |
|
Change Parameter Type savepointStore : StateStore<CompletedCheckpoint> to savepointStore : SavepointStore in method private createSavepointCoordinator(jobId JobID, checkpointTimeout long, triggerVertices ExecutionVertex[], ackVertices ExecutionVertex[], commitVertices ExecutionVertex[], checkpointIdCounter CheckpointIDCounter, savepointStore SavepointStore) : SavepointCoordinator in class org.apache.flink.runtime.checkpoint.savepoint.SavepointCoordinatorTest |
From |
To |
|
Change Variable Type savepoint : CompletedCheckpoint to savepoint : SavepointV0 in method public testTriggerSavepointAndResume() : void in class org.apache.flink.test.checkpointing.SavepointITCase |
From |
To |
|
Change Variable Type checkpoint : TestCheckpoint to checkpoint : TestCompletedCheckpoint in method public testShutdownDiscardsCheckpoints() : void in class org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStoreTest |
From |
To |
|
Change Variable Type savepointStore : HeapStateStore<CompletedCheckpoint> to savepointStore : SavepointStore in method public testTriggerAndDeclineCheckpointSimple() : void in class org.apache.flink.runtime.checkpoint.savepoint.SavepointCoordinatorTest |
From |
To |
|
Change Variable Type state : T to savepoint : Savepoint in method public disposeSavepoint(path String, classLoader ClassLoader) : void in class org.apache.flink.runtime.checkpoint.savepoint.HeapSavepointStore |
From |
To |
|
Change Variable Type savepoint : CompletedCheckpoint to savepoint : Savepoint in method public testSimpleTriggerSavepoint() : void in class org.apache.flink.runtime.checkpoint.savepoint.SavepointCoordinatorTest |
From |
To |
|
Change Variable Type checkpoint : TestCheckpoint to checkpoint : TestCompletedCheckpoint in method public testGetAllCheckpoints() : void in class org.apache.flink.runtime.checkpoint.CompletedCheckpointStoreTest |
From |
To |
|
Change Variable Type checkpoint : TestCheckpoint to checkpoint : TestCompletedCheckpoint in method public testShutdownDiscardsCheckpoints() : void in class org.apache.flink.runtime.checkpoint.ZooKeeperCompletedCheckpointStoreITCase |
From |
To |
|
Change Variable Type state : T to savepoint : Savepoint in method public loadSavepoint(path String) : Savepoint in class org.apache.flink.runtime.checkpoint.savepoint.HeapSavepointStore |
From |
To |
|
Change Variable Type savepointStore : HeapStateStore<CompletedCheckpoint> to savepointStore : HeapSavepointStore in method public testRollbackStateStoreFailure() : void in class org.apache.flink.runtime.checkpoint.savepoint.SavepointCoordinatorTest |
From |
To |
|
Change Variable Type that : TestCheckpoint to that : TestCompletedCheckpoint in method public equals(o Object) : boolean in class org.apache.flink.runtime.checkpoint.CompletedCheckpointStoreTest.TestCompletedCheckpoint |
From |
To |
|
Change Variable Type checkpoint : TestCheckpoint to checkpoint : TestCompletedCheckpoint in method public testDiscardAllCheckpoints() : void in class org.apache.flink.runtime.checkpoint.CompletedCheckpointStoreTest |
From |
To |
|
Change Variable Type savepoint : CompletedCheckpoint to savepoint : Savepoint in method public testShutdownDoesNotCleanUpCompletedCheckpointsWithFileSystemStore() : void in class org.apache.flink.runtime.checkpoint.savepoint.SavepointCoordinatorTest |
From |
To |
|
Change Variable Type savepointStore : HeapStateStore<CompletedCheckpoint> to savepointStore : HeapSavepointStore in method public testAbortSavepointOnStateStoreFailure() : void in class org.apache.flink.runtime.checkpoint.savepoint.SavepointCoordinatorTest |
From |
To |
|
Change Variable Type savepoint : CompletedCheckpoint to savepoint : SavepointV0 in method public testCheckpointsRemovedWithJobManagerBackendOnShutdown() : void in class org.apache.flink.test.checkpointing.SavepointITCase |
From |
To |
|
Change Variable Type checkpoint : TestCheckpoint to checkpoint : TestCompletedCheckpoint in method public testSuspendKeepsCheckpoints() : void in class org.apache.flink.runtime.checkpoint.ZooKeeperCompletedCheckpointStoreITCase |
From |
To |
|
Change Variable Type checkpoint : TestCheckpoint to checkpoint : TestCompletedCheckpoint in method public testSuspendDiscardsCheckpoints() : void in class org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStoreTest |
From |
To |