|
Change Parameter Type harness : OneInputStreamTaskTestHarness<Tuple3<String,Integer,Integer>,Tuple3<String,Integer,Integer>> to harness : OneInputStreamOperatorTestHarness<Tuple3<String,Integer,Integer>,Tuple3<String,Integer,Integer>> in method protected verifyResultsDataPersistenceUponMissedNotify(harness OneInputStreamOperatorTestHarness<Tuple3<String,Integer,Integer>,Tuple3<String,Integer,Integer>>, sink CassandraTupleWriteAheadSink<Tuple3<String,Integer,Integer>>) : void in class org.apache.flink.streaming.connectors.cassandra.CassandraConnectorITCase |
From |
To |
|
Change Parameter Type stateStorage : StateStorageHelper<MesosWorkerStore.Worker> to stateStorage : RetrievableStateStorageHelper<Worker> in method package ZooKeeperMesosWorkerStore(client CuratorFramework, storePath String, stateStorage RetrievableStateStorageHelper<Worker>) in class org.apache.flink.mesos.runtime.clusterframework.store.ZooKeeperMesosWorkerStore |
From |
To |
|
Change Parameter Type initialState : SerializedValue<StateHandle<?>> to chainedStateHandle : ChainedStateHandle<StreamStateHandle> in method public setInitialState(chainedStateHandle ChainedStateHandle<StreamStateHandle>, keyGroupsStateHandles List<KeyGroupsStateHandle>) : void in class org.apache.flink.runtime.executiongraph.Execution |
From |
To |
|
Change Parameter Type state : SerializedValue<StateHandle<?>> to state : ChainedStateHandle<StreamStateHandle> in method public acknowledgeTask(attemptID ExecutionAttemptID, state ChainedStateHandle<StreamStateHandle>, keyGroupsState List<KeyGroupsStateHandle>) : boolean in class org.apache.flink.runtime.checkpoint.PendingCheckpoint |
From |
To |
|
Change Parameter Type state : StreamTaskState to in : FSDataInputStream in method public restoreState(in FSDataInputStream) : void in class org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator |
From |
To |
|
Change Parameter Type state : StreamTaskState to state : FSDataInputStream in method public restoreState(state FSDataInputStream) : void in class org.apache.flink.cep.operator.AbstractKeyedCEPPatternOperator |
From |
To |
|
Change Parameter Type harness : OneInputStreamTaskTestHarness<Tuple3<String,Integer,Integer>,Tuple3<String,Integer,Integer>> to harness : OneInputStreamOperatorTestHarness<Tuple3<String,Integer,Integer>,Tuple3<String,Integer,Integer>> in method protected verifyResultsIdealCircumstances(harness OneInputStreamOperatorTestHarness<Tuple3<String,Integer,Integer>,Tuple3<String,Integer,Integer>>, sink CassandraTupleWriteAheadSink<Tuple3<String,Integer,Integer>>) : void in class org.apache.flink.streaming.connectors.cassandra.CassandraConnectorITCase |
From |
To |
|
Change Parameter Type stateHandleAndPath : Tuple2<StateHandle<CompletedCheckpoint>,String> to stateHandleAndPath : Tuple2<RetrievableStateHandle<CompletedCheckpoint>,String> in method private removeFromZooKeeperAndDiscardCheckpoint(stateHandleAndPath Tuple2<RetrievableStateHandle<CompletedCheckpoint>,String>) : void in class org.apache.flink.runtime.checkpoint.ZooKeeperCompletedCheckpointStore |
From |
To |
|
Change Parameter Type state : SerializedValue<StateHandle<?>> to state : ChainedStateHandle<StreamStateHandle> in method public AcknowledgeCheckpoint(job JobID, taskExecutionId ExecutionAttemptID, checkpointId long, state ChainedStateHandle<StreamStateHandle>, keyGroupStateAndSizes List<KeyGroupsStateHandle>) in class org.apache.flink.runtime.messages.checkpoint.AcknowledgeCheckpoint |
From |
To |
|
Change Parameter Type harness : OneInputStreamTaskTestHarness<Tuple3<String,Integer,Integer>,Tuple3<String,Integer,Integer>> to harness : OneInputStreamOperatorTestHarness<Tuple3<String,Integer,Integer>,Tuple3<String,Integer,Integer>> in method protected verifyResultsDataDiscardingUponRestore(harness OneInputStreamOperatorTestHarness<Tuple3<String,Integer,Integer>,Tuple3<String,Integer,Integer>>, sink CassandraTupleWriteAheadSink<Tuple3<String,Integer,Integer>>) : void in class org.apache.flink.streaming.connectors.cassandra.CassandraConnectorITCase |
From |
To |
|
Change Parameter Type stateSize : long to keyGroupStateAndSizes : List<KeyGroupsStateHandle> in method public AcknowledgeCheckpoint(job JobID, taskExecutionId ExecutionAttemptID, checkpointId long, state ChainedStateHandle<StreamStateHandle>, keyGroupStateAndSizes List<KeyGroupsStateHandle>) in class org.apache.flink.runtime.messages.checkpoint.AcknowledgeCheckpoint |
From |
To |
|
Change Parameter Type harness : OneInputStreamTaskTestHarness<Tuple1<Integer>,Tuple1<Integer>> to harness : OneInputStreamOperatorTestHarness<Tuple1<Integer>,Tuple1<Integer>> in method protected verifyResultsIdealCircumstances(harness OneInputStreamOperatorTestHarness<Tuple1<Integer>,Tuple1<Integer>>, sink ListSink) : void in class org.apache.flink.streaming.runtime.operators.GenericWriteAheadSinkTest |
From |
To |
|
Change Parameter Type stateStorage : StateStorageHelper<CompletedCheckpoint> to stateStorage : RetrievableStateStorageHelper<CompletedCheckpoint> in method public ZooKeeperCompletedCheckpointStore(maxNumberOfCheckpointsToRetain int, userClassLoader ClassLoader, client CuratorFramework, checkpointsPath String, stateStorage RetrievableStateStorageHelper<CompletedCheckpoint>) in class org.apache.flink.runtime.checkpoint.ZooKeeperCompletedCheckpointStore |
From |
To |
|
Change Parameter Type storage : StateStorageHelper to storage : RetrievableStateStorageHelper<T> in method public ZooKeeperStateHandleStore(client CuratorFramework, storage RetrievableStateStorageHelper<T>) in class org.apache.flink.runtime.zookeeper.ZooKeeperStateHandleStore |
From |
To |
|
Change Parameter Type operatorState : SerializedValue<StateHandle<?>> to operatorState : ChainedStateHandle<StreamStateHandle> in method package createDeploymentDescriptor(executionId ExecutionAttemptID, targetSlot SimpleSlot, operatorState ChainedStateHandle<StreamStateHandle>, keyGroupStates List<KeyGroupsStateHandle>, attemptNumber int) : TaskDeploymentDescriptor in class org.apache.flink.runtime.executiongraph.ExecutionVertex |
From |
To |
|
Change Parameter Type state : StreamTaskState to in : FSDataInputStream in method public restoreState(in FSDataInputStream) : void in class org.apache.flink.streaming.api.operators.StreamOperator |
From |
To |
|
Change Parameter Type harness : OneInputStreamTaskTestHarness<Tuple1<Integer>,Tuple1<Integer>> to harness : OneInputStreamOperatorTestHarness<Tuple1<Integer>,Tuple1<Integer>> in method protected verifyResultsDataDiscardingUponRestore(harness OneInputStreamOperatorTestHarness<Tuple1<Integer>,Tuple1<Integer>>, sink ListSink) : void in class org.apache.flink.streaming.runtime.operators.GenericWriteAheadSinkTest |
From |
To |
|
Change Parameter Type harness : OneInputStreamTaskTestHarness<Tuple1<Integer>,Tuple1<Integer>> to harness : OneInputStreamOperatorTestHarness<Tuple1<Integer>,Tuple1<Integer>> in method protected verifyResultsDataPersistenceUponMissedNotify(harness OneInputStreamOperatorTestHarness<Tuple1<Integer>,Tuple1<Integer>>, sink ListSink) : void in class org.apache.flink.streaming.runtime.operators.GenericWriteAheadSinkTest |
From |
To |
|
Change Parameter Type stateStorage : StateStorageHelper<SubmittedJobGraph> to stateStorage : RetrievableStateStorageHelper<SubmittedJobGraph> in method public ZooKeeperSubmittedJobGraphStore(client CuratorFramework, currentJobsPath String, stateStorage RetrievableStateStorageHelper<SubmittedJobGraph>) in class org.apache.flink.runtime.jobmanager.ZooKeeperSubmittedJobGraphStore |
From |
To |
|
Change Parameter Type state : StreamTaskState to is : FSDataInputStream in method public restoreState(is FSDataInputStream) : void in class org.apache.flink.streaming.api.functions.source.ContinuousFileReaderOperator |
From |
To |
|
Change Parameter Type taskState : StreamTaskState to in : FSDataInputStream in method public restoreState(in FSDataInputStream) : void in class org.apache.flink.streaming.runtime.operators.windowing.AbstractAlignedProcessingTimeWindowOperator |
From |
To |
|
Change Parameter Type snapshot : StreamTaskState to snapshot : StreamStateHandle in method public restore(snapshot StreamStateHandle) : void in class org.apache.flink.streaming.util.OneInputStreamOperatorTestHarness |
From |
To |
|
Change Parameter Type operatorState : SerializedValue<StateHandle<?>> to operatorState : ChainedStateHandle<StreamStateHandle> in method public TaskDeploymentDescriptor(jobID JobID, jobName String, vertexID JobVertexID, executionId ExecutionAttemptID, serializedExecutionConfig SerializedValue<ExecutionConfig>, taskName String, indexInSubtaskGroup int, numberOfSubtasks int, attemptNumber int, jobConfiguration Configuration, taskConfiguration Configuration, invokableClassName String, producedPartitions List<ResultPartitionDeploymentDescriptor>, inputGates List<InputGateDeploymentDescriptor>, requiredJarFiles List<BlobKey>, requiredClasspaths List<URL>, targetSlotNumber int, operatorState ChainedStateHandle<StreamStateHandle>, keyGroupState List<KeyGroupsStateHandle>) in class org.apache.flink.runtime.deployment.TaskDeploymentDescriptor |
From |
To |
|
Change Variable Type snapshot : StreamTaskState to snapshot : StreamStateHandle in method public testCEPOperatorCheckpointing() : void in class org.apache.flink.cep.operator.CEPOperatorTest |
From |
To |
|
Change Variable Type snapshot : StreamTaskState to snapshot : StreamStateHandle in method public testKeyedCEPOperatorCheckpointingWithRocksDB() : void in class org.apache.flink.cep.operator.CEPOperatorTest |
From |
To |
|
Change Variable Type allStateHandles : List<Tuple2<StateHandle<T>,String>> to allStateHandles : List<Tuple2<RetrievableStateHandle<T>,String>> in method public removeAndDiscardAllState() : void in class org.apache.flink.runtime.zookeeper.ZooKeeperStateHandleStore |
From |
To |
|
Change Variable Type stateHandle : StateHandle<T> to stateHandle : RetrievableStateHandle<T> in method public getAllSortedByName() : List<Tuple2<RetrievableStateHandle<T>,String>> in class org.apache.flink.runtime.zookeeper.ZooKeeperStateHandleStore |
From |
To |
|
Change Variable Type savepoint : SavepointV0 to savepoint : SavepointV1 in method public testTriggerSavepointAndResume() : void in class org.apache.flink.test.checkpointing.SavepointITCase |
From |
To |
|
Change Variable Type actual : List<Tuple2<StateHandle<Long>,String>> to actual : List<Tuple2<RetrievableStateHandle<Long>,String>> in method public testGetAllSortedByName() : void in class org.apache.flink.runtime.zookeeper.ZooKeeperStateHandleStoreITCase |
From |
To |
|
Change Variable Type handle4 : StreamStateHandle to handle4 : FileStateHandle in method public testStateOutputStream() : void in class org.apache.flink.hdfstests.FileStateBackendTest |
From |
To |
|
Change Variable Type stateHandle : Tuple2<StateHandle<CompletedCheckpoint>,String> to stateHandle : Tuple2<RetrievableStateHandle<CompletedCheckpoint>,String> in method public getAllCheckpoints() : List<CompletedCheckpoint> in class org.apache.flink.runtime.checkpoint.ZooKeeperCompletedCheckpointStore |
From |
To |
|
Change Variable Type handle1 : FileStreamStateHandle to handle1 : FileStateHandle in method public testStateOutputStream() : void in class org.apache.flink.runtime.state.FileStateBackendTest |
From |
To |
|
Change Variable Type latest : Tuple2<StateHandle<CompletedCheckpoint>,String> to latest : Tuple2<RetrievableStateHandle<CompletedCheckpoint>,String> in method public recover() : void in class org.apache.flink.runtime.checkpoint.ZooKeeperCompletedCheckpointStore |
From |
To |
|
Change Variable Type stateHandles : List<Tuple2<StateHandle<T>,String>> to stateHandles : List<Tuple2<RetrievableStateHandle<T>,String>> in method public getAllSortedByName() : List<Tuple2<RetrievableStateHandle<T>,String>> in class org.apache.flink.runtime.zookeeper.ZooKeeperStateHandleStore |
From |
To |
|
Change Variable Type stateHandle : StateHandle<T> to stateHandle : RetrievableStateHandle<T> in method public removeAndDiscardState(pathInZooKeeper String) : void in class org.apache.flink.runtime.zookeeper.ZooKeeperStateHandleStore |
From |
To |
|
Change Variable Type kvStateForTaskMap : Map<Integer,SerializedValue<StateHandle<?>>> to subtaskKeyGroupStates : List<KeyGroupsStateHandle> in method public restoreLatestCheckpointedState(tasks Map<JobVertexID,ExecutionJobVertex>, errorIfNoCheckpoint boolean, allOrNothingState boolean) : boolean in class org.apache.flink.runtime.checkpoint.CheckpointCoordinator |
From |
To |
|
Change Variable Type keyGroupPartitions : List<Set<Integer>> to keyGroupPartitions : List<KeyGroupRange> in method public restoreLatestCheckpointedState(tasks Map<JobVertexID,ExecutionJobVertex>, errorIfNoCheckpoint boolean, allOrNothingState boolean) : boolean in class org.apache.flink.runtime.checkpoint.CheckpointCoordinator |
From |
To |
|
Change Variable Type stored : SavepointV0 to stored : SavepointV1 in method public testStoreLoadDispose() : void in class org.apache.flink.runtime.checkpoint.savepoint.FsSavepointStoreTest |
From |
To |
|
Change Variable Type snapshot : StreamTaskState to snapshot : StreamStateHandle in method public testSessionWindowsWithCountTrigger() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorTest |
From |
To |
|
Change Variable Type submitted : List<Tuple2<StateHandle<SubmittedJobGraph>,String>> to submitted : List<Tuple2<RetrievableStateHandle<SubmittedJobGraph>,String>> in method public recoverJobGraphs() : List<SubmittedJobGraph> in class org.apache.flink.runtime.jobmanager.ZooKeeperSubmittedJobGraphStore |
From |
To |
|
Change Variable Type handle1 : FileStreamStateHandle to handle1 : FileStateHandle in method public testStateOutputStream() : void in class org.apache.flink.hdfstests.FileStateBackendTest |
From |
To |
|
Change Variable Type handle : Tuple2<StateHandle<MesosWorkerStore.Worker>,String> to handle : Tuple2<RetrievableStateHandle<Worker>,String> in method public recoverWorkers() : List<MesosWorkerStore.Worker> in class org.apache.flink.mesos.runtime.clusterframework.store.ZooKeeperMesosWorkerStore |
From |
To |
|
Change Variable Type snapshot2 : StreamTaskState to snapshot2 : StreamStateHandle in method public testKeyedCEPOperatorCheckpointing() : void in class org.apache.flink.cep.operator.CEPOperatorTest |
From |
To |
|
Change Variable Type stateStorage : StateStorageHelper<Long> to stateStorage : RetrievableStateStorageHelper<Long> in method public testReplaceNonExistingPath() : void in class org.apache.flink.runtime.zookeeper.ZooKeeperStateHandleStoreITCase |
From |
To |
|
Change Variable Type snapshot : StreamTaskState to snapshot : StreamStateHandle in method public testSnapshotingAndRecovery() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowingTestHarnessTest |
From |
To |
|
Change Variable Type stateHandles : List<Tuple2<StateHandle<T>,String>> to stateHandles : List<Tuple2<RetrievableStateHandle<T>,String>> in method public getAll() : List<Tuple2<RetrievableStateHandle<T>,String>> in class org.apache.flink.runtime.zookeeper.ZooKeeperStateHandleStore |
From |
To |
|
Change Variable Type in : DataInputView to inView : DataInputViewStreamWrapper in method public restoreState(in FSDataInputStream) : void in class org.apache.flink.streaming.runtime.operators.windowing.AbstractAlignedProcessingTimeWindowOperator |
From |
To |
|
Change Variable Type stateHandle : StateHandle<T> to newStateHandle : RetrievableStateHandle<T> in method public replace(pathInZooKeeper String, expectedVersion int, state T) : void in class org.apache.flink.runtime.zookeeper.ZooKeeperStateHandleStore |
From |
To |
|
Change Variable Type state : StreamTaskState to state : StreamStateHandle in method public checkpointRestoreWithPendingWindowTumbling() : void in class org.apache.flink.streaming.runtime.operators.windowing.AggregatingAlignedProcessingTimeWindowOperatorTest |
From |
To |
|
Change Variable Type that : SavepointV0 to that : SavepointV1 in method public equals(o Object) : boolean in class org.apache.flink.runtime.checkpoint.savepoint.SavepointV1 |
From |
To |
|
Change Variable Type handle : StateHandle<DataInputView> to handle : StreamStateHandle in method private saveHandleInState(checkpointId long, timestamp long) : void in class org.apache.flink.streaming.runtime.operators.GenericWriteAheadSink |
From |
To |
|
Change Variable Type handle : Tuple2<Long,StateHandle<DataInputView>> to handle : Tuple2<Long,StreamStateHandle> in method public notifyOfCompletedCheckpoint(checkpointId long) : void in class org.apache.flink.streaming.runtime.operators.GenericWriteAheadSink |
From |
To |
|
Change Variable Type actual : StateHandle<Long> to actual : RetrievableStateHandle<Long> in method public testGetAndExists() : void in class org.apache.flink.runtime.zookeeper.ZooKeeperStateHandleStoreITCase |
From |
To |
|
Change Variable Type snapshot : StreamTaskState to snapshot : StreamStateHandle in method public testPointSessions() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorTest |
From |
To |
|
Change Variable Type fsState : AbstractFileStateHandle to fileStateHandle : FileStateHandle in method public testCheckpointsRemovedWithJobManagerBackendOnShutdown() : void in class org.apache.flink.test.checkpointing.SavepointITCase |
From |
To |
|
Change Variable Type snapshot : StreamTaskState to snapshot : StreamStateHandle in method public testKeyedCEPOperatorCheckpointing() : void in class org.apache.flink.cep.operator.CEPOperatorTest |
From |
To |
|
Change Variable Type stateHandleAndPath : Tuple2<StateHandle<T>,String> to stateHandleAndPath : Tuple2<RetrievableStateHandle<T>,String> in method public removeAndDiscardAllState() : void in class org.apache.flink.runtime.zookeeper.ZooKeeperStateHandleStore |
From |
To |
|
Change Variable Type state : StreamTaskState to state : StreamStateHandle in method public checkpointRestoreWithPendingWindowTumbling() : void in class org.apache.flink.streaming.runtime.operators.windowing.AccumulatingAlignedProcessingTimeWindowOperatorTest |
From |
To |
|
Change Variable Type lockingHandle : StateHandle<Serializable> to lockingHandle : StreamStateHandle in method public testRestoreWithInterrupt() : void in class org.apache.flink.streaming.runtime.tasks.InterruptSensitiveRestoreTest |
From |
To |
|
Change Variable Type expected : SavepointV0 to expected : SavepointV1 in method public testSerializeDeserializeV1() : void in class org.apache.flink.runtime.checkpoint.savepoint.SavepointV1SerializerTest |
From |
To |
|
Change Variable Type state : SerializedValue<StateHandle<?>> to state : ChainedStateHandle<StreamStateHandle> in method public restoreLatestCheckpointedState(tasks Map<JobVertexID,ExecutionJobVertex>, errorIfNoCheckpoint boolean, allOrNothingState boolean) : boolean in class org.apache.flink.runtime.checkpoint.CheckpointCoordinator |
From |
To |
|
Change Variable Type out : AbstractStateBackend.CheckpointStateOutputView to outView : DataOutputViewStreamWrapper in method public snapshotState(out FSDataOutputStream, checkpointId long, timestamp long) : void in class org.apache.flink.streaming.runtime.operators.windowing.AbstractAlignedProcessingTimeWindowOperator |
From |
To |
|
Change Variable Type stateHandle : StateHandle<T> to storeHandle : RetrievableStateHandle<T> in method public add(pathInZooKeeper String, state T, createMode CreateMode) : RetrievableStateHandle<T> in class org.apache.flink.runtime.zookeeper.ZooKeeperStateHandleStore |
From |
To |
|
Change Variable Type stateHandle : LongStateHandle to stateHandle : LongRetrievableStateHandle in method public store(state Long) : RetrievableStateHandle<Long> in class org.apache.flink.runtime.zookeeper.ZooKeeperStateHandleStoreITCase.LongStateStorage |
From |
To |
|
Change Variable Type val : Tuple2<StateHandle<Long>,String> to val : Tuple2<RetrievableStateHandle<Long>,String> in method public testGetAll() : void in class org.apache.flink.runtime.zookeeper.ZooKeeperStateHandleStoreITCase |
From |
To |
|
Change Variable Type snapshot2 : StreamTaskState to snapshot2 : StreamStateHandle in method public testCEPOperatorCheckpointing() : void in class org.apache.flink.cep.operator.CEPOperatorTest |
From |
To |
|
Change Variable Type stateStorage : StateStorageHelper<CompletedCheckpoint> to stateStorage : RetrievableStateStorageHelper<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 snapshot : StreamTaskState to snapshot : StreamStateHandle in method private testSlidingEventTimeWindows(testHarness OneInputStreamOperatorTestHarness<Tuple2<String,Integer>,Tuple2<String,Integer>>) : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorTest |
From |
To |
|
Change Variable Type snapshot2 : StreamTaskState to snapshot2 : StreamStateHandle in method public testKeyedCEPOperatorCheckpointingWithRocksDB() : void in class org.apache.flink.cep.operator.CEPOperatorTest |
From |
To |
|
Change Variable Type state : StateHandle<Long> to state : RetrievableStreamStateHandle<Long> in method public triggerCheckpoint(checkpointId long, timestamp long) : boolean in class org.apache.flink.runtime.jobmanager.JobManagerHARecoveryTest.BlockingStatefulInvokable |
From |
To |
|
Change Variable Type checkpoint : Tuple2<StateHandle<CompletedCheckpoint>,String> to checkpoint : Tuple2<RetrievableStateHandle<CompletedCheckpoint>,String> in method public shutdown() : void in class org.apache.flink.runtime.checkpoint.ZooKeeperCompletedCheckpointStore |
From |
To |
|
Change Variable Type op : StatefulTask<?> to op : StatefulTask in method public run() : void in class org.apache.flink.runtime.taskmanager.Task |
From |
To |
|
Change Variable Type stateHandle : StateHandle<T> to stateHandle : RetrievableStateHandle<T> in method public getAll() : List<Tuple2<RetrievableStateHandle<T>,String>> in class org.apache.flink.runtime.zookeeper.ZooKeeperStateHandleStore |
From |
To |
|
Change Variable Type statefulTask : StatefulTask<?> to statefulTask : StatefulTask in method public notifyCheckpointComplete(checkpointID long) : void in class org.apache.flink.runtime.taskmanager.Task |
From |
To |
|
Change Variable Type fsState : AbstractFileStateHandle to fileStateHandle : FileStateHandle in method public testTriggerSavepointAndResume() : void in class org.apache.flink.test.checkpointing.SavepointITCase |
From |
To |
|
Change Variable Type handles : List<Tuple2<StateHandle<MesosWorkerStore.Worker>,String>> to handles : List<Tuple2<RetrievableStateHandle<Worker>,String>> in method public recoverWorkers() : List<MesosWorkerStore.Worker> in class org.apache.flink.mesos.runtime.clusterframework.store.ZooKeeperMesosWorkerStore |
From |
To |
|
Change Variable Type stateStorage : StateStorageHelper<SubmittedJobGraph> to stateStorage : RetrievableStateStorageHelper<SubmittedJobGraph> in method public createSubmittedJobGraphs(client CuratorFramework, configuration Configuration) : ZooKeeperSubmittedJobGraphStore in class org.apache.flink.runtime.util.ZooKeeperUtils |
From |
To |
|
Change Variable Type snapshot : StreamTaskState to snapshot : StreamStateHandle in method public testReduceSessionWindows() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorTest |
From |
To |
|
Change Variable Type snapshot : StreamTaskState to snapshot : StreamStateHandle in method public testRestoreAndSnapshotAreInSync() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorTest |
From |
To |
|
Change Variable Type savepoint : SavepointV0 to savepoint : SavepointV1 in method public testSavepointV1() : void in class org.apache.flink.runtime.checkpoint.savepoint.SavepointV1Test |
From |
To |
|
Change Variable Type oldStateHandle : StateHandle<T> to oldStateHandle : RetrievableStateHandle<T> in method public replace(pathInZooKeeper String, expectedVersion int, state T) : void in class org.apache.flink.runtime.zookeeper.ZooKeeperStateHandleStore |
From |
To |
|
Change Variable Type savepoint : SavepointV0 to savepoint : SavepointV1 in method public testCheckpointsRemovedWithJobManagerBackendOnShutdown() : void in class org.apache.flink.test.checkpointing.SavepointITCase |
From |
To |
|
Change Variable Type snapshot1 : StreamTaskState to snapshot1 : StreamStateHandle in method public testCheckpointWithoutNotify() : void in class org.apache.flink.streaming.connectors.fs.bucketing.BucketingSinkTest |
From |
To |
|
Change Variable Type stateHandle : StateHandle<CompletedCheckpoint> to stateHandle : RetrievableStateHandle<CompletedCheckpoint> in method public addCheckpoint(checkpoint CompletedCheckpoint) : void in class org.apache.flink.runtime.checkpoint.ZooKeeperCompletedCheckpointStore |
From |
To |
|
Change Variable Type snapshot : StreamTaskState to snapshot : StreamStateHandle in method public testSessionWindows() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorTest |
From |
To |
|
Change Variable Type snapshot : StreamTaskState to snapshot : StreamStateHandle in method public testCountTrigger() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorTest |
From |
To |
|
Change Variable Type state : StreamTaskState to state : StreamStateHandle in method public checkpointRestoreWithPendingWindowSliding() : void in class org.apache.flink.streaming.runtime.operators.windowing.AggregatingAlignedProcessingTimeWindowOperatorTest |
From |
To |
|
Change Variable Type serializer : SavepointV0Serializer to serializer : SavepointV1Serializer in method public testSerializeDeserializeV1() : void in class org.apache.flink.runtime.checkpoint.savepoint.SavepointV1SerializerTest |
From |
To |
|
Change Variable Type snapshot : StreamTaskState to snapshot : StreamStateHandle in method private testTumblingEventTimeWindows(testHarness OneInputStreamOperatorTestHarness<Tuple2<String,Integer>,Tuple2<String,Integer>>) : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorTest |
From |
To |
|
Change Variable Type task : OperatorExposingTask<IN> to sink : S in method public testIdealCircumstances() : void in class org.apache.flink.streaming.runtime.operators.WriteAheadSinkTestBase |
From |
To |
|
Change Variable Type initialCheckpoints : List<Tuple2<StateHandle<CompletedCheckpoint>,String>> to initialCheckpoints : List<Tuple2<RetrievableStateHandle<CompletedCheckpoint>,String>> in method public recover() : void in class org.apache.flink.runtime.checkpoint.ZooKeeperCompletedCheckpointStore |
From |
To |
|
Change Variable Type handle4 : FileStreamStateHandle to handle4 : StreamStateHandle in method public testStateOutputStream() : void in class org.apache.flink.runtime.state.FileStateBackendTest |
From |
To |
|
Change Variable Type state : StreamTaskState to state : StreamStateHandle in method public checkpointRestoreWithPendingWindowSliding() : void in class org.apache.flink.streaming.runtime.operators.windowing.AccumulatingAlignedProcessingTimeWindowOperatorTest |
From |
To |
|
Change Variable Type stateStorage : StateStorageHelper<MesosWorkerStore.Worker> to stateStorage : RetrievableStateStorageHelper<MesosWorkerStore.Worker> in method public createMesosWorkerStore(client CuratorFramework, configuration Configuration) : ZooKeeperMesosWorkerStore in class org.apache.flink.mesos.runtime.clusterframework.store.ZooKeeperMesosWorkerStore |
From |
To |
|
Change Variable Type statefulTask : StatefulTask<?> to statefulTask : StatefulTask in method public triggerCheckpointBarrier(checkpointID long, checkpointTimestamp long) : void in class org.apache.flink.runtime.taskmanager.Task |
From |
To |
|
Change Variable Type savepoint : SavepointV0 to savepoint : SavepointV1 in method public testLoadAndValidateSavepoint() : void in class org.apache.flink.runtime.checkpoint.savepoint.SavepointLoaderTest |
From |
To |
|
Change Variable Type jobStateHandle : Tuple2<StateHandle<SubmittedJobGraph>,String> to jobStateHandle : Tuple2<RetrievableStateHandle<SubmittedJobGraph>,String> in method public recoverJobGraphs() : List<SubmittedJobGraph> in class org.apache.flink.runtime.jobmanager.ZooKeeperSubmittedJobGraphStore |
From |
To |
|
Change Return Type StreamTaskState to void in method public snapshotState(out FSDataOutputStream, checkpointId long, timestamp long) : void in class org.apache.flink.streaming.runtime.operators.windowing.AbstractAlignedProcessingTimeWindowOperator |
From |
To |
|
Change Return Type List<Tuple2<StateHandle<T>,String>> to List<Tuple2<RetrievableStateHandle<T>,String>> in method public getAll() : List<Tuple2<RetrievableStateHandle<T>,String>> in class org.apache.flink.runtime.zookeeper.ZooKeeperStateHandleStore |
From |
To |
|
Change Return Type StateHandle<T> to RetrievableStateHandle<T> in method public store(state T) : RetrievableStateHandle<T> in class org.apache.flink.runtime.zookeeper.RetrievableStateStorageHelper |
From |
To |
|
Change Return Type StreamTaskState to StreamStateHandle in method public snapshot(checkpointId long, timestamp long) : StreamStateHandle in class org.apache.flink.streaming.util.OneInputStreamOperatorTestHarness |
From |
To |
|
Change Return Type StreamTaskState to StreamStateHandle in method public snapshot(checkpointId long, timestamp long) : StreamStateHandle in class org.apache.flink.streaming.util.WindowingTestHarness |
From |
To |
|
Change Return Type StreamTaskState to void in method public snapshotState(out FSDataOutputStream, checkpointId long, timestamp long) : void in class org.apache.flink.cep.operator.AbstractKeyedCEPPatternOperator |
From |
To |
|
Change Return Type StreamTaskState to void in method public snapshotState(out FSDataOutputStream, checkpointId long, timestamp long) : void in class org.apache.flink.streaming.api.operators.StreamOperator |
From |
To |
|
Change Return Type List<LongStateHandle> to List<LongRetrievableStateHandle> in method package getStateHandles() : List<LongRetrievableStateHandle> in class org.apache.flink.runtime.zookeeper.ZooKeeperStateHandleStoreITCase.LongStateStorage |
From |
To |
|
Change Return Type StreamTaskState to void in method public snapshotState(out FSDataOutputStream, checkpointId long, timestamp long) : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperator |
From |
To |
|
Change Return Type List<Tuple2<StateHandle<T>,String>> to List<Tuple2<RetrievableStateHandle<T>,String>> in method public getAllSortedByName() : List<Tuple2<RetrievableStateHandle<T>,String>> in class org.apache.flink.runtime.zookeeper.ZooKeeperStateHandleStore |
From |
To |
|
Change Return Type StateHandle<Long> to RetrievableStateHandle<Long> in method public store(state Long) : RetrievableStateHandle<Long> in class org.apache.flink.runtime.zookeeper.ZooKeeperStateHandleStoreITCase.LongStateStorage |
From |
To |
|
Change Return Type StateHandle<T> to RetrievableStateHandle<T> in method public add(pathInZooKeeper String, state T, createMode CreateMode) : RetrievableStateHandle<T> in class org.apache.flink.runtime.zookeeper.ZooKeeperStateHandleStore |
From |
To |
|
Change Return Type StateHandle<T> to RetrievableStateHandle<T> in method public add(pathInZooKeeper String, state T) : RetrievableStateHandle<T> in class org.apache.flink.runtime.zookeeper.ZooKeeperStateHandleStore |
From |
To |
|
Change Return Type StreamTaskState to void in method public snapshotState(os FSDataOutputStream, checkpointId long, timestamp long) : void in class org.apache.flink.streaming.api.functions.source.ContinuousFileReaderOperator |
From |
To |
|
Change Return Type TreeMap<Long,Tuple2<Long,StateHandle<DataInputView>>> to TreeMap<Long,Tuple2<Long,StreamStateHandle>> in method public getState(userCodeClassLoader ClassLoader) : TreeMap<Long,Tuple2<Long,StreamStateHandle>> in class org.apache.flink.streaming.runtime.operators.GenericWriteAheadSink.ExactlyOnceState |
From |
To |
|
Change Return Type SerializedValue<StateHandle<?>> to ChainedStateHandle<StreamStateHandle> in method public getOperatorState() : ChainedStateHandle<StreamStateHandle> in class org.apache.flink.runtime.deployment.TaskDeploymentDescriptor |
From |
To |
|
Change Return Type StateHandle<T> to RetrievableStateHandle<T> in method public store(state T) : RetrievableStateHandle<T> in class org.apache.flink.runtime.zookeeper.filesystem.FileSystemStateStorageHelper |
From |
To |
|
Change Return Type StateHandle<T> to RetrievableStateHandle<T> in method public get(pathInZooKeeper String) : RetrievableStateHandle<T> in class org.apache.flink.runtime.zookeeper.ZooKeeperStateHandleStore |
From |
To |