d1ea365ef1fa979d40532bf3f114fc03284164bc
Files Diff
- Added: 2
- Removed: 0
- Renamed: 0
- Modified: 10
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Variable | 2 | ||
| Rename Variable targetPath : Path to bufferSize : int in method public createCheckpointStateOutputStream(checkpointID long, timestamp long) : FsCheckpointStateOutputStream in class org.apache.flink.runtime.state.filesystem.FsStateBackend | From | To | |
| Rename Variable outStream : FSDataOutputStream to stream : FsCheckpointStateOutputStream in method public checkpointStateSerializable(state S, checkpointID long, timestamp long) : StateHandle<S> in class org.apache.flink.runtime.state.filesystem.FsStateBackend | From | To | |
| Change Return Type | 2 | ||
| Change Return Type FileStreamStateHandle to StreamStateHandle in method public closeAndGetHandle() : StreamStateHandle in class org.apache.flink.runtime.state.filesystem.FsStateBackend.FsCheckpointStateOutputStream | From | To | |
| Change Return Type String to URI in method private randomHdfsFileUri() : URI in class org.apache.flink.hdfstests.FileStateBackendTest | From | To | |
| Rename Attribute | 1 | ||
| Rename Attribute filePath : Path to basePath : Path in class org.apache.flink.runtime.state.filesystem.FsStateBackend.FsCheckpointStateOutputStream | From | To | |
| Extract Variable | 1 | ||
| Extract Variable numBytesRead : int in method private validateBytesInStream(is InputStream, data byte[]) : void from class org.apache.flink.runtime.state.FileStateBackendTest | From | To | |
| Change Variable Type | 7 | ||
| Change Variable Type handle2 : FileStreamStateHandle to handle2 : ByteStreamStateHandle in method public testStateOutputStream() : void in class org.apache.flink.hdfstests.FileStateBackendTest | From | To | |
| Change Variable Type targetPath : Path to bufferSize : int in method public createCheckpointStateOutputStream(checkpointID long, timestamp long) : FsCheckpointStateOutputStream in class org.apache.flink.runtime.state.filesystem.FsStateBackend | From | To | |
| Change Variable Type handle3 : FileStreamStateHandle to handle3 : ByteStreamStateHandle in method public testStateOutputStream() : void in class org.apache.flink.hdfstests.FileStateBackendTest | From | To | |
| Change Variable Type outStream : FSDataOutputStream to stream : FsCheckpointStateOutputStream in method public checkpointStateSerializable(state S, checkpointID long, timestamp long) : StateHandle<S> in class org.apache.flink.runtime.state.filesystem.FsStateBackend | From | To | |
| Change Variable Type handle2 : FileStreamStateHandle to handle2 : ByteStreamStateHandle in method public testStateOutputStream() : void in class org.apache.flink.runtime.state.FileStateBackendTest | From | To | |
| Change Variable Type handle3 : FileStreamStateHandle to handle3 : ByteStreamStateHandle in method public testStateOutputStream() : void in class org.apache.flink.runtime.state.FileStateBackendTest | From | To | |
| Change Variable Type handle4 : StreamStateHandle to handle4 : FileStreamStateHandle in method public testStateOutputStream() : void in class org.apache.flink.runtime.state.FileStateBackendTest | From | To | |
| Extract And Move Method | 1 | ||
| Extract And Move Method public toSerializableHandle() : StateHandle<T> extracted from public checkpointStateSerializable(state S, checkpointID long, timestamp long) : StateHandle<S> in class org.apache.flink.runtime.state.filesystem.FsStateBackend & moved to class org.apache.flink.runtime.state.filesystem.FileStreamStateHandle | From | To | |
| Rename Parameter | 1 | ||
| Rename Parameter filePath : Path to basePath : Path in method public FsCheckpointStateOutputStream(basePath Path, fs FileSystem, bufferSize int, localStateThreshold int) in class org.apache.flink.runtime.state.filesystem.FsStateBackend.FsCheckpointStateOutputStream | From | To |