|
Change Parameter Type savepointStore : StateStore<Savepoint> to savepointStore : StateStore<CompletedCheckpoint> in method public SavepointCoordinator(jobId JobID, baseInterval long, checkpointTimeout long, tasksToTrigger ExecutionVertex[], tasksToWaitFor ExecutionVertex[], tasksToCommitTo ExecutionVertex[], userClassLoader ClassLoader, checkpointIDCounter CheckpointIDCounter, savepointStore StateStore<CompletedCheckpoint>, statsTracker CheckpointStatsTracker) in class org.apache.flink.runtime.checkpoint.SavepointCoordinator |
From |
To |
|
Change Parameter Type savepointStore : StateStore<Savepoint> to savepointStore : StateStore<CompletedCheckpoint> in method public enableSnapshotCheckpointing(interval long, checkpointTimeout long, minPauseBetweenCheckpoints long, maxConcurrentCheckpoints int, verticesToTrigger List<ExecutionJobVertex>, verticesToWaitFor List<ExecutionJobVertex>, verticesToCommitTo List<ExecutionJobVertex>, actorSystem ActorSystem, leaderSessionID UUID, checkpointIDCounter CheckpointIDCounter, completedCheckpointStore CompletedCheckpointStore, recoveryMode RecoveryMode, savepointStore StateStore<CompletedCheckpoint>) : void in class org.apache.flink.runtime.executiongraph.ExecutionGraph |
From |
To |
|
Change Parameter Type savepointStore : StateStore<Savepoint> to savepointStore : StateStore<CompletedCheckpoint> in method private createSavepointCoordinator(jobId JobID, checkpointTimeout long, triggerVertices ExecutionVertex[], ackVertices ExecutionVertex[], commitVertices ExecutionVertex[], checkpointIdCounter CheckpointIDCounter, savepointStore StateStore<CompletedCheckpoint>) : SavepointCoordinator in class org.apache.flink.runtime.checkpoint.SavepointCoordinatorTest |
From |
To |
|
Change Parameter Type stateStore : StateStore<Savepoint> to stateStore : StateStore<CompletedCheckpoint> in method public SavepointStore(stateStore StateStore<CompletedCheckpoint>) in class org.apache.flink.runtime.checkpoint.SavepointStore |
From |
To |
|
Change Parameter Type state : Savepoint to state : CompletedCheckpoint in method public putState(state CompletedCheckpoint) : String in class org.apache.flink.runtime.checkpoint.SavepointStore |
From |
To |
|
Change Variable Type heapStateStore : HeapStateStore<Savepoint> to heapStateStore : HeapStateStore<CompletedCheckpoint> in method public stop() : void in class org.apache.flink.runtime.checkpoint.SavepointStore |
From |
To |
|
Change Variable Type savepoint : Savepoint to savepoint : CompletedCheckpoint in method public testShutdownDoesNotCleanUpCompletedCheckpointsWithFileSystemStore() : void in class org.apache.flink.runtime.checkpoint.SavepointCoordinatorTest |
From |
To |
|
Change Variable Type savepointStore : HeapStateStore<Savepoint> to savepointStore : HeapStateStore<CompletedCheckpoint> in method public testRollbackStateStoreFailure() : void in class org.apache.flink.runtime.checkpoint.SavepointCoordinatorTest |
From |
To |
|
Change Variable Type savepoint : Savepoint to savepoint : CompletedCheckpoint in method public testCheckpointsRemovedWithJobManagerBackendOnShutdown() : void in class org.apache.flink.test.checkpointing.SavepointITCase |
From |
To |
|
Change Variable Type savepoint : Savepoint to savepoint : CompletedCheckpoint in method public testCheckpointHasBeenRemoved() : void in class org.apache.flink.test.checkpointing.SavepointITCase |
From |
To |
|
Change Variable Type savepointStore : StateStore<Savepoint> to savepointStore : StateStore<CompletedCheckpoint> in method public testRollbackParallelismMismatch() : void in class org.apache.flink.runtime.checkpoint.SavepointCoordinatorTest |
From |
To |
|
Change Variable Type savepoint : Savepoint to savepoint : CompletedCheckpoint in method public testTriggerSavepointAndResume() : void in class org.apache.flink.test.checkpointing.SavepointITCase |
From |
To |
|
Change Variable Type savepointStore : StateStore<Savepoint> to savepointStore : StateStore<CompletedCheckpoint> in method public testRollbackSetsCheckpointID() : void in class org.apache.flink.runtime.checkpoint.SavepointCoordinatorTest |
From |
To |
|
Change Variable Type savepointStore : HeapStateStore<Savepoint> to savepointStore : HeapStateStore<CompletedCheckpoint> in method public testAbortSavepointOnStateStoreFailure() : void in class org.apache.flink.runtime.checkpoint.SavepointCoordinatorTest |
From |
To |
|
Change Variable Type stateStore : FileSystemStateStore<Savepoint> to stateStore : FileSystemStateStore<CompletedCheckpoint> in method public testSavepointBackendFileSystem() : void in class org.apache.flink.runtime.checkpoint.SavepointStoreFactoryTest |
From |
To |
|
Change Variable Type savepointStore : HeapStateStore<Savepoint> to savepointStore : HeapStateStore<CompletedCheckpoint> in method public testSimpleTriggerSavepoint() : void in class org.apache.flink.runtime.checkpoint.SavepointCoordinatorTest |
From |
To |
|
Change Variable Type savepointStore : HeapStateStore<Savepoint> to savepointStore : HeapStateStore<CompletedCheckpoint> in method public testAbortSavepointIfSubsumed() : void in class org.apache.flink.runtime.checkpoint.SavepointCoordinatorTest |
From |
To |
|
Change Variable Type savepointStore : FileSystemStateStore<Savepoint> to savepointStore : FileSystemStateStore<CompletedCheckpoint> in method public testShutdownDoesNotCleanUpCompletedCheckpointsWithFileSystemStore() : void in class org.apache.flink.runtime.checkpoint.SavepointCoordinatorTest |
From |
To |
|
Change Variable Type savepoint : Savepoint to savepoint : CompletedCheckpoint in method public testSimpleTriggerSavepoint() : void in class org.apache.flink.runtime.checkpoint.SavepointCoordinatorTest |
From |
To |
|
Change Variable Type savepoint : Savepoint to savepoint : CompletedCheckpoint in method public stop() : void in class org.apache.flink.runtime.checkpoint.SavepointStore |
From |
To |
|
Change Variable Type savepointStore : StateStore<Savepoint> to savepointStore : StateStore<CompletedCheckpoint> in method public testSimpleRollbackSavepoint() : void in class org.apache.flink.runtime.checkpoint.SavepointCoordinatorTest |
From |
To |
|
Rename Parameter appId : String to jobId : String in method public createCheckpointsTable(jobId String, con Connection) : void in class org.apache.flink.contrib.streaming.state.DbAdapter |
From |
To |
|
Rename Parameter appId : String to jobId : String in method public getCheckpoint(jobId String, con Connection, checkpointId long, checkpointTs long, handleId long) : byte[] in class org.apache.flink.contrib.streaming.state.MySqlAdapter |
From |
To |
|
Rename Parameter appId : String to jobId : String in method public prepareCheckpointInsert(jobId String, con Connection) : PreparedStatement in class org.apache.flink.contrib.streaming.state.MySqlAdapter |
From |
To |
|
Rename Parameter appId : String to jobId : String in method public DbStateHandle(jobId String, checkpointId long, checkpointTs long, handleId long, dbConfig DbBackendConfig, stateSize long) in class org.apache.flink.contrib.streaming.state.DbStateHandle |
From |
To |
|
Rename Parameter appId : String to jobId : String in method public createCheckpointsTable(jobId String, con Connection) : void in class org.apache.flink.contrib.streaming.state.DerbyAdapter |
From |
To |
|
Rename Parameter appId : String to jobId : String in method public setCheckpointInsertParams(jobId String, insertStatement PreparedStatement, checkpointId long, timestamp long, handleId long, checkpoint byte[]) : void in class org.apache.flink.contrib.streaming.state.MySqlAdapter |
From |
To |
|
Rename Parameter appId : String to jobId : String in method public prepareCheckpointInsert(jobId String, con Connection) : PreparedStatement in class org.apache.flink.contrib.streaming.state.DbAdapter |
From |
To |
|
Rename Parameter appId : String to jobId : String in method public createCheckpointsTable(jobId String, con Connection) : void in class org.apache.flink.contrib.streaming.state.MySqlAdapter |
From |
To |
|
Rename Parameter appId : String to jobId : String in method public getCheckpoint(jobId String, con Connection, checkpointId long, checkpointTs long, handleId long) : byte[] in class org.apache.flink.contrib.streaming.state.DbAdapter |
From |
To |
|
Rename Parameter appId : String to jobId : String in method public deleteCheckpoint(jobId String, con Connection, checkpointId long, checkpointTs long, handleId long) : void in class org.apache.flink.contrib.streaming.state.MySqlAdapter |
From |
To |
|
Rename Parameter appId : String to jobId : String in method public disposeAllStateForJob(jobId String, con Connection) : void in class org.apache.flink.contrib.streaming.state.MySqlAdapter |
From |
To |
|
Rename Parameter appId : String to jobId : String in method public disposeAllStateForJob(jobId String, con Connection) : void in class org.apache.flink.contrib.streaming.state.DbAdapter |
From |
To |
|
Rename Parameter appId : String to jobId : String in method public deleteCheckpoint(jobId String, con Connection, checkpointId long, checkpointTs long, handleId long) : void in class org.apache.flink.contrib.streaming.state.DbAdapter |
From |
To |
|
Rename Parameter appId : String to jobId : String in method public setCheckpointInsertParams(jobId String, insertStatement PreparedStatement, checkpointId long, timestamp long, handleId long, checkpoint byte[]) : void in class org.apache.flink.contrib.streaming.state.DbAdapter |
From |
To |