|
Change Return Type byte[] to List<byte[]> in method public snapshotState(checkpointId long, timestamp long) : List<byte[]> in class org.apache.flink.test.checkpointing.SavepointITCase.StatefulCounter |
From |
To |
|
Change Return Type Long to List<Long> in method public snapshotState(checkpointId long, timestamp long) : List<Long> in class org.apache.flink.test.checkpointing.UdfStreamOperatorCheckpointingITCase.StatefulMultipleSequence |
From |
To |
|
Change Return Type Integer to List<Integer> in method public snapshotState(checkpointId long, timestamp long) : List<Integer> in class org.apache.flink.test.checkpointing.StreamCheckpointNotifierITCase.GeneratingSourceFunction |
From |
To |
|
Change Return Type Long to List<Long> in method public snapshotState(checkpointId long, timestamp long) : List<Long> in class org.apache.flink.test.checkpointing.CoStreamCheckpointingITCase.StatefulCounterFunction |
From |
To |
|
Change Return Type Long to List<Long> in method public snapshotState(checkpointId long, timestamp long) : List<Long> in class org.apache.flink.test.checkpointing.StreamCheckpointNotifierITCase.OnceFailingReducer |
From |
To |
|
Change Return Type Integer to List<Integer> in method public snapshotState(checkpointId long, timestamp long) : List<Integer> in class org.apache.flink.test.checkpointing.RescalingITCase.NonPartitionedStateSource |
From |
To |
|
Change Return Type Tuple2<Integer,BitSet> to List<Tuple2<Integer,BitSet>> in method public snapshotState(checkpointId long, timestamp long) : List<Tuple2<Integer,BitSet>> in class org.apache.flink.streaming.connectors.kafka.testutils.ValidatingExactlyOnceSink |
From |
To |
|
Change Return Type Serializable to List<Serializable> in method public snapshotState(checkpointId long, timestamp long) : List<Serializable> in class org.apache.flink.streaming.runtime.tasks.SourceStreamTaskTest.MockSource |
From |
To |
|
Change Return Type Integer to List<Integer> in method public snapshotState(checkpointId long, timestamp long) : List<Integer> in class org.apache.flink.streaming.connectors.fs.bucketing.BucketingSinkFaultToleranceITCase.StringGeneratingSourceFunction |
From |
To |
|
Change Return Type Integer to List<Integer> in method public snapshotState(checkpointId long, timestamp long) : List<Integer> in class org.apache.flink.test.checkpointing.StateCheckpointedITCase.StringGeneratingSourceFunction |
From |
To |
|
Change Return Type HashMap<Long,Integer> to List<HashMap<Long,Integer>> in method public snapshotState(checkpointId long, timestamp long) : List<HashMap<Long,Integer>> in class org.apache.flink.test.checkpointing.WindowCheckpointingITCase.ValidatingSink |
From |
To |
|
Change Return Type Integer to List<Integer> in method public snapshotState(checkpointId long, timestamp long) : List<Integer> in class org.apache.flink.test.checkpointing.CoStreamCheckpointingITCase.StringGeneratingSourceFunction |
From |
To |
|
Change Return Type HashMap<Long,Integer> to List<HashMap<Long,Integer>> in method public snapshotState(checkpointId long, timestamp long) : List<HashMap<Long,Integer>> in class org.apache.flink.test.checkpointing.AbstractEventTimeWindowCheckpointingITCase.ValidatingSink |
From |
To |
|
Change Return Type HashMap<String,PrefixCount> to List<HashMap<String,PrefixCount>> in method public snapshotState(checkpointId long, timestamp long) : List<HashMap<String,PrefixCount>> in class org.apache.flink.test.checkpointing.StateCheckpointedITCase.OnceFailingAggregator |
From |
To |
|
Change Return Type Integer to List<Integer> in method public snapshotState(checkpointId long, timestamp long) : List<Integer> in class org.apache.flink.streaming.connectors.cassandra.example.CassandraTupleWriteAheadSinkExample.MySource |
From |
To |
|
Change Return Type Long to List<Long> in method public snapshotState(checkpointId long, timestamp long) : List<Long> in class org.apache.flink.test.recovery.JobManagerHACheckpointRecoveryITCase.CheckpointedSequenceSource |
From |
To |
|
Change Return Type Integer to List<Integer> in method public snapshotState(checkpointId long, timestamp long) : List<Integer> in class org.apache.flink.test.classloading.jar.CheckpointingCustomKvStateProgram.InfiniteIntegerSource |
From |
To |
|
Change Return Type Long to List<Long> in method public snapshotState(checkpointId long, timestamp long) : List<Long> in class org.apache.flink.test.checkpointing.StateCheckpointedITCase.StatefulCounterFunction |
From |
To |
|
Change Return Type Integer to List<Integer> in method public snapshotState(checkpointId long, timestamp long) : List<Integer> in class org.apache.flink.test.checkpointing.PartitionedStateCheckpointingITCase.IntGeneratingSourceFunction |
From |
To |
|
Change Return Type Long to List<Long> in method public snapshotState(checkpointId long, timestamp long) : List<Long> in class org.apache.flink.test.checkpointing.StreamCheckpointingITCase.StringRichFilterFunction |
From |
To |
|
Change Return Type Integer to List<Integer> in method public snapshotState(checkpointId long, timestamp long) : List<Integer> in class org.apache.flink.streaming.connectors.kafka.testutils.FailingIdentityMapper |
From |
To |
|
Change Return Type CountingSink to List<CountingSink> in method public snapshotState(checkpointId long, timestamp long) : List<CountingSink> in class org.apache.flink.test.recovery.ChaosMonkeyITCase.CountingSink |
From |
To |
|
Change Return Type Long to List<Long> in method public snapshotState(checkpointId long, timestamp long) : List<Long> in class org.apache.flink.test.checkpointing.StateCheckpointedITCase.StringRichFilterFunction |
From |
To |
|
Change Return Type HashMap<Character,Long> to List<HashMap<Character,Long>> in method public snapshotState(checkpointId long, timestamp long) : List<HashMap<Character,Long>> in class org.apache.flink.test.checkpointing.StateCheckpointedITCase.ValidatingSink |
From |
To |
|
Change Return Type Integer to List<Integer> in method public snapshotState(checkpointId long, timestamp long) : List<Integer> in class org.apache.flink.test.checkpointing.EventTimeAllWindowCheckpointingITCase.FailingSource |
From |
To |
|
Change Return Type Integer to List<Integer> in method public snapshotState(checkpointId long, timestamp long) : List<Integer> in class org.apache.flink.test.classloading.jar.CheckpointedStreamingProgram.SimpleStringGenerator |
From |
To |
|
Change Return Type Long to List<Long> in method public snapshotState(checkpointId long, timestamp long) : List<Long> in class org.apache.flink.test.checkpointing.StreamCheckpointingITCase.StringPrefixCountRichMapFunction |
From |
To |
|
Change Return Type HashMap<Long,Integer> to List<HashMap<Long,Integer>> in method public snapshotState(checkpointId long, timestamp long) : List<HashMap<Long,Integer>> in class org.apache.flink.test.checkpointing.EventTimeAllWindowCheckpointingITCase.ValidatingSink |
From |
To |
|
Change Return Type Integer to List<Integer> in method public snapshotState(checkpointId long, timestamp long) : List<Integer> in class org.apache.flink.test.checkpointing.AbstractEventTimeWindowCheckpointingITCase.FailingSource |
From |
To |
|
Change Return Type Long to List<Long> in method public snapshotState(checkpointId long, timestamp long) : List<Long> in class org.apache.flink.test.checkpointing.StreamCheckpointingITCase.StatefulCounterFunction |
From |
To |
|
Change Return Type Long to List<Long> in method public snapshotState(checkpointId long, timestamp long) : List<Long> in class org.apache.flink.test.checkpointing.StateCheckpointedITCase.StringPrefixCountRichMapFunction |
From |
To |
|
Change Return Type ReducingStateFlatMap to List<ReducingStateFlatMap> in method public snapshotState(checkpointId long, timestamp long) : List<ReducingStateFlatMap> in class org.apache.flink.test.classloading.jar.CheckpointingCustomKvStateProgram.ReducingStateFlatMap |
From |
To |
|
Change Return Type StatefulMapper to List<StatefulMapper> in method public snapshotState(checkpointId long, timestamp long) : List<StatefulMapper> in class org.apache.flink.test.classloading.jar.CheckpointedStreamingProgram.StatefulMapper |
From |
To |
|
Change Return Type Integer to List<Integer> in method public snapshotState(checkpointId long, timestamp long) : List<Integer> in class org.apache.flink.test.checkpointing.RescalingITCase.SubtaskIndexNonPartitionedStateSource |
From |
To |
|
Change Return Type Integer to List<Integer> in method public snapshotState(checkpointId long, timestamp long) : List<Integer> in class org.apache.flink.streaming.connectors.kafka.KafkaConsumerTestBase.BrokerKillingMapper |
From |
To |
|
Change Return Type Long to List<Long> in method public snapshotState(checkpointId long, timestamp long) : List<Long> in class org.apache.flink.test.checkpointing.CoStreamCheckpointingITCase.StringRichFilterFunction |
From |
To |
|
Change Return Type HashMap<Long,Integer> to List<HashMap<Long,Integer>> in method public snapshotState(checkpointId long, timestamp long) : List<HashMap<Long,Integer>> in class org.apache.flink.test.checkpointing.AbstractEventTimeWindowCheckpointingITCase.CountValidatingSink |
From |
To |
|
Change Return Type Long to List<Long> in method public snapshotState(checkpointId long, timestamp long) : List<Long> in class org.apache.flink.test.checkpointing.StreamCheckpointingITCase.OnceFailingPrefixCounter |
From |
To |
|
Change Return Type CountingSink to List<CountingSink> in method public snapshotState(checkpointId long, timestamp long) : List<CountingSink> in class org.apache.flink.test.recovery.JobManagerHACheckpointRecoveryITCase.CountingSink |
From |
To |
|
Change Return Type Long to List<Long> in method public snapshotState(checkpointId long, timestamp long) : List<Long> in class org.apache.flink.test.recovery.TaskManagerProcessFailureStreamingRecoveryITCase.SleepyDurableGenerateSequence |
From |
To |
|
Change Return Type Long to List<Long> in method public snapshotState(checkpointId long, timestamp long) : List<Long> in class org.apache.flink.test.checkpointing.CoStreamCheckpointingITCase.LeftIdentityCoRichFlatMapFunction |
From |
To |
|
Change Return Type Long to List<Long> in method public snapshotState(checkpointId long, timestamp long) : List<Long> in class org.apache.flink.test.recovery.TaskManagerProcessFailureStreamingRecoveryITCase.CheckpointedSink |
From |
To |
|
Change Return Type Integer to List<Integer> in method public snapshotState(checkpointId long, timestamp long) : List<Integer> in class org.apache.flink.test.checkpointing.WindowCheckpointingITCase.FailingSource |
From |
To |
|
Change Return Type Long to List<Long> in method public snapshotState(checkpointId long, timestamp long) : List<Long> in class org.apache.flink.test.checkpointing.CoStreamCheckpointingITCase.StringPrefixCountRichMapFunction |
From |
To |
|
Change Return Type Long to List<Long> in method public snapshotState(checkpointId long, timestamp long) : List<Long> in class org.apache.flink.test.recovery.ChaosMonkeyITCase.CheckpointedSequenceSource |
From |
To |
|
Change Return Type Integer to List<Integer> in method public snapshotState(checkpointId long, timestamp long) : List<Integer> in class org.apache.flink.streaming.connectors.fs.RollingSinkFaultToleranceITCase.StringGeneratingSourceFunction |
From |
To |
|
Change Return Type Integer to List<Integer> in method public snapshotState(checkpointId long, timestamp long) : List<Integer> in class org.apache.flink.test.checkpointing.StreamCheckpointingITCase.StringGeneratingSourceFunction |
From |
To |
|
Rename Parameter checkpointTimestamp : long to timestamp : long in method public snapshotState(checkpointId long, timestamp long) : List<Long> in class org.apache.flink.test.checkpointing.StateCheckpointedITCase.StringRichFilterFunction |
From |
To |
|
Rename Parameter checkpointTimestamp : long to timestamp : long in method public snapshotState(checkpointId long, timestamp long) : List<Integer> in class org.apache.flink.test.checkpointing.EventTimeAllWindowCheckpointingITCase.FailingSource |
From |
To |
|
Rename Parameter checkpointTimestamp : long to timestamp : long in method public snapshotState(checkpointId long, timestamp long) : List<byte[]> in class org.apache.flink.test.checkpointing.SavepointITCase.StatefulCounter |
From |
To |
|
Rename Parameter checkpointTimestamp : long to timestamp : long in method public snapshotState(checkpointId long, timestamp long) : List<Integer> in class org.apache.flink.test.checkpointing.StateCheckpointedITCase.StringGeneratingSourceFunction |
From |
To |
|
Rename Parameter checkpointTimestamp : long to timestamp : long in method public snapshotState(checkpointId long, timestamp long) : List<Long> in class org.apache.flink.test.checkpointing.StreamCheckpointingITCase.StringRichFilterFunction |
From |
To |
|
Rename Parameter checkpointTimestamp : long to timestamp : long in method public snapshotState(checkpointId long, timestamp long) : List<Long> in class org.apache.flink.test.checkpointing.CoStreamCheckpointingITCase.StringPrefixCountRichMapFunction |
From |
To |
|
Rename Parameter checkpointTimestamp : long to timestamp : long in method public snapshotState(checkpointId long, timestamp long) : List<HashMap<Character,Long>> in class org.apache.flink.test.checkpointing.StateCheckpointedITCase.ValidatingSink |
From |
To |
|
Rename Parameter checkpointTimestamp : long to timestamp : long in method public snapshotState(checkpointId long, timestamp long) : List<Integer> in class org.apache.flink.test.checkpointing.StreamCheckpointingITCase.StringGeneratingSourceFunction |
From |
To |
|
Rename Parameter checkpointTimestamp : long to timestamp : long in method public snapshotState(checkpointId long, timestamp long) : List<Integer> in class org.apache.flink.test.checkpointing.RescalingITCase.SubtaskIndexNonPartitionedStateSource |
From |
To |
|
Rename Parameter checkpointTimestamp : long to timestamp : long in method public snapshotState(checkpointId long, timestamp long) : List<Integer> in class org.apache.flink.streaming.connectors.fs.RollingSinkFaultToleranceITCase.StringGeneratingSourceFunction |
From |
To |
|
Rename Parameter checkpointTimestamp : long to timestamp : long in method public snapshotState(checkpointId long, timestamp long) : List<Integer> in class org.apache.flink.test.classloading.jar.CheckpointingCustomKvStateProgram.InfiniteIntegerSource |
From |
To |
|
Rename Parameter checkpointTimestamp : long to timestamp : long in method public snapshotState(checkpointId long, timestamp long) : List<Long> in class org.apache.flink.test.checkpointing.StreamCheckpointingITCase.OnceFailingPrefixCounter |
From |
To |
|
Rename Parameter checkpointTimestamp : long to timestamp : long in method public snapshotState(checkpointId long, timestamp long) : List<CountingSink> in class org.apache.flink.test.recovery.JobManagerHACheckpointRecoveryITCase.CountingSink |
From |
To |
|
Rename Parameter checkpointTimestamp : long to timestamp : long in method public snapshotState(checkpointId long, timestamp long) : List<ReducingStateFlatMap> in class org.apache.flink.test.classloading.jar.CheckpointingCustomKvStateProgram.ReducingStateFlatMap |
From |
To |
|
Rename Parameter checkpointTimestamp : long to timestamp : long in method public snapshotState(checkpointId long, timestamp long) : List<HashMap<String,PrefixCount>> in class org.apache.flink.test.checkpointing.StateCheckpointedITCase.OnceFailingAggregator |
From |
To |
|
Rename Parameter checkpointTimestamp : long to timestamp : long in method public snapshotState(checkpointId long, timestamp long) : List<Integer> in class org.apache.flink.test.checkpointing.PartitionedStateCheckpointingITCase.IntGeneratingSourceFunction |
From |
To |
|
Rename Parameter checkpointTimestamp : long to timestamp : long in method public snapshotState(checkpointId long, timestamp long) : List<Integer> in class org.apache.flink.test.checkpointing.StreamCheckpointNotifierITCase.GeneratingSourceFunction |
From |
To |
|
Rename Parameter checkpointTimestamp : long to timestamp : long in method public snapshotState(checkpointId long, timestamp long) : List<Long> in class org.apache.flink.test.checkpointing.CoStreamCheckpointingITCase.StatefulCounterFunction |
From |
To |
|
Rename Parameter checkpointTimestamp : long to timestamp : long in method public snapshotState(checkpointId long, timestamp long) : List<Long> in class org.apache.flink.test.checkpointing.StateCheckpointedITCase.StatefulCounterFunction |
From |
To |
|
Rename Parameter checkpointTimestamp : long to timestamp : long in method public snapshotState(checkpointId long, timestamp long) : List<Long> in class org.apache.flink.test.recovery.ChaosMonkeyITCase.CheckpointedSequenceSource |
From |
To |
|
Rename Parameter checkpointTimestamp : long to timestamp : long in method public snapshotState(checkpointId long, timestamp long) : List<Integer> in class org.apache.flink.test.checkpointing.RescalingITCase.NonPartitionedStateSource |
From |
To |
|
Rename Parameter checkpointTimestamp : long to timestamp : long in method public snapshotState(checkpointId long, timestamp long) : List<Integer> in class org.apache.flink.test.checkpointing.AbstractEventTimeWindowCheckpointingITCase.FailingSource |
From |
To |
|
Rename Parameter data : byte[] to state : List<byte[]> in method public restoreState(state List<byte[]>) : void in class org.apache.flink.test.checkpointing.SavepointITCase.StatefulCounter |
From |
To |
|
Rename Parameter checkpointTimestamp : long to timestamp : long in method public snapshotState(checkpointId long, timestamp long) : List<Long> in class org.apache.flink.test.recovery.TaskManagerProcessFailureStreamingRecoveryITCase.CheckpointedSink |
From |
To |
|
Rename Parameter checkpointTimestamp : long to timestamp : long in method public snapshotState(checkpointId long, timestamp long) : List<HashMap<Long,Integer>> in class org.apache.flink.test.checkpointing.AbstractEventTimeWindowCheckpointingITCase.CountValidatingSink |
From |
To |
|
Rename Parameter checkpointTimestamp : long to timestamp : long in method public snapshotState(checkpointId long, timestamp long) : List<Integer> in class org.apache.flink.streaming.connectors.kafka.KafkaConsumerTestBase.BrokerKillingMapper |
From |
To |
|
Rename Parameter checkpointTimestamp : long to timestamp : long in method public snapshotState(checkpointId long, timestamp long) : List<HashMap<Long,Integer>> in class org.apache.flink.test.checkpointing.AbstractEventTimeWindowCheckpointingITCase.ValidatingSink |
From |
To |
|
Rename Parameter checkpointTimestamp : long to timestamp : long in method public snapshotState(checkpointId long, timestamp long) : List<Integer> in class org.apache.flink.test.classloading.jar.CheckpointedStreamingProgram.SimpleStringGenerator |
From |
To |
|
Rename Parameter checkpointTimestamp : long to timestamp : long in method public snapshotState(checkpointId long, timestamp long) : List<StatefulMapper> in class org.apache.flink.test.classloading.jar.CheckpointedStreamingProgram.StatefulMapper |
From |
To |
|
Rename Parameter checkpointTimestamp : long to timestamp : long in method public snapshotState(checkpointId long, timestamp long) : List<Integer> in class org.apache.flink.streaming.connectors.kafka.testutils.FailingIdentityMapper |
From |
To |
|
Rename Parameter checkpointTimestamp : long to timestamp : long in method public snapshotState(checkpointId long, timestamp long) : List<Serializable> in class org.apache.flink.streaming.runtime.tasks.SourceStreamTaskTest.MockSource |
From |
To |
|
Rename Parameter checkpointTimestamp : long to timestamp : long in method public snapshotState(checkpointId long, timestamp long) : List<Integer> in class org.apache.flink.streaming.connectors.cassandra.example.CassandraTupleWriteAheadSinkExample.MySource |
From |
To |
|
Rename Parameter checkpointTimestamp : long to timestamp : long in method public snapshotState(checkpointId long, timestamp long) : List<Tuple2<Integer,BitSet>> in class org.apache.flink.streaming.connectors.kafka.testutils.ValidatingExactlyOnceSink |
From |
To |
|
Rename Parameter checkpointTimestamp : long to timestamp : long in method public snapshotState(checkpointId long, timestamp long) : List<Long> in class org.apache.flink.test.checkpointing.StreamCheckpointNotifierITCase.OnceFailingReducer |
From |
To |
|
Rename Parameter checkpointTimestamp : long to timestamp : long in method public snapshotState(checkpointId long, timestamp long) : List<Integer> in class org.apache.flink.test.checkpointing.CoStreamCheckpointingITCase.StringGeneratingSourceFunction |
From |
To |
|
Rename Parameter checkpointTimestamp : long to timestamp : long in method public snapshotState(checkpointId long, timestamp long) : List<Integer> in class org.apache.flink.streaming.connectors.fs.bucketing.BucketingSinkFaultToleranceITCase.StringGeneratingSourceFunction |
From |
To |
|
Rename Parameter checkpointTimestamp : long to timestamp : long in method public snapshotState(checkpointId long, timestamp long) : List<Long> in class org.apache.flink.test.recovery.JobManagerHACheckpointRecoveryITCase.CheckpointedSequenceSource |
From |
To |
|
Rename Parameter checkpointTimestamp : long to timestamp : long in method public snapshotState(checkpointId long, timestamp long) : List<Long> in class org.apache.flink.test.recovery.TaskManagerProcessFailureStreamingRecoveryITCase.SleepyDurableGenerateSequence |
From |
To |
|
Rename Parameter checkpointTimestamp : long to timestamp : long in method public snapshotState(checkpointId long, timestamp long) : List<Long> in class org.apache.flink.test.checkpointing.CoStreamCheckpointingITCase.StringRichFilterFunction |
From |
To |
|
Rename Parameter checkpointTimestamp : long to timestamp : long in method public snapshotState(checkpointId long, timestamp long) : List<Long> in class org.apache.flink.test.checkpointing.StateCheckpointedITCase.StringPrefixCountRichMapFunction |
From |
To |
|
Rename Parameter checkpointTimestamp : long to timestamp : long in method public snapshotState(checkpointId long, timestamp long) : List<Integer> in class org.apache.flink.test.checkpointing.WindowCheckpointingITCase.FailingSource |
From |
To |
|
Rename Parameter checkpointTimestamp : long to timestamp : long in method public snapshotState(checkpointId long, timestamp long) : List<Long> in class org.apache.flink.test.checkpointing.StreamCheckpointingITCase.StringPrefixCountRichMapFunction |
From |
To |
|
Rename Parameter checkpointTimestamp : long to timestamp : long in method public snapshotState(checkpointId long, timestamp long) : List<CountingSink> in class org.apache.flink.test.recovery.ChaosMonkeyITCase.CountingSink |
From |
To |
|
Rename Parameter checkpointTimestamp : long to timestamp : long in method public snapshotState(checkpointId long, timestamp long) : List<HashMap<Long,Integer>> in class org.apache.flink.test.checkpointing.WindowCheckpointingITCase.ValidatingSink |
From |
To |
|
Rename Parameter checkpointTimestamp : long to timestamp : long in method public snapshotState(checkpointId long, timestamp long) : List<HashMap<Long,Integer>> in class org.apache.flink.test.checkpointing.EventTimeAllWindowCheckpointingITCase.ValidatingSink |
From |
To |
|
Rename Parameter checkpointTimestamp : long to timestamp : long in method public snapshotState(checkpointId long, timestamp long) : List<Long> in class org.apache.flink.test.checkpointing.CoStreamCheckpointingITCase.LeftIdentityCoRichFlatMapFunction |
From |
To |
|
Rename Parameter checkpointTimestamp : long to timestamp : long in method public snapshotState(checkpointId long, timestamp long) : List<Long> in class org.apache.flink.test.checkpointing.StreamCheckpointingITCase.StatefulCounterFunction |
From |
To |
|
Rename Parameter checkpointTimestamp : long to timestamp : long in method public snapshotState(checkpointId long, timestamp long) : List<Long> in class org.apache.flink.test.checkpointing.UdfStreamOperatorCheckpointingITCase.StatefulMultipleSequence |
From |
To |