5af463a9c0ff62603bc342a78dfd5483d834e8a7
Files Diff
- Added: 1
- Removed: 2
- Renamed: 0
- Modified: 17
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Method | 2 | ||
| Rename Method public unregisterClosable(closeable C) : void renamed to public unregisterCloseable(closeable C) : boolean in class org.apache.flink.util.AbstractCloseableRegistry | From | To | |
| Rename Method public registerClosable(closeable C) : void renamed to public registerCloseable(closeable C) : void in class org.apache.flink.util.AbstractCloseableRegistry | From | To | |
| Change Return Type | 5 | ||
| Change Return Type IOException to Exception in method public getStopException() : Exception in class org.apache.flink.runtime.io.async.AsyncStoppable | From | To | |
| Change Return Type void to boolean in method protected doUnRegister(closeable Closeable, closeableMap Map<Closeable,Object>) : boolean in class org.apache.flink.core.fs.CloseableRegistry | From | To | |
| Change Return Type void to boolean in method protected abstract doUnRegister(closeable C, closeableMap Map<Closeable,T>) : boolean in class org.apache.flink.util.AbstractCloseableRegistry | From | To | |
| Change Return Type void to boolean in method public unregisterCloseable(closeable C) : boolean in class org.apache.flink.util.AbstractCloseableRegistry | From | To | |
| Change Return Type void to boolean in method protected doUnRegister(closeable WrappingProxyCloseable<? extends Closeable>, closeableMap Map<Closeable,PhantomDelegatingCloseableRef>) : boolean in class org.apache.flink.core.fs.SafetyNetCloseableRegistry | From | To | |
| Extract Variable | 1 | ||
| Extract Variable delegate : CheckpointStreamFactory.CheckpointStateOutputStream in method private closeAndUnregisterStream(stream NonClosingCheckpointOutputStream<T>) : void from class org.apache.flink.runtime.state.StateSnapshotContextSynchronousImpl | From | To | |
| Change Variable Type | 1 | ||
| Change Variable Type ioCallable : AbstractAsyncIOCallable<KeyedStateHandle,CheckpointStreamFactory.CheckpointStateOutputStream> to ioCallable : AbstractAsyncCallableWithResources<KeyedStateHandle> in method private snapshotFully(checkpointId long, timestamp long, streamFactory CheckpointStreamFactory) : RunnableFuture<KeyedStateHandle> in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend | From | To |