|
Change Parameter Type operatorSubtaskStateFromJobManager : OperatorSubtaskState to restoreStateAlternatives : Iterator<StateObjectCollection<KeyedStateHandle>> in method protected rawKeyedStateInputs(restoreStateAlternatives Iterator<StateObjectCollection<KeyedStateHandle>>) : CloseableIterable<KeyGroupStatePartitionStreamProvider> in class org.apache.flink.streaming.api.operators.StreamTaskStateInitializerImpl |
From |
To |
|
Change Parameter Type keyedStateManagedFuture : RunnableFuture<KeyedStateHandle> to keyedStateManagedFuture : RunnableFuture<SnapshotResult<KeyedStateHandle>> in method public OperatorSnapshotFutures(keyedStateManagedFuture RunnableFuture<SnapshotResult<KeyedStateHandle>>, keyedStateRawFuture RunnableFuture<SnapshotResult<KeyedStateHandle>>, operatorStateManagedFuture RunnableFuture<SnapshotResult<OperatorStateHandle>>, operatorStateRawFuture RunnableFuture<SnapshotResult<OperatorStateHandle>>) in class org.apache.flink.streaming.api.operators.OperatorSnapshotFutures |
From |
To |
|
Change Parameter Type keyedStateRawFuture : RunnableFuture<KeyedStateHandle> to keyedStateRawFuture : RunnableFuture<SnapshotResult<KeyedStateHandle>> in method public OperatorSnapshotFutures(keyedStateManagedFuture RunnableFuture<SnapshotResult<KeyedStateHandle>>, keyedStateRawFuture RunnableFuture<SnapshotResult<KeyedStateHandle>>, operatorStateManagedFuture RunnableFuture<SnapshotResult<OperatorStateHandle>>, operatorStateRawFuture RunnableFuture<SnapshotResult<OperatorStateHandle>>) in class org.apache.flink.streaming.api.operators.OperatorSnapshotFutures |
From |
To |
|
Change Parameter Type operatorStateManagedFuture : RunnableFuture<OperatorStateHandle> to operatorStateManagedFuture : RunnableFuture<SnapshotResult<OperatorStateHandle>> in method public setOperatorStateManagedFuture(operatorStateManagedFuture RunnableFuture<SnapshotResult<OperatorStateHandle>>) : void in class org.apache.flink.streaming.api.operators.OperatorSnapshotFutures |
From |
To |
|
Change Parameter Type managedOperatorState : Collection<OperatorStateHandle> to managedOperatorState : StateObjectCollection<OperatorStateHandle> in method public OperatorSubtaskState(managedOperatorState StateObjectCollection<OperatorStateHandle>, rawOperatorState StateObjectCollection<OperatorStateHandle>, managedKeyedState StateObjectCollection<KeyedStateHandle>, rawKeyedState StateObjectCollection<KeyedStateHandle>) in class org.apache.flink.runtime.checkpoint.OperatorSubtaskState |
From |
To |
|
Change Parameter Type operatorSubtaskStateFromJobManager : OperatorSubtaskState to restoreStateAlternatives : Iterator<StateObjectCollection<OperatorStateHandle>> in method protected rawOperatorStateInputs(restoreStateAlternatives Iterator<StateObjectCollection<OperatorStateHandle>>) : CloseableIterable<StatePartitionStreamProvider> in class org.apache.flink.streaming.api.operators.StreamTaskStateInitializerImpl |
From |
To |
|
Change Parameter Type rawKeyedState : Collection<KeyedStateHandle> to rawKeyedState : StateObjectCollection<KeyedStateHandle> in method public OperatorSubtaskState(managedOperatorState StateObjectCollection<OperatorStateHandle>, rawOperatorState StateObjectCollection<OperatorStateHandle>, managedKeyedState StateObjectCollection<KeyedStateHandle>, rawKeyedState StateObjectCollection<KeyedStateHandle>) in class org.apache.flink.runtime.checkpoint.OperatorSubtaskState |
From |
To |
|
Change Parameter Type enableIncrementalCheckpointing : boolean to enableIncrementalCheckpointing : TernaryBoolean in method public RocksDBStateBackend(checkpointStreamBackend StateBackend, enableIncrementalCheckpointing TernaryBoolean) in class org.apache.flink.contrib.streaming.state.RocksDBStateBackend |
From |
To |
|
Change Parameter Type stream : NonClosingCheckpointOutputStream<T> to stream : NonClosingCheckpointOutputStream<? extends T> in method private closeAndUnregisterStream(stream NonClosingCheckpointOutputStream<? extends T>) : void in class org.apache.flink.runtime.state.StateSnapshotContextSynchronousImpl |
From |
To |
|
Change Parameter Type managedKeyedState : Collection<KeyedStateHandle> to managedKeyedState : StateObjectCollection<KeyedStateHandle> in method public OperatorSubtaskState(managedOperatorState StateObjectCollection<OperatorStateHandle>, rawOperatorState StateObjectCollection<OperatorStateHandle>, managedKeyedState StateObjectCollection<KeyedStateHandle>, rawKeyedState StateObjectCollection<KeyedStateHandle>) in class org.apache.flink.runtime.checkpoint.OperatorSubtaskState |
From |
To |
|
Change Parameter Type keyedStateManagedFuture : RunnableFuture<KeyedStateHandle> to keyedStateManagedFuture : RunnableFuture<SnapshotResult<KeyedStateHandle>> in method public setKeyedStateManagedFuture(keyedStateManagedFuture RunnableFuture<SnapshotResult<KeyedStateHandle>>) : void in class org.apache.flink.streaming.api.operators.OperatorSnapshotFutures |
From |
To |
|
Change Parameter Type keyedStateRawFuture : RunnableFuture<KeyedStateHandle> to keyedStateRawFuture : RunnableFuture<SnapshotResult<KeyedStateHandle>> in method public setKeyedStateRawFuture(keyedStateRawFuture RunnableFuture<SnapshotResult<KeyedStateHandle>>) : void in class org.apache.flink.streaming.api.operators.OperatorSnapshotFutures |
From |
To |
|
Change Parameter Type operatorStateManagedFuture : RunnableFuture<OperatorStateHandle> to operatorStateManagedFuture : RunnableFuture<SnapshotResult<OperatorStateHandle>> in method public OperatorSnapshotFutures(keyedStateManagedFuture RunnableFuture<SnapshotResult<KeyedStateHandle>>, keyedStateRawFuture RunnableFuture<SnapshotResult<KeyedStateHandle>>, operatorStateManagedFuture RunnableFuture<SnapshotResult<OperatorStateHandle>>, operatorStateRawFuture RunnableFuture<SnapshotResult<OperatorStateHandle>>) in class org.apache.flink.streaming.api.operators.OperatorSnapshotFutures |
From |
To |
|
Change Parameter Type operatorStateRawFuture : RunnableFuture<OperatorStateHandle> to operatorStateRawFuture : RunnableFuture<SnapshotResult<OperatorStateHandle>> in method public setOperatorStateRawFuture(operatorStateRawFuture RunnableFuture<SnapshotResult<OperatorStateHandle>>) : void in class org.apache.flink.streaming.api.operators.OperatorSnapshotFutures |
From |
To |
|
Change Parameter Type rawOperatorState : Collection<OperatorStateHandle> to rawOperatorState : StateObjectCollection<OperatorStateHandle> in method public OperatorSubtaskState(managedOperatorState StateObjectCollection<OperatorStateHandle>, rawOperatorState StateObjectCollection<OperatorStateHandle>, managedKeyedState StateObjectCollection<KeyedStateHandle>, rawKeyedState StateObjectCollection<KeyedStateHandle>) in class org.apache.flink.runtime.checkpoint.OperatorSubtaskState |
From |
To |
|
Change Parameter Type operatorStateRawFuture : RunnableFuture<OperatorStateHandle> to operatorStateRawFuture : RunnableFuture<SnapshotResult<OperatorStateHandle>> in method public OperatorSnapshotFutures(keyedStateManagedFuture RunnableFuture<SnapshotResult<KeyedStateHandle>>, keyedStateRawFuture RunnableFuture<SnapshotResult<KeyedStateHandle>>, operatorStateManagedFuture RunnableFuture<SnapshotResult<OperatorStateHandle>>, operatorStateRawFuture RunnableFuture<SnapshotResult<OperatorStateHandle>>) in class org.apache.flink.streaming.api.operators.OperatorSnapshotFutures |
From |
To |
|
Change Parameter Type toRelease : Iterable<TaskLocalStateStore> to toRelease : Iterable<TaskLocalStateStoreImpl> in method private doRelease(toRelease Iterable<TaskLocalStateStoreImpl>) : void in class org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager |
From |
To |
|
Change Parameter Type jobID : JobID to allocationID : AllocationID in method public releaseLocalStateForAllocationId(allocationID AllocationID) : void in class org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager |
From |
To |
|
Change Variable Type snapshot : RunnableFuture<OperatorStateHandle> to snapshot : RunnableFuture<SnapshotResult<OperatorStateHandle>> in method public testSnapshotBroadcastStateWithEmptyOperatorState() : void in class org.apache.flink.runtime.state.OperatorStateBackendTest |
From |
To |
|
Change Variable Type futureOperatorStateHandle : RunnableFuture<OperatorStateHandle> to futureOperatorStateHandle : RunnableFuture<SnapshotResult<OperatorStateHandle>> in method public testFailingBackendSnapshotMethod() : void in class org.apache.flink.streaming.api.operators.AbstractStreamOperatorTest |
From |
To |
|
Change Variable Type runnableFuture : RunnableFuture<OperatorStateHandle> to runnableFuture : RunnableFuture<SnapshotResult<OperatorStateHandle>> in method public testOperatorStateRestoreFailsIfSerializerDeserializationFails() : void in class org.apache.flink.runtime.state.MemoryStateBackendTest |
From |
To |
|
Change Variable Type offsetsMap : Map<String,StateMetaInfo> to offsetsMap : Map<String,OperatorStateHandle.StateMetaInfo> in method public createOperatorStates(random Random, numTaskStates int, numSubtasksPerTask int) : Collection<OperatorState> in class org.apache.flink.runtime.checkpoint.savepoint.CheckpointTestUtils |
From |
To |
|
Change Variable Type snapshotFuture : RunnableFuture<KeyedStateHandle> to snapshotFuture : RunnableFuture<SnapshotResult<KeyedStateHandle>> in method public testCleanupOfSnapshotsInFailureCase() : void in class org.apache.flink.contrib.streaming.state.RocksDBAsyncSnapshotTest |
From |
To |
|
Change Variable Type snapshot : RunnableFuture<OperatorStateHandle> to snapshot : RunnableFuture<SnapshotResult<OperatorStateHandle>> in method public testSnapshotEmpty() : void in class org.apache.flink.runtime.state.OperatorStateBackendTest |
From |
To |
|
Change Variable Type futureManagedOperatorStateHandle : RunnableFuture<OperatorStateHandle> to futureManagedOperatorStateHandle : RunnableFuture<SnapshotResult<OperatorStateHandle>> in method public testFailingBackendSnapshotMethod() : void in class org.apache.flink.streaming.api.operators.AbstractStreamOperatorTest |
From |
To |
|
Change Variable Type task : AsyncStoppableTaskWithCallback<OperatorStateHandle> to task : AsyncStoppableTaskWithCallback<SnapshotResult<OperatorStateHandle>> in method public snapshot(checkpointId long, timestamp long, streamFactory CheckpointStreamFactory, checkpointOptions CheckpointOptions) : RunnableFuture<SnapshotResult<OperatorStateHandle>> in class org.apache.flink.runtime.state.DefaultOperatorStateBackend |
From |
To |
|
Change Variable Type snapshot : RunnableFuture<KeyedStateHandle> to snapshot : RunnableFuture<SnapshotResult<KeyedStateHandle>> in method public testCancelRunningSnapshot() : void in class org.apache.flink.contrib.streaming.state.RocksDBStateBackendTest |
From |
To |
|
Change Variable Type snapshot2 : RunnableFuture<KeyedStateHandle> to snapshot2 : RunnableFuture<SnapshotResult<KeyedStateHandle>> in method public testParallelAsyncSnapshots() : void in class org.apache.flink.runtime.state.StateBackendTestBase |
From |
To |
|
Change Variable Type snapshot : RunnableFuture<KeyedStateHandle> to snapshot : RunnableFuture<SnapshotResult<KeyedStateHandle>> in method public testReleasingSnapshotAfterBackendClosed() : void in class org.apache.flink.contrib.streaming.state.RocksDBStateBackendTest |
From |
To |
|
Change Variable Type ioCallable : AbstractAsyncCallableWithResources<OperatorStateHandle> to ioCallable : AbstractAsyncCallableWithResources<SnapshotResult<OperatorStateHandle>> in method public snapshot(checkpointId long, timestamp long, streamFactory CheckpointStreamFactory, checkpointOptions CheckpointOptions) : RunnableFuture<SnapshotResult<OperatorStateHandle>> in class org.apache.flink.runtime.state.DefaultOperatorStateBackend |
From |
To |
|
Change Variable Type snapshot : RunnableFuture<KeyedStateHandle> to snapshot : RunnableFuture<SnapshotResult<KeyedStateHandle>> in method public testSharedIncrementalStateDeRegistration() : void in class org.apache.flink.contrib.streaming.state.RocksDBStateBackendTest |
From |
To |
|
Change Variable Type failingFuture : RunnableFuture<OperatorStateHandle> to failingFuture : RunnableFuture<SnapshotResult<OperatorStateHandle>> in method public testFailingAsyncCheckpointRunnable() : void in class org.apache.flink.streaming.runtime.tasks.StreamTaskTest |
From |
To |
|
Change Variable Type task : AsyncStoppableTaskWithCallback<KeyedStateHandle> to task : AsyncStoppableTaskWithCallback<SnapshotResult<KeyedStateHandle>> in method public snapshot(checkpointId long, timestamp long, streamFactory CheckpointStreamFactory, checkpointOptions CheckpointOptions) : RunnableFuture<SnapshotResult<KeyedStateHandle>> in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend |
From |
To |
|
Change Variable Type futureKeyedStateHandle : RunnableFuture<KeyedStateHandle> to futureKeyedStateHandle : RunnableFuture<SnapshotResult<KeyedStateHandle>> in method public testFailingBackendSnapshotMethod() : void in class org.apache.flink.streaming.api.operators.AbstractStreamOperatorTest |
From |
To |
|
Change Variable Type runnableFuture : RunnableFuture<OperatorStateHandle> to runnableFuture : RunnableFuture<SnapshotResult<OperatorStateHandle>> in method public testCorrectClassLoaderUsedOnSnapshot() : void in class org.apache.flink.runtime.state.OperatorStateBackendTest |
From |
To |
|
Change Variable Type offsetsMap : Map<String,StateMetaInfo> to offsetsMap : Map<String,OperatorStateHandle.StateMetaInfo> in method public createTaskStates(random Random, numTaskStates int, numSubtasksPerTask int) : Collection<TaskState> in class org.apache.flink.runtime.checkpoint.savepoint.CheckpointTestUtils |
From |
To |
|
Change Variable Type snapshot : RunnableFuture<KeyedStateHandle> to snapshot : RunnableFuture<SnapshotResult<KeyedStateHandle>> in method public testCompletingSnapshot() : void in class org.apache.flink.contrib.streaming.state.RocksDBStateBackendTest |
From |
To |
|
Change Variable Type snapshot : RunnableFuture<KeyedStateHandle> to snapshot : RunnableFuture<SnapshotResult<KeyedStateHandle>> in method private snapshotRestoreRoundtrip(useCompression boolean) : void in class org.apache.flink.runtime.state.StateSnapshotCompressionTest |
From |
To |
|
Change Variable Type snapshot1 : RunnableFuture<KeyedStateHandle> to snapshot1 : RunnableFuture<SnapshotResult<KeyedStateHandle>> in method public testParallelAsyncSnapshots() : void in class org.apache.flink.runtime.state.StateBackendTestBase |
From |
To |
|
Change Variable Type snapshot : RunnableFuture<KeyedStateHandle> to snapshot : RunnableFuture<SnapshotResult<KeyedStateHandle>> in method public testDismissingSnapshotNotRunnable() : void in class org.apache.flink.contrib.streaming.state.RocksDBStateBackendTest |
From |
To |
|
Change Variable Type stateStore : TaskLocalStateStore to stateStore : TaskLocalStateStoreImpl in method private doRelease(toRelease Iterable<TaskLocalStateStoreImpl>) : void in class org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager |
From |
To |
|
Change Variable Type subtaskState : OperatorSubtaskState to subtaskState : PrioritizedOperatorSubtaskState in method public invoke() : void in class org.apache.flink.runtime.jobmanager.JobManagerHARecoveryTest.BlockingInvokable |
From |
To |
|
Change Variable Type snapshot : RunnableFuture<KeyedStateHandle> to snapshot : RunnableFuture<SnapshotResult<KeyedStateHandle>> in method public testAsyncSnapshotCancellation() : void in class org.apache.flink.runtime.state.StateBackendTestBase |
From |
To |
|
Change Variable Type runnableFuture : RunnableFuture<OperatorStateHandle> to runnableFuture : RunnableFuture<SnapshotResult<OperatorStateHandle>> in method public testSnapshotAsyncClose() : void in class org.apache.flink.runtime.state.OperatorStateBackendTest |
From |
To |
|
Change Variable Type runnableFuture : RunnableFuture<OperatorStateHandle> to runnableFuture : RunnableFuture<SnapshotResult<OperatorStateHandle>> in method public testSnapshotAsyncCancel() : void in class org.apache.flink.runtime.state.OperatorStateBackendTest |
From |
To |
|
Change Variable Type snapshot : RunnableFuture<KeyedStateHandle> to snapshot : RunnableFuture<SnapshotResult<KeyedStateHandle>> in method public testAsyncSnapshot() : void in class org.apache.flink.runtime.state.StateBackendTestBase |
From |
To |
|
Change Variable Type runnableFuture : RunnableFuture<OperatorStateHandle> to runnableFuture : RunnableFuture<SnapshotResult<OperatorStateHandle>> in method public testSnapshotRestoreAsync() : void in class org.apache.flink.runtime.state.OperatorStateBackendTest |
From |
To |
|
Change Variable Type keyGroupsStateHandle : KeyGroupsStateHandle to keyGroupsStateHandle : KeyedStateHandle in method public getKeyedStateStreamFuture() : RunnableFuture<SnapshotResult<KeyedStateHandle>> in class org.apache.flink.runtime.state.StateSnapshotContextSynchronousImpl |
From |
To |
|
Change Variable Type ioCallable : AbstractAsyncCallableWithResources<KeyedStateHandle> to ioCallable : AbstractAsyncCallableWithResources<SnapshotResult<KeyedStateHandle>> in method public snapshot(checkpointId long, timestamp long, streamFactory CheckpointStreamFactory, checkpointOptions CheckpointOptions) : RunnableFuture<SnapshotResult<KeyedStateHandle>> in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend |
From |
To |
|
Change Variable Type snapshot : RunnableFuture<KeyedStateHandle> to snapshot : RunnableFuture<SnapshotResult<KeyedStateHandle>> in method public testDismissingSnapshot() : void in class org.apache.flink.contrib.streaming.state.RocksDBStateBackendTest |
From |
To |
|
Change Variable Type runnableFuture : RunnableFuture<OperatorStateHandle> to snapshot : RunnableFuture<SnapshotResult<OperatorStateHandle>> in method public testSnapshotRestoreSync() : void in class org.apache.flink.runtime.state.OperatorStateBackendTest |
From |
To |
|
Change Variable Type operatorSubtaskStateFromJobManager : OperatorSubtaskState to prioritizedOperatorSubtaskStates : PrioritizedOperatorSubtaskState in method public streamOperatorStateContext(operatorID OperatorID, operatorClassName String, keyContext KeyContext, keySerializer TypeSerializer<?>, streamTaskCloseableRegistry CloseableRegistry) : StreamOperatorStateContext in class org.apache.flink.streaming.api.operators.StreamTaskStateInitializerImpl |
From |
To |
|
Change Variable Type runnableFuture : RunnableFuture<OperatorStateHandle> to runnableFuture : RunnableFuture<SnapshotResult<OperatorStateHandle>> in method public testRestoreFailsIfSerializerDeserializationFails() : void in class org.apache.flink.runtime.state.OperatorStateBackendTest |
From |
To |
|
Change Variable Type ioCallable : AbstractAsyncCallableWithResources<KeyedStateHandle> to ioCallable : AbstractAsyncCallableWithResources<SnapshotResult<KeyedStateHandle>> in method private snapshotFully(checkpointId long, timestamp long, streamFactory CheckpointStreamFactory) : RunnableFuture<SnapshotResult<KeyedStateHandle>> in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend |
From |
To |
|
Rename Method public releaseJob(jobID JobID) : void renamed to public releaseLocalStateForAllocationId(allocationID AllocationID) : void in class org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager |
From |
To |
|
Rename Method public setTaskStateSnapshotsByCheckpointId(taskStateSnapshotsByCheckpointId Map<Long,TaskStateSnapshot>) : void renamed to public setJobManagerTaskStateSnapshotsByCheckpointId(jobManagerTaskStateSnapshotsByCheckpointId Map<Long,TaskStateSnapshot>) : void in class org.apache.flink.runtime.state.TestTaskStateManager |
From |
To |
|
Rename Method public getTaskStateSnapshotsByCheckpointId() : Map<Long,TaskStateSnapshot> renamed to public getJobManagerTaskStateSnapshotsByCheckpointId() : Map<Long,TaskStateSnapshot> in class org.apache.flink.runtime.state.TestTaskStateManager |
From |
To |
|
Rename Method public getTaskStateManager() : TaskExecutorLocalStateStoresManager renamed to public getTaskManagerStateStore() : TaskExecutorLocalStateStoresManager in class org.apache.flink.runtime.taskexecutor.TaskManagerServices |
From |
To |
|
Rename Method public reportStateHandles(checkpointMetaData CheckpointMetaData, checkpointMetrics CheckpointMetrics, acknowledgedState TaskStateSnapshot) : void renamed to public reportTaskStateSnapshots(checkpointMetaData CheckpointMetaData, checkpointMetrics CheckpointMetrics, acknowledgedState TaskStateSnapshot, localState TaskStateSnapshot) : void in class org.apache.flink.runtime.state.TaskStateManager |
From |
To |
|
Rename Method public reportStateHandles(checkpointMetaData CheckpointMetaData, checkpointMetrics CheckpointMetrics, acknowledgedState TaskStateSnapshot) : void renamed to public reportTaskStateSnapshots(checkpointMetaData CheckpointMetaData, checkpointMetrics CheckpointMetrics, acknowledgedState TaskStateSnapshot, localState TaskStateSnapshot) : void in class org.apache.flink.runtime.state.TestTaskStateManager |
From |
To |
|
Rename Method public getLastTaskStateSnapshot() : TaskStateSnapshot renamed to public getLastJobManagerTaskStateSnapshot() : TaskStateSnapshot in class org.apache.flink.runtime.state.TestTaskStateManager |
From |
To |
|
Rename Method public reportStateHandles(checkpointMetaData CheckpointMetaData, checkpointMetrics CheckpointMetrics, acknowledgedState TaskStateSnapshot) : void renamed to public reportTaskStateSnapshots(checkpointMetaData CheckpointMetaData, checkpointMetrics CheckpointMetrics, acknowledgedState TaskStateSnapshot, localState TaskStateSnapshot) : void in class org.apache.flink.runtime.state.TaskStateManagerImpl |
From |
To |
|
Rename Variable operatorStateHandles : List<OperatorStateHandle> to operatorSubtaskState : List<OperatorStateHandle> in method public testScaleUpAfterScalingDown() : void in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer011ITCase |
From |
To |
|
Rename Variable checkpointResponderMock : TestCheckpointResponder to testCheckpointResponder : TestCheckpointResponder in method public testStateReportingAndRetrieving() : void in class org.apache.flink.runtime.state.TaskStateManagerImplTest |
From |
To |
|
Rename Variable operatorSubtaskState_1 : OperatorSubtaskState to jmOperatorSubtaskState_1 : OperatorSubtaskState in method public testStateReportingAndRetrieving() : void in class org.apache.flink.runtime.state.TaskStateManagerImplTest |
From |
To |
|
Rename Variable taskStateSnapshot : TaskStateSnapshot to jmTaskStateSnapshot : TaskStateSnapshot in method public testStateReportingAndRetrieving() : void in class org.apache.flink.runtime.state.TaskStateManagerImplTest |
From |
To |
|
Rename Variable taskOperatorSubtaskStates : TaskStateSnapshot to jobManagerTaskOperatorSubtaskStates : TaskStateSnapshot in method public run() : void in class org.apache.flink.streaming.runtime.tasks.StreamTask.AsyncCheckpointRunnable |
From |
To |
|
Rename Variable runnableFuture : RunnableFuture<OperatorStateHandle> to snapshot : RunnableFuture<SnapshotResult<OperatorStateHandle>> in method public testSnapshotRestoreSync() : void in class org.apache.flink.runtime.state.OperatorStateBackendTest |
From |
To |
|
Rename Variable operatorSubtaskStateFromJobManager : OperatorSubtaskState to prioritizedOperatorSubtaskStates : PrioritizedOperatorSubtaskState in method public streamOperatorStateContext(operatorID OperatorID, operatorClassName String, keyContext KeyContext, keySerializer TypeSerializer<?>, streamTaskCloseableRegistry CloseableRegistry) : StreamOperatorStateContext in class org.apache.flink.streaming.api.operators.StreamTaskStateInitializerImpl |
From |
To |
|
Rename Variable taskStateSnapshot : TaskStateSnapshot to jmTaskStateSnapshot : TaskStateSnapshot in method public initializeState(jmOperatorStateHandles OperatorSubtaskState, tmOperatorStateHandles OperatorSubtaskState) : void in class org.apache.flink.streaming.util.AbstractStreamOperatorTestHarness |
From |
To |
|
Rename Variable operatorSubtaskState : OperatorSubtaskState to processedJmOpSubtaskState : OperatorSubtaskState in method public initializeState(jmOperatorStateHandles OperatorSubtaskState, tmOperatorStateHandles OperatorSubtaskState) : void in class org.apache.flink.streaming.util.AbstractStreamOperatorTestHarness |
From |
To |
|
Change Return Type Collection<OperatorStateHandle> to StateObjectCollection<OperatorStateHandle> in method public getManagedOperatorState() : StateObjectCollection<OperatorStateHandle> in class org.apache.flink.runtime.checkpoint.OperatorSubtaskState |
From |
To |
|
Change Return Type Collection<T> to StateObjectCollection<T> in method private singletonOrEmptyOnNull(element T) : StateObjectCollection<T> in class org.apache.flink.runtime.checkpoint.OperatorSubtaskState |
From |
To |
|
Change Return Type MemCheckpointStreamFactory.MemoryCheckpointOutputStream to BlockingCheckpointOutputStream in method public getLastCreatedStream() : BlockingCheckpointOutputStream in class org.apache.flink.runtime.util.BlockerCheckpointStreamFactory |
From |
To |
|
Change Return Type RunnableFuture<KeyedStateHandle> to RunnableFuture<SnapshotResult<KeyedStateHandle>> in method public getKeyedStateManagedFuture() : RunnableFuture<SnapshotResult<KeyedStateHandle>> in class org.apache.flink.streaming.api.operators.OperatorSnapshotFutures |
From |
To |
|
Change Return Type RunnableFuture<KeyedStateHandle> to RunnableFuture<SnapshotResult<KeyedStateHandle>> in method private snapshotFully(checkpointId long, timestamp long, streamFactory CheckpointStreamFactory) : RunnableFuture<SnapshotResult<KeyedStateHandle>> in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend |
From |
To |
|
Change Return Type RunnableFuture<OperatorStateHandle> to RunnableFuture<SnapshotResult<OperatorStateHandle>> in method public getOperatorStateStreamFuture() : RunnableFuture<SnapshotResult<OperatorStateHandle>> in class org.apache.flink.runtime.state.StateSnapshotContextSynchronousImpl |
From |
To |
|
Change Return Type OperatorStateHandle to SnapshotResult<OperatorStateHandle> in method public call() : SnapshotResult<OperatorStateHandle> in class org.apache.flink.streaming.runtime.tasks.StreamTaskTerminationTest.BlockingCallable |
From |
To |
|
Change Return Type Collection<KeyedStateHandle> to StateObjectCollection<KeyedStateHandle> in method public getManagedKeyedState() : StateObjectCollection<KeyedStateHandle> in class org.apache.flink.runtime.checkpoint.OperatorSubtaskState |
From |
To |
|
Change Return Type RunnableFuture<KeyedStateHandle> to RunnableFuture<SnapshotResult<KeyedStateHandle>> in method public snapshot(checkpointId long, timestamp long, streamFactory CheckpointStreamFactory, checkpointOptions CheckpointOptions) : RunnableFuture<SnapshotResult<KeyedStateHandle>> in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend |
From |
To |
|
Change Return Type RunnableFuture<OperatorStateHandle> to RunnableFuture<SnapshotResult<OperatorStateHandle>> in method public snapshot(checkpointId long, timestamp long, streamFactory CheckpointStreamFactory, checkpointOptions CheckpointOptions) : RunnableFuture<SnapshotResult<OperatorStateHandle>> in class org.apache.flink.runtime.state.DefaultOperatorStateBackend |
From |
To |
|
Change Return Type RunnableFuture<OperatorStateHandle> to RunnableFuture<SnapshotResult<OperatorStateHandle>> in method public getOperatorStateManagedFuture() : RunnableFuture<SnapshotResult<OperatorStateHandle>> in class org.apache.flink.streaming.api.operators.OperatorSnapshotFutures |
From |
To |
|
Change Return Type RunnableFuture<KeyedStateHandle> to RunnableFuture<SnapshotResult<KeyedStateHandle>> in method public getKeyedStateStreamFuture() : RunnableFuture<SnapshotResult<KeyedStateHandle>> in class org.apache.flink.runtime.state.StateSnapshotContextSynchronousImpl |
From |
To |
|
Change Return Type RunnableFuture<KeyedStateHandle> to RunnableFuture<SnapshotResult<KeyedStateHandle>> in method private snapshotIncrementally(checkpointId long, checkpointTimestamp long, checkpointStreamFactory CheckpointStreamFactory) : RunnableFuture<SnapshotResult<KeyedStateHandle>> in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend |
From |
To |
|
Change Return Type RunnableFuture<KeyedStateHandle> to RunnableFuture<SnapshotResult<KeyedStateHandle>> in method public getKeyedStateRawFuture() : RunnableFuture<SnapshotResult<KeyedStateHandle>> in class org.apache.flink.streaming.api.operators.OperatorSnapshotFutures |
From |
To |
|
Change Return Type Collection<KeyedStateHandle> to StateObjectCollection<KeyedStateHandle> in method public getRawKeyedState() : StateObjectCollection<KeyedStateHandle> in class org.apache.flink.runtime.checkpoint.OperatorSubtaskState |
From |
To |
|
Change Return Type Collection<OperatorStateHandle> to StateObjectCollection<OperatorStateHandle> in method public getRawOperatorState() : StateObjectCollection<OperatorStateHandle> in class org.apache.flink.runtime.checkpoint.OperatorSubtaskState |
From |
To |
|
Change Return Type RunnableFuture<KeyedStateHandle> to RunnableFuture<SnapshotResult<KeyedStateHandle>> in method public snapshot(checkpointId long, timestamp long, streamFactory CheckpointStreamFactory, checkpointOptions CheckpointOptions) : RunnableFuture<SnapshotResult<KeyedStateHandle>> in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend |
From |
To |
|
Change Return Type RunnableFuture<OperatorStateHandle> to RunnableFuture<SnapshotResult<OperatorStateHandle>> in method public getOperatorStateRawFuture() : RunnableFuture<SnapshotResult<OperatorStateHandle>> in class org.apache.flink.streaming.api.operators.OperatorSnapshotFutures |
From |
To |
|
Change Attribute Type operatorStateRawFuture : RunnableFuture<OperatorStateHandle> to operatorStateRawFuture : RunnableFuture<SnapshotResult<OperatorStateHandle>> in class org.apache.flink.streaming.api.operators.OperatorSnapshotFutures |
From |
To |
|
Change Attribute Type managedKeyedState : Collection<KeyedStateHandle> to managedKeyedState : StateObjectCollection<KeyedStateHandle> in class org.apache.flink.runtime.checkpoint.OperatorSubtaskState |
From |
To |
|
Change Attribute Type taskStateManagers : Map<JobID,Map<JobVertexSubtaskKey,TaskLocalStateStore>> to taskStateStoresByAllocationID : Map<AllocationID,Map<JobVertexSubtaskKey,TaskLocalStateStoreImpl>> in class org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager |
From |
To |
|
Change Attribute Type operatorStateManagedFuture : RunnableFuture<OperatorStateHandle> to operatorStateManagedFuture : RunnableFuture<SnapshotResult<OperatorStateHandle>> in class org.apache.flink.streaming.api.operators.OperatorSnapshotFutures |
From |
To |
|
Change Attribute Type managedOperatorState : Collection<OperatorStateHandle> to managedOperatorState : StateObjectCollection<OperatorStateHandle> in class org.apache.flink.runtime.checkpoint.OperatorSubtaskState |
From |
To |
|
Change Attribute Type rawKeyedState : Collection<KeyedStateHandle> to rawKeyedState : StateObjectCollection<KeyedStateHandle> in class org.apache.flink.runtime.checkpoint.OperatorSubtaskState |
From |
To |
|
Change Attribute Type enableIncrementalCheckpointing : Boolean to enableIncrementalCheckpointing : TernaryBoolean in class org.apache.flink.contrib.streaming.state.RocksDBStateBackend |
From |
To |
|
Change Attribute Type keyedStateRawFuture : RunnableFuture<KeyedStateHandle> to keyedStateRawFuture : RunnableFuture<SnapshotResult<KeyedStateHandle>> in class org.apache.flink.streaming.api.operators.OperatorSnapshotFutures |
From |
To |
|
Change Attribute Type rawOperatorState : Collection<OperatorStateHandle> to rawOperatorState : StateObjectCollection<OperatorStateHandle> in class org.apache.flink.runtime.checkpoint.OperatorSubtaskState |
From |
To |
|
Change Attribute Type lastCreatedStream : MemCheckpointStreamFactory.MemoryCheckpointOutputStream to lastCreatedStream : BlockingCheckpointOutputStream in class org.apache.flink.runtime.util.BlockerCheckpointStreamFactory |
From |
To |
|
Change Attribute Type keyedStateManagedFuture : RunnableFuture<KeyedStateHandle> to keyedStateManagedFuture : RunnableFuture<SnapshotResult<KeyedStateHandle>> in class org.apache.flink.streaming.api.operators.OperatorSnapshotFutures |
From |
To |
|
Change Attribute Type stateSize : long to delegateStateHandle : StreamStateHandle in class org.apache.flink.runtime.state.OperatorStreamStateHandle |
From |
To |
|
Rename Parameter operatorStateHandles : OperatorSubtaskState to operatorSubtaskState : OperatorSubtaskState in method private runOperator(taskConfiguration Configuration, executionConfig ExecutionConfig, operator OneInputStreamOperator<Long,Long>, keySelector KeySelector<Long,Long>, isKeyedState boolean, stateBackend StateBackend, classLoader ClassLoader, operatorSubtaskState OperatorSubtaskState, input Iterable<Long>) : OperatorSubtaskState in class org.apache.flink.test.typeserializerupgrade.PojoSerializerUpgradeTest |
From |
To |
|
Rename Parameter taskStateSnapshotsByCheckpointId : Map<Long,TaskStateSnapshot> to jobManagerTaskStateSnapshotsByCheckpointId : Map<Long,TaskStateSnapshot> in method public setJobManagerTaskStateSnapshotsByCheckpointId(jobManagerTaskStateSnapshotsByCheckpointId Map<Long,TaskStateSnapshot>) : void in class org.apache.flink.runtime.state.TestTaskStateManager |
From |
To |
|
Rename Parameter operatorSubtaskStateFromJobManager : OperatorSubtaskState to restoreStateAlternatives : Iterator<StateObjectCollection<OperatorStateHandle>> in method protected rawOperatorStateInputs(restoreStateAlternatives Iterator<StateObjectCollection<OperatorStateHandle>>) : CloseableIterable<StatePartitionStreamProvider> in class org.apache.flink.streaming.api.operators.StreamTaskStateInitializerImpl |
From |
To |
|
Rename Parameter jobID : JobID to allocationID : AllocationID in method public releaseLocalStateForAllocationId(allocationID AllocationID) : void in class org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager |
From |
To |
|
Rename Parameter operatorSubtaskStateFromJobManager : OperatorSubtaskState to restoreStateAlternatives : Iterator<StateObjectCollection<KeyedStateHandle>> in method protected rawKeyedStateInputs(restoreStateAlternatives Iterator<StateObjectCollection<KeyedStateHandle>>) : CloseableIterable<KeyGroupStatePartitionStreamProvider> in class org.apache.flink.streaming.api.operators.StreamTaskStateInitializerImpl |
From |
To |
|
Rename Parameter operatorStateHandles : OperatorSubtaskState to jmOperatorStateHandles : OperatorSubtaskState in method public initializeState(jmOperatorStateHandles OperatorSubtaskState, tmOperatorStateHandles OperatorSubtaskState) : void in class org.apache.flink.streaming.util.AbstractStreamOperatorTestHarness |
From |
To |
|
Rename Parameter taskStateManager : TaskExecutorLocalStateStoresManager to taskManagerStateStore : TaskExecutorLocalStateStoresManager in method package TaskManagerServices(taskManagerLocation TaskManagerLocation, memoryManager MemoryManager, ioManager IOManager, networkEnvironment NetworkEnvironment, broadcastVariableManager BroadcastVariableManager, fileCache FileCache, taskSlotTable TaskSlotTable, jobManagerTable JobManagerTable, jobLeaderService JobLeaderService, taskManagerStateStore TaskExecutorLocalStateStoresManager) in class org.apache.flink.runtime.taskexecutor.TaskManagerServices |
From |
To |