1887187f6b5c210d2091c69ef14fa8b8a5cae82c
Files Diff
- Added: 2
- Removed: 2
- Renamed: 0
- Modified: 39
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Move And Rename Method | 2 | ||
| Move And Rename Method public createSavepointStreamFactory(jobId JobID, operatorIdentifier String, targetLocation String) : CheckpointStreamFactory from class org.apache.flink.runtime.checkpoint.CheckpointSettingsSerializableTest.CustomStateBackend to public resolveCheckpoint(pointer String) : StreamStateHandle from class org.apache.flink.runtime.state.testutils.BackendForTestStream.TestCheckpointStorage | From | To | |
| Move And Rename Method public createStreamFactory(jobId JobID, operatorIdentifier String) : CheckpointStreamFactory from class org.apache.flink.runtime.checkpoint.CheckpointSettingsSerializableTest.CustomStateBackend to public resolveCheckpoint(pointer String) : StreamStateHandle from class org.apache.flink.runtime.state.testutils.BackendForTestStream.TestCheckpointStorage | From | To | |
| Move And Inline Method | 1 | ||
| Move And Inline Method public createStreamFactory(jobId JobID, operatorIdentifier String) : CheckpointStreamFactory moved from class org.apache.flink.runtime.state.memory.MemoryStateBackend to class org.apache.flink.contrib.streaming.state.RocksDBAsyncSnapshotTest & inlined to public testCleanupOfSnapshotsInFailureCase() : void | From | To | |
| Change Parameter Type | 1 | ||
| Change Parameter Type backend : AbstractStateBackend to backend : StateBackend in method private createTask(op StreamOperator<?>, backend StateBackend, checkpointResponder CheckpointResponder, failOnCheckpointErrors boolean) : Task in class org.apache.flink.streaming.runtime.tasks.TaskCheckpointingBehaviourTest | From | To | |
| Rename Variable | 4 | ||
| Rename Variable memoryStateBackend : BlockingStreamMemoryStateBackend to stateBackend : StateBackend in method public testCancelFullyAsyncCheckpoints() : void in class org.apache.flink.contrib.streaming.state.RocksDBAsyncSnapshotTest | From | To | |
| Rename Variable mockStateBackend : AbstractStateBackend to checkpointStorage : CheckpointStorage in method public testAsyncCheckpointingConcurrentCloseAfterAcknowledge() : void in class org.apache.flink.streaming.runtime.tasks.StreamTaskTest | From | To | |
| Rename Variable mockStateBackend : AbstractStateBackend to checkpointStorage : CheckpointStorage in method public testAsyncCheckpointingConcurrentCloseBeforeAcknowledge() : void in class org.apache.flink.streaming.runtime.tasks.StreamTaskTest | From | To | |
| Rename Variable nonPartBackend : AbstractStateBackend to storageBackend : AbstractStateBackend in method public testCallsForwardedToNonPartitionedBackend() : void in class org.apache.flink.contrib.streaming.state.RocksDBStateBackendConfigTest | From | To | |
| Change Return Type | 3 | ||
| Change Return Type CheckpointStreamFactory to StreamStateHandle in method public resolveCheckpoint(pointer String) : StreamStateHandle in class org.apache.flink.runtime.state.testutils.BackendForTestStream.TestCheckpointStorage | From | To | |
| Change Return Type FsCheckpointStorageLocation to CheckpointStorageLocation in method public initializeLocationForSavepoint(checkpointId long, externalLocationPointer String) : CheckpointStorageLocation in class org.apache.flink.runtime.state.filesystem.AbstractFsCheckpointStorage | From | To | |
| Rename Attribute | 1 | ||
| Rename Attribute checkpointStreamFactory : CheckpointStreamFactory to checkpointStorage : CheckpointStorage in class org.apache.flink.streaming.runtime.operators.GenericWriteAheadSink | From | To | |
| Extract Variable | 1 | ||
| Extract Variable lockingStateBackend : StateBackend in method public testBlockingNonInterruptibleCheckpoint() : void from class org.apache.flink.streaming.runtime.tasks.TaskCheckpointingBehaviourTest | From | To | |
| Change Variable Type | 3 | ||
| Change Variable Type mockStateBackend : AbstractStateBackend to checkpointStorage : CheckpointStorage in method public testAsyncCheckpointingConcurrentCloseAfterAcknowledge() : void in class org.apache.flink.streaming.runtime.tasks.StreamTaskTest | From | To | |
| Change Variable Type mockStateBackend : AbstractStateBackend to checkpointStorage : CheckpointStorage in method public testAsyncCheckpointingConcurrentCloseBeforeAcknowledge() : void in class org.apache.flink.streaming.runtime.tasks.StreamTaskTest | From | To | |
| Change Variable Type memoryStateBackend : BlockingStreamMemoryStateBackend to stateBackend : StateBackend in method public testCancelFullyAsyncCheckpoints() : void in class org.apache.flink.contrib.streaming.state.RocksDBAsyncSnapshotTest | From | To | |
| Change Attribute Type | 1 | ||
| Change Attribute Type checkpointStreamFactory : CheckpointStreamFactory to checkpointStorage : CheckpointStorage in class org.apache.flink.streaming.runtime.operators.GenericWriteAheadSink | From | To | |
| Extract And Move Method | 1 | ||
| Extract And Move Method protected createSavepointLocation(fs FileSystem, location Path) : CheckpointStorageLocation extracted from public initializeLocationForSavepoint(checkpointId long, externalLocationPointer String) : FsCheckpointStorageLocation in class org.apache.flink.runtime.state.filesystem.AbstractFsCheckpointStorage & moved to class org.apache.flink.runtime.state.filesystem.FsCheckpointStorage | From | To | |
| Rename Parameter | 3 | ||
| Rename Parameter operatorIdentifier : String to pointer : String in method public resolveCheckpoint(pointer String) : StreamStateHandle in class org.apache.flink.runtime.state.testutils.BackendForTestStream.TestCheckpointStorage | From | To | |
| Rename Parameter checkpointDataUri : Path to checkpointDirectory : Path in method public FsCheckpointStreamFactory(fileSystem FileSystem, checkpointDirectory Path, fileStateSizeThreshold int) in class org.apache.flink.runtime.state.filesystem.FsCheckpointStreamFactory | From | To |