|
Change Parameter Type stateHandleProvider : StateHandleProvider<T> to storage : StateStorageHelper in method public ZooKeeperStateHandleStore(client CuratorFramework, storage StateStorageHelper) in class org.apache.flink.runtime.zookeeper.ZooKeeperStateHandleStore |
From |
To |
|
Change Parameter Type stateHandleProvider : StateHandleProvider<SubmittedJobGraph> to stateStorage : StateStorageHelper<SubmittedJobGraph> in method public ZooKeeperSubmittedJobGraphStore(client CuratorFramework, currentJobsPath String, stateStorage StateStorageHelper<SubmittedJobGraph>) in class org.apache.flink.runtime.jobmanager.ZooKeeperSubmittedJobGraphStore |
From |
To |
|
Change Parameter Type stateHandleProvider : StateHandleProvider<CompletedCheckpoint> to stateStorage : StateStorageHelper<CompletedCheckpoint> in method public ZooKeeperCompletedCheckpointStore(maxNumberOfCheckpointsToRetain int, userClassLoader ClassLoader, client CuratorFramework, checkpointsPath String, stateStorage StateStorageHelper<CompletedCheckpoint>) in class org.apache.flink.runtime.checkpoint.ZooKeeperCompletedCheckpointStore |
From |
To |
|
Rename Variable stateHandleProvider : LongStateHandleProvider to longStateStorage : LongStateStorage in method public testAdd() : void in class org.apache.flink.runtime.zookeeper.ZooKeeperStateHandleStoreITCase |
From |
To |
|
Rename Variable completedCheckpointsPath : String to checkpointsPath : String in method public createCompletedCheckpoints(client CuratorFramework, configuration Configuration, jobId JobID, maxNumberOfCheckpointsToRetain int, userClassLoader ClassLoader) : CompletedCheckpointStore in class org.apache.flink.runtime.util.ZooKeeperUtils |
From |
To |
|
Rename Variable stateHandleProvider : StateHandleProvider<Long> to stateStorage : StateStorageHelper<Long> in method public testReplaceNonExistingPath() : void in class org.apache.flink.runtime.zookeeper.ZooKeeperStateHandleStoreITCase |
From |
To |
|
Rename Variable stateHandleProvider : LongStateHandleProvider to longStateStorage : LongStateStorage in method public testAddWithCreateMode() : void in class org.apache.flink.runtime.zookeeper.ZooKeeperStateHandleStoreITCase |
From |
To |
|
Rename Variable stateHandleProvider : StateHandleProvider<SubmittedJobGraph> to stateStorage : StateStorageHelper<SubmittedJobGraph> in method public createSubmittedJobGraphs(client CuratorFramework, configuration Configuration) : ZooKeeperSubmittedJobGraphStore in class org.apache.flink.runtime.util.ZooKeeperUtils |
From |
To |
|
Rename Variable stateHandleProvider : StateHandleProvider<CompletedCheckpoint> to stateStorage : StateStorageHelper<CompletedCheckpoint> in method public createCompletedCheckpoints(client CuratorFramework, configuration Configuration, jobId JobID, maxNumberOfCheckpointsToRetain int, userClassLoader ClassLoader) : CompletedCheckpointStore in class org.apache.flink.runtime.util.ZooKeeperUtils |
From |
To |
|
Move Class org.apache.flink.streaming.api.state.filesystem.FileSerializableStateHandle moved to org.apache.flink.runtime.state.filesystem.FileSerializableStateHandle |
From |
To |
|
Move Class org.apache.flink.streaming.api.state.filesystem.FsStateBackend moved to org.apache.flink.runtime.state.filesystem.FsStateBackend |
From |
To |
|
Move Class org.apache.flink.streaming.api.state.KvStateSnapshot moved to org.apache.flink.runtime.state.KvStateSnapshot |
From |
To |
|
Move Class org.apache.flink.streaming.api.state.memory.MemoryHeapKvStateSnapshot moved to org.apache.flink.runtime.state.memory.MemoryHeapKvStateSnapshot |
From |
To |
|
Move Class org.apache.flink.streaming.api.state.filesystem.AbstractFileState moved to org.apache.flink.runtime.state.filesystem.AbstractFileState |
From |
To |
|
Move Class org.apache.flink.streaming.api.state.memory.SerializedStateHandle moved to org.apache.flink.runtime.state.memory.SerializedStateHandle |
From |
To |
|
Move Class org.apache.flink.streaming.api.state.filesystem.FsHeapKvState moved to org.apache.flink.runtime.state.filesystem.FsHeapKvState |
From |
To |
|
Move Class org.apache.flink.streaming.api.state.SerializedCheckpointData moved to org.apache.flink.runtime.state.SerializedCheckpointData |
From |
To |
|
Move Class org.apache.flink.streaming.api.state.MemoryStateBackendTest moved to org.apache.flink.runtime.state.MemoryStateBackendTest |
From |
To |
|
Move Class org.apache.flink.streaming.api.state.filesystem.FsStateBackendFactory moved to org.apache.flink.runtime.state.filesystem.FsStateBackendFactory |
From |
To |
|
Move Class org.apache.flink.streaming.api.state.StateBackend.CheckpointStateOutputStream moved to org.apache.flink.runtime.state.StateBackend.CheckpointStateOutputStream |
From |
To |
|
Move Class org.apache.flink.streaming.api.state.StateBackend.DataInputViewHandle moved to org.apache.flink.runtime.state.StateBackend.DataInputViewHandle |
From |
To |
|
Move Class org.apache.flink.streaming.api.state.memory.MemoryStateBackend moved to org.apache.flink.runtime.state.memory.MemoryStateBackend |
From |
To |
|
Move Class org.apache.flink.streaming.api.state.StreamStateHandle moved to org.apache.flink.runtime.state.StreamStateHandle |
From |
To |
|
Move Class org.apache.flink.streaming.api.state.StateBackend.CheckpointStateOutputView moved to org.apache.flink.runtime.state.StateBackend.CheckpointStateOutputView |
From |
To |
|
Move Class org.apache.flink.streaming.api.state.filesystem.FsHeapKvStateSnapshot moved to org.apache.flink.runtime.state.filesystem.FsHeapKvStateSnapshot |
From |
To |
|
Move Class org.apache.flink.streaming.api.state.KvState moved to org.apache.flink.runtime.state.KvState |
From |
To |
|
Move Class org.apache.flink.streaming.api.state.memory.MemHeapKvState moved to org.apache.flink.runtime.state.memory.MemHeapKvState |
From |
To |
|
Move Class org.apache.flink.streaming.api.state.filesystem.FileStreamStateHandle moved to org.apache.flink.runtime.state.filesystem.FileStreamStateHandle |
From |
To |
|
Move Class org.apache.flink.streaming.api.state.AbstractHeapKvState moved to org.apache.flink.runtime.state.AbstractHeapKvState |
From |
To |
|
Move Class org.apache.flink.streaming.api.state.FileStateBackendTest moved to org.apache.flink.runtime.state.FileStateBackendTest |
From |
To |
|
Move Class org.apache.flink.streaming.api.state.StateBackendFactory moved to org.apache.flink.runtime.state.StateBackendFactory |
From |
To |
|
Move Class org.apache.flink.streaming.api.state.memory.ByteStreamStateHandle moved to org.apache.flink.runtime.state.memory.ByteStreamStateHandle |
From |
To |
|
Change Variable Type stateHandleProvider : LongStateHandleProvider to stateHandleProvider : LongStateStorage in method public testGetAndExists() : void in class org.apache.flink.runtime.zookeeper.ZooKeeperStateHandleStoreITCase |
From |
To |
|
Change Variable Type stateHandleProvider : LongStateHandleProvider to longStateStorage : LongStateStorage in method public testAddWithCreateMode() : void in class org.apache.flink.runtime.zookeeper.ZooKeeperStateHandleStoreITCase |
From |
To |
|
Change Variable Type stateHandleProvider : StateHandleProvider<SubmittedJobGraph> to stateStorage : StateStorageHelper<SubmittedJobGraph> in method public createSubmittedJobGraphs(client CuratorFramework, configuration Configuration) : ZooKeeperSubmittedJobGraphStore in class org.apache.flink.runtime.util.ZooKeeperUtils |
From |
To |
|
Change Variable Type stateHandleProvider : StateHandleProvider<CompletedCheckpoint> to stateStorage : StateStorageHelper<CompletedCheckpoint> in method public createCompletedCheckpoints(client CuratorFramework, configuration Configuration, jobId JobID, maxNumberOfCheckpointsToRetain int, userClassLoader ClassLoader) : CompletedCheckpointStore in class org.apache.flink.runtime.util.ZooKeeperUtils |
From |
To |
|
Change Variable Type stateHandleProvider : LongStateHandleProvider to stateHandleProvider : LongStateStorage in method public testAddAlreadyExistingPath() : void in class org.apache.flink.runtime.zookeeper.ZooKeeperStateHandleStoreITCase |
From |
To |
|
Change Variable Type stateHandleProvider : LongStateHandleProvider to stateHandleProvider : LongStateStorage in method public testReplaceDiscardStateHandleAfterFailure() : void in class org.apache.flink.runtime.zookeeper.ZooKeeperStateHandleStoreITCase |
From |
To |
|
Change Variable Type stateHandleProvider : LongStateHandleProvider to stateHandleProvider : LongStateStorage in method public testGetNonExistingPath() : void in class org.apache.flink.runtime.zookeeper.ZooKeeperStateHandleStoreITCase |
From |
To |
|
Change Variable Type stateHandleProvider : LongStateHandleProvider to stateHandleProvider : LongStateStorage in method public testReplace() : void in class org.apache.flink.runtime.zookeeper.ZooKeeperStateHandleStoreITCase |
From |
To |
|
Change Variable Type stateHandleProvider : LongStateHandleProvider to stateHandleProvider : LongStateStorage in method public testGetAll() : void in class org.apache.flink.runtime.zookeeper.ZooKeeperStateHandleStoreITCase |
From |
To |
|
Change Variable Type stateHandleProvider : LongStateHandleProvider to stateHandleProvider : LongStateStorage in method public testRemoveAndDiscardState() : void in class org.apache.flink.runtime.zookeeper.ZooKeeperStateHandleStoreITCase |
From |
To |
|
Change Variable Type stateHandleProvider : LongStateHandleProvider to stateHandleProvider : LongStateStorage in method public testRemoveAndDiscardAllState() : void in class org.apache.flink.runtime.zookeeper.ZooKeeperStateHandleStoreITCase |
From |
To |
|
Change Variable Type stateHandleProvider : LongStateHandleProvider to stateHandleProvider : LongStateStorage in method public testAddDiscardStateHandleAfterFailure() : void in class org.apache.flink.runtime.zookeeper.ZooKeeperStateHandleStoreITCase |
From |
To |
|
Change Variable Type stateHandleProvider : LongStateHandleProvider to stateHandleProvider : LongStateStorage in method public testRemove() : void in class org.apache.flink.runtime.zookeeper.ZooKeeperStateHandleStoreITCase |
From |
To |
|
Change Variable Type stateHandleProvider : LongStateHandleProvider to stateHandleProvider : LongStateStorage in method public testRemoveWithCallback() : void in class org.apache.flink.runtime.zookeeper.ZooKeeperStateHandleStoreITCase |
From |
To |
|
Change Variable Type stateHandleProvider : LongStateHandleProvider to longStateStorage : LongStateStorage in method public testAdd() : void in class org.apache.flink.runtime.zookeeper.ZooKeeperStateHandleStoreITCase |
From |
To |
|
Change Variable Type stateHandleProvider : LongStateHandleProvider to stateHandleProvider : LongStateStorage in method public testGetAllSortedByName() : void in class org.apache.flink.runtime.zookeeper.ZooKeeperStateHandleStoreITCase |
From |
To |
|
Change Variable Type stateHandleProvider : StateHandleProvider<Long> to stateStorage : StateStorageHelper<Long> in method public testReplaceNonExistingPath() : void in class org.apache.flink.runtime.zookeeper.ZooKeeperStateHandleStoreITCase |
From |
To |
|
Rename Parameter stateHandleProvider : StateHandleProvider<SubmittedJobGraph> to stateStorage : StateStorageHelper<SubmittedJobGraph> in method public ZooKeeperSubmittedJobGraphStore(client CuratorFramework, currentJobsPath String, stateStorage StateStorageHelper<SubmittedJobGraph>) in class org.apache.flink.runtime.jobmanager.ZooKeeperSubmittedJobGraphStore |
From |
To |
|
Rename Parameter stateHandleProvider : StateHandleProvider<CompletedCheckpoint> to stateStorage : StateStorageHelper<CompletedCheckpoint> in method public ZooKeeperCompletedCheckpointStore(maxNumberOfCheckpointsToRetain int, userClassLoader ClassLoader, client CuratorFramework, checkpointsPath String, stateStorage StateStorageHelper<CompletedCheckpoint>) in class org.apache.flink.runtime.checkpoint.ZooKeeperCompletedCheckpointStore |
From |
To |
|
Rename Parameter stateHandleProvider : StateHandleProvider<T> to storage : StateStorageHelper in method public ZooKeeperStateHandleStore(client CuratorFramework, storage StateStorageHelper) in class org.apache.flink.runtime.zookeeper.ZooKeeperStateHandleStore |
From |
To |