flink ba8ed263695d16eacb4bdfdf195dd22c83bb53ed

ba8ed263695d16eacb4bdfdf195dd22c83bb53ed

Files Diff

Added: 12
Removed: 1
Renamed: 0
Modified: 16

Link to commit

Dependency Action

Refactorings reported:

Refactoring Name	Occurences
Change Parameter Type	4
Change Parameter Type closableRegistry : ClosableRegistry to closableRegistry : CloseableRegistry in method public KeyGroupStreamIterator(stateHandleIterator Iterator<KeyGroupsStateHandle>, closableRegistry CloseableRegistry) in class org.apache.flink.runtime.state.StateInitializationContextImpl.KeyGroupStreamIterator	From	To
Change Parameter Type closableRegistry : ClosableRegistry to closableRegistry : CloseableRegistry in method public OperatorStateStreamIterator(stateName String, stateHandleIterator Iterator<OperatorStateHandle>, closableRegistry CloseableRegistry) in class org.apache.flink.runtime.state.StateInitializationContextImpl.OperatorStateStreamIterator	From	To
Change Parameter Type closableRegistry : ClosableRegistry to closableRegistry : CloseableRegistry in method public StateSnapshotContextSynchronousImpl(checkpointId long, checkpointTimestamp long, streamFactory CheckpointStreamFactory, keyGroupRange KeyGroupRange, closableRegistry CloseableRegistry) in class org.apache.flink.runtime.state.StateSnapshotContextSynchronousImpl	From	To
Change Parameter Type closableRegistry : ClosableRegistry to closableRegistry : CloseableRegistry in method public StateInitializationContextImpl(restored boolean, operatorStateStore OperatorStateStore, keyedStateStore KeyedStateStore, keyGroupsStateHandles Collection<KeyGroupsStateHandle>, operatorStateHandles Collection<OperatorStateHandle>, closableRegistry CloseableRegistry) in class org.apache.flink.runtime.state.StateInitializationContextImpl	From	To
Move Method	2
Move Method public close() : void from class org.apache.flink.runtime.state.ClosableRegistry to public close() : void from class org.apache.flink.core.fs.ClosingFSDataInputStream	From	To
Move Method public isClosed() : boolean from class org.apache.flink.runtime.state.ClosableRegistry to public isClosed() : boolean from class org.apache.flink.core.fs.ClosingFSDataInputStream	From	To
Change Return Type	2
Change Return Type ClosableRegistry to CloseableRegistry in method public getClosableRegistry() : CloseableRegistry in class org.apache.flink.runtime.state.StateInitializationContextImpl	From	To
Change Return Type ClosableRegistry to CloseableRegistry in method public getCancelables() : CloseableRegistry in class org.apache.flink.streaming.runtime.tasks.StreamTask	From	To
Move Attribute	1
Move Attribute private closed : boolean from class org.apache.flink.runtime.state.ClosableRegistry to private closed : boolean from class org.apache.flink.core.fs.ClosingFSDataInputStream	From	To
Extract Class	1
Extract Class org.apache.flink.core.fs.ClosingFSDataInputStream from class org.apache.flink.runtime.state.ClosableRegistry	From	To
Move And Rename Class	1
Move And Rename Class org.apache.flink.runtime.state.ClosableRegistry moved and renamed to org.apache.flink.core.fs.CloseableRegistry	From	To
Change Variable Type	1
Change Variable Type closableRegistry : ClosableRegistry to closableRegistry : CloseableRegistry in method public setUp() : void in class org.apache.flink.streaming.api.operators.StateSnapshotContextSynchronousImplTest	From	To
Extract Variable	1
Extract Variable fs : FileSystem in method public discardState() : void from class org.apache.flink.runtime.state.filesystem.FileStateHandle	From	To
Change Attribute Type	9
Change Attribute Type closableRegistry : ClosableRegistry to closableRegistry : CloseableRegistry in class org.apache.flink.streaming.util.AbstractStreamOperatorTestHarness	From	To
Change Attribute Type cancelStreamRegistry : ClosableRegistry to cancelStreamRegistry : CloseableRegistry in class org.apache.flink.runtime.state.AbstractKeyedStateBackend	From	To
Change Attribute Type closableRegistry : ClosableRegistry to closableRegistry : CloseableRegistry in class org.apache.flink.streaming.api.operators.StateInitializationContextImplTest	From	To
Change Attribute Type cancelables : ClosableRegistry to cancelables : CloseableRegistry in class org.apache.flink.streaming.runtime.tasks.StreamTask	From	To
Change Attribute Type closableRegistry : ClosableRegistry to closableRegistry : CloseableRegistry in class org.apache.flink.runtime.state.StateInitializationContextImpl.KeyGroupStreamIterator	From	To
Change Attribute Type closableRegistry : ClosableRegistry to closableRegistry : CloseableRegistry in class org.apache.flink.runtime.state.StateSnapshotContextSynchronousImpl	From	To
Change Attribute Type closableRegistry : ClosableRegistry to closableRegistry : CloseableRegistry in class org.apache.flink.runtime.state.StateInitializationContextImpl	From	To
Change Attribute Type closableRegistry : ClosableRegistry to closableRegistry : CloseableRegistry in class org.apache.flink.runtime.state.StateInitializationContextImpl.OperatorStateStreamIterator	From	To
Change Attribute Type closeStreamOnCancelRegistry : ClosableRegistry to closeStreamOnCancelRegistry : CloseableRegistry in class org.apache.flink.runtime.state.DefaultOperatorStateBackend	From	To
Extract Method	1
Extract Method public getUnguardedFileSystem(uri URI) : FileSystem extracted from public get(uri URI) : FileSystem in class org.apache.flink.core.fs.FileSystem	From	To

ba8ed263695d16eacb4bdfdf195dd22c83bb53ed

Files Diff

Link to commit

Third party dependencies:

Refactorings reported: