|
Change Return Type StreamStateHandle to CompletedCheckpointStorageLocation in method public resolveCheckpoint(checkpointPointer String) : CompletedCheckpointStorageLocation in class org.apache.flink.runtime.state.filesystem.AbstractFsCheckpointStorage |
From |
To |
|
Change Return Type StreamStateHandle to CompletedCheckpointStorageLocation in method protected resolveCheckpointPointer(checkpointPointer String) : CompletedCheckpointStorageLocation in class org.apache.flink.runtime.state.filesystem.AbstractFsCheckpointStorage |
From |
To |
|
Change Return Type FileStateHandle to FsCompletedCheckpointStorageLocation in method public closeAndFinalizeCheckpoint() : FsCompletedCheckpointStorageLocation in class org.apache.flink.runtime.state.filesystem.FixFileFsStateOutputStream |
From |
To |
|
Change Return Type CheckpointStateOutputStream to CheckpointMetadataOutputStream in method public createMetadataOutputStream() : CheckpointMetadataOutputStream in class org.apache.flink.runtime.state.CheckpointStorageLocation |
From |
To |
|
Change Return Type StreamStateHandle to CompletedCheckpointStorageLocation in method public resolveCheckpoint(externalPointer String) : CompletedCheckpointStorageLocation in class org.apache.flink.runtime.state.StateBackend |
From |
To |
|
Change Return Type StreamStateHandle to CompletedCheckpointStorageLocation in method public resolveCheckpoint(pointer String) : CompletedCheckpointStorageLocation in class org.apache.flink.runtime.state.filesystem.AbstractFileStateBackend |
From |
To |
|
Change Return Type StreamStateHandle to CompletedCheckpointStorageLocation in method public resolveCheckpoint(pointer String) : CompletedCheckpointStorageLocation in class org.apache.flink.contrib.streaming.state.RocksDBStateBackend |
From |
To |
|
Change Return Type CheckpointStateOutputStream to CheckpointMetadataOutputStream in method public createMetadataOutputStream() : CheckpointMetadataOutputStream in class org.apache.flink.runtime.state.filesystem.FsCheckpointStorageLocation |
From |
To |
|
Change Return Type StreamStateHandle to CompletedCheckpointStorageLocation in method public resolveCheckpoint(externalPointer String) : CompletedCheckpointStorageLocation in class org.apache.flink.runtime.state.CheckpointStorage |
From |
To |
|
Change Return Type CheckpointStateOutputStream to CheckpointMetadataOutputStream in method public createMetadataOutputStream() : CheckpointMetadataOutputStream in class org.apache.flink.runtime.state.memory.NonPersistentMetadataCheckpointStorageLocation |
From |
To |
|
Change Return Type CheckpointStateOutputStream to CheckpointMetadataOutputStream in method public createMetadataOutputStream() : CheckpointMetadataOutputStream in class org.apache.flink.runtime.state.memory.PersistentMetadataCheckpointStorageLocation |
From |
To |
|
Change Variable Type in : FSDataInputStream to in : InputStream in method public disposeSavepoint(pointer String, stateBackend StateBackend, classLoader ClassLoader) : void in class org.apache.flink.runtime.checkpoint.Checkpoints |
From |
To |
|
Change Variable Type in : FSDataInputStream to in : InputStream in method public loadAndValidateCheckpoint(jobId JobID, tasks Map<JobVertexID,ExecutionJobVertex>, location CompletedCheckpointStorageLocation, classLoader ClassLoader, allowNonRestoredState boolean) : CompletedCheckpoint in class org.apache.flink.runtime.checkpoint.Checkpoints |
From |
To |
|
Change Variable Type out : CheckpointStateOutputStream to out : CheckpointMetadataOutputStream in method public finalizeCheckpoint() : CompletedCheckpoint in class org.apache.flink.runtime.checkpoint.PendingCheckpoint |
From |
To |
|
Change Variable Type metadataHandle : StreamStateHandle to finalizedLocation : CompletedCheckpointStorageLocation in method public finalizeCheckpoint() : CompletedCheckpoint in class org.apache.flink.runtime.checkpoint.PendingCheckpoint |
From |
To |