|
Rename Variable UPDATED_ELEMENTS : String to updatedElements : String in method public testConnectedComponentsWithParametrizableConvergence() : void in class org.apache.flink.test.iterative.aggregators.AggregatorConvergenceITCase |
From |
To |
|
Rename Variable p_y : int to pY : int in method public join(first Tuple3<String,Integer,Integer>, second Tuple4<String,Integer,Integer,Integer>) : Tuple2<String,Integer> in class org.apache.flink.test.broadcastvars.BroadcastBranchingITCase.Jn2 |
From |
To |
|
Rename Variable NUM_ELEMENTS : int to numElements : int in method public testTimestampExtractorWithLongMaxWatermarkFromSource2() : void in class org.apache.flink.test.streaming.runtime.TimestampITCase |
From |
To |
|
Rename Variable convergence_threshold : long to convergenceThreshold : long in method public testConnectedComponentsWithParametrizableConvergence() : void in class org.apache.flink.test.iterative.aggregators.AggregatorConvergenceITCase |
From |
To |
|
Rename Variable NUM_ELEMENTS : int to numElements : int in method public testTimestampExtractorWithCustomWatermarkEmit() : void in class org.apache.flink.test.streaming.runtime.TimestampITCase |
From |
To |
|
Rename Variable NUM_STRINGS : int to numStrings : int in method public testStringTuplesSorting() : void in class org.apache.flink.test.manual.MassiveStringSorting |
From |
To |
|
Rename Variable NUM_ELEMENTS : int to numElements : int in method public testDisabledTimestamps() : void in class org.apache.flink.test.streaming.runtime.TimestampITCase |
From |
To |
|
Rename Variable p_x : int to pX : int in method public join(first Tuple3<String,Integer,Integer>, second Tuple4<String,Integer,Integer,Integer>) : Tuple2<String,Integer> in class org.apache.flink.test.broadcastvars.BroadcastBranchingITCase.Jn2 |
From |
To |
|
Rename Variable ACC_NAME : String to accName : String in method public testAccumulatorsAfterNoOp() : void in class org.apache.flink.test.misc.MiscellaneousIssuesITCase |
From |
To |
|
Rename Variable AGGREGATOR_NAME : String to aggregatorName : String in method public testParameterizableAggregator() : void in class org.apache.flink.test.iterative.aggregators.AggregatorConvergenceITCase |
From |
To |
|
Rename Variable NUM_WATERMARKS : int to numWatermarks : int in method public testWatermarkPropagationNoFinalWatermarkOnStop() : void in class org.apache.flink.test.streaming.runtime.TimestampITCase |
From |
To |
|
Rename Variable NUM_ELEMENTS : long to numElements : long in method public testJobManagerFailure(zkQuorum String, coordinateDir File) : void in class org.apache.flink.test.recovery.JobManagerHAProcessFailureBatchRecoveryITCase |
From |
To |
|
Rename Variable NUM_ELEMENTS : long to numElements : long in method public testTaskManagerFailure(jobManagerPort int, coordinateDir File) : void in class org.apache.flink.test.recovery.TaskManagerProcessFailureBatchRecoveryITCase |
From |
To |
|
Rename Variable NUM_ELEMENTS : int to numElements : int in method public testTimestampHandling() : void in class org.apache.flink.test.streaming.runtime.TimestampITCase |
From |
To |
|
Rename Variable EXPECTED_SUCCESSFUL_CHECKS : int to expectedSuccessfulChecks : int in method public testSavepointRestoreFromFlink11() : void in class org.apache.flink.test.checkpointing.utils.StatefulJobSavepointFrom11MigrationITCase |
From |
To |
|
Rename Variable aggr_values : long[] to aggrValues : long[] in method public testParameterizableAggregator() : void in class org.apache.flink.test.iterative.aggregators.AggregatorConvergenceITCase |
From |
To |
|
Rename Variable NUM_STRINGS : int to numStrings : int in method public testStringValueTuplesSorting() : void in class org.apache.flink.test.manual.MassiveStringValueSorting |
From |
To |
|
Rename Variable convergence_threshold : long to convergenceThreshold : long in method public testDeltaConnectedComponentsWithParametrizableConvergence() : void in class org.apache.flink.test.iterative.aggregators.AggregatorConvergenceITCase |
From |
To |
|
Rename Variable NUM_ELEMENTS : int to numElements : int in method public testTimestampExtractorWithDecreasingCustomWatermarkEmit() : void in class org.apache.flink.test.streaming.runtime.TimestampITCase |
From |
To |
|
Rename Variable NUM_ELEMENTS : int to numElements : int in method public testTimestampExtractorWithLongMaxWatermarkFromSource() : void in class org.apache.flink.test.streaming.runtime.TimestampITCase |
From |
To |
|
Rename Variable NUM_ELEMENTS : int to numElements : int in method public testTimestampExtractorWithAutoInterval() : void in class org.apache.flink.test.streaming.runtime.TimestampITCase |
From |
To |
|
Rename Variable UPDATED_ELEMENTS : String to updatedElements : String in method public testDeltaConnectedComponentsWithParametrizableConvergence() : void in class org.apache.flink.test.iterative.aggregators.AggregatorConvergenceITCase |
From |
To |
|
Rename Variable NUM_WATERMARKS : int to numWatermarks : int in method public testWatermarkPropagation() : void in class org.apache.flink.test.streaming.runtime.TimestampITCase |
From |
To |
|
Rename Variable MinMaxSelector : MapPartitionFunction<Long,Tuple2<Long,Long>> to minMaxSelector : MapPartitionFunction<Long,Tuple2<Long,Long>> in method public testRangePartitionerOnSequenceData() : void in class org.apache.flink.test.operators.PartitionITCase |
From |
To |
|
Rename Variable EXPECTED_SUCCESSFUL_CHECKS : int to expectedSuccessfulChecks : int in method public testSavepointRestoreFromFlink11FromRocksDB() : void in class org.apache.flink.test.checkpointing.utils.StatefulJobSavepointFrom11MigrationITCase |
From |
To |
|
Move Class org.apache.flink.test.javaApiOperators.OuterJoinITCase moved to org.apache.flink.test.operators.OuterJoinITCase |
From |
To |
|
Move Class org.apache.flink.test.exampleScalaPrograms.TransitiveClosureITCase moved to org.apache.flink.test.example.scala.TransitiveClosureITCase |
From |
To |
|
Move Class org.apache.flink.test.javaApiOperators.SortPartitionITCase moved to org.apache.flink.test.operators.SortPartitionITCase |
From |
To |
|
Move Class org.apache.flink.test.failingPrograms.TaskFailureITCase moved to org.apache.flink.test.example.failing.TaskFailureITCase |
From |
To |
|
Move Class org.apache.flink.test.javaApiOperators.ReplicatingDataSourceITCase moved to org.apache.flink.test.operators.ReplicatingDataSourceITCase |
From |
To |
|
Move Class org.apache.flink.test.javaApiOperators.ReduceITCase moved to org.apache.flink.test.operators.ReduceITCase |
From |
To |
|
Move Class org.apache.flink.test.exampleJavaPrograms.WordCountNestedPOJOITCase moved to org.apache.flink.test.example.java.WordCountNestedPOJOITCase |
From |
To |
|
Move Class org.apache.flink.test.exampleJavaPrograms.WordCountITCase moved to org.apache.flink.test.example.java.WordCountITCase |
From |
To |
|
Move Class org.apache.flink.test.exampleScalaPrograms.WordCountITCase moved to org.apache.flink.test.example.scala.WordCountITCase |
From |
To |
|
Move Class org.apache.flink.test.exampleJavaPrograms.WordCountSubclassPOJOITCase moved to org.apache.flink.test.example.java.WordCountSubclassPOJOITCase |
From |
To |
|
Move Class org.apache.flink.test.javaApiOperators.ReduceWithCombinerITCase moved to org.apache.flink.test.operators.ReduceWithCombinerITCase |
From |
To |
|
Move Class org.apache.flink.test.exampleJavaPrograms.WordCountSimplePOJOITCase moved to org.apache.flink.test.example.java.WordCountSimplePOJOITCase |
From |
To |
|
Move Class org.apache.flink.test.javaApiOperators.ObjectReuseITCase moved to org.apache.flink.test.operators.ObjectReuseITCase |
From |
To |
|
Move Class org.apache.flink.test.javaApiOperators.RemoteEnvironmentITCase moved to org.apache.flink.test.operators.RemoteEnvironmentITCase |
From |
To |
|
Move Class org.apache.flink.test.javaApiOperators.CoGroupGroupSortITCase moved to org.apache.flink.test.operators.CoGroupGroupSortITCase |
From |
To |
|
Move Class org.apache.flink.test.exampleScalaPrograms.WebLogAnalysisITCase moved to org.apache.flink.test.example.scala.WebLogAnalysisITCase |
From |
To |
|
Move Class org.apache.flink.test.javaApiOperators.SampleITCase moved to org.apache.flink.test.operators.SampleITCase |
From |
To |
|
Move Class org.apache.flink.test.javaApiOperators.CrossITCase moved to org.apache.flink.test.operators.CrossITCase |
From |
To |
|
Move Class org.apache.flink.test.javaApiOperators.DataSourceITCase moved to org.apache.flink.test.operators.DataSourceITCase |
From |
To |
|
Move Class org.apache.flink.test.javaApiOperators.CustomDistributionITCase moved to org.apache.flink.test.operators.CustomDistributionITCase |
From |
To |
|
Move Class org.apache.flink.test.javaApiOperators.util.CollectionDataSets moved to org.apache.flink.test.operators.util.CollectionDataSets |
From |
To |
|
Move Class org.apache.flink.test.javaApiOperators.ProjectITCase moved to org.apache.flink.test.operators.ProjectITCase |
From |
To |
|
Move Class org.apache.flink.test.clients.examples.JobRetrievalITCase moved to org.apache.flink.test.example.client.JobRetrievalITCase |
From |
To |
|
Move Class org.apache.flink.test.javaApiOperators.CoGroupITCase moved to org.apache.flink.test.operators.CoGroupITCase |
From |
To |
|
Move Class org.apache.flink.test.javaApiOperators.FilterITCase moved to org.apache.flink.test.operators.FilterITCase |
From |
To |
|
Move Class org.apache.flink.test.exampleScalaPrograms.PageRankITCase moved to org.apache.flink.test.example.scala.PageRankITCase |
From |
To |
|
Move Class org.apache.flink.test.exampleJavaPrograms.PageRankITCase moved to org.apache.flink.test.example.java.PageRankITCase |
From |
To |
|
Move Class org.apache.flink.test.distributedCache.DistributedCacheTest moved to org.apache.flink.test.distributedcache.DistributedCacheTest |
From |
To |
|
Move Class org.apache.flink.test.javaApiOperators.TypeHintITCase moved to org.apache.flink.test.operators.TypeHintITCase |
From |
To |
|
Move Class org.apache.flink.test.javaApiOperators.util.ValueCollectionDataSets moved to org.apache.flink.test.operators.util.ValueCollectionDataSets |
From |
To |
|
Move Class org.apache.flink.test.javaApiOperators.ExecutionEnvironmentITCase moved to org.apache.flink.test.operators.ExecutionEnvironmentITCase |
From |
To |
|
Move Class org.apache.flink.test.javaApiOperators.MapITCase moved to org.apache.flink.test.operators.MapITCase |
From |
To |
|
Move Class org.apache.flink.test.javaApiOperators.FirstNITCase moved to org.apache.flink.test.operators.FirstNITCase |
From |
To |
|
Move Class org.apache.flink.test.javaApiOperators.SumMinMaxITCase moved to org.apache.flink.test.operators.SumMinMaxITCase |
From |
To |
|
Move Class org.apache.flink.test.javaApiOperators.UnionITCase moved to org.apache.flink.test.operators.UnionITCase |
From |
To |
|
Move Class org.apache.flink.test.exampleJavaPrograms.WordCountSubclassInterfacePOJOITCase moved to org.apache.flink.test.example.java.WordCountSubclassInterfacePOJOITCase |
From |
To |
|
Move Class org.apache.flink.test.javaApiOperators.DataSinkITCase moved to org.apache.flink.test.operators.DataSinkITCase |
From |
To |
|
Move Class org.apache.flink.test.javaApiOperators.JoinITCase moved to org.apache.flink.test.operators.JoinITCase |
From |
To |
|
Move Class org.apache.flink.test.javaApiOperators.GroupCombineITCase moved to org.apache.flink.test.operators.GroupCombineITCase |
From |
To |
|
Move Class org.apache.flink.test.exampleJavaPrograms.ConnectedComponentsITCase moved to org.apache.flink.test.example.java.ConnectedComponentsITCase |
From |
To |
|
Move Class org.apache.flink.test.exampleJavaPrograms.WebLogAnalysisITCase moved to org.apache.flink.test.example.java.WebLogAnalysisITCase |
From |
To |
|
Move Class org.apache.flink.test.exampleScalaPrograms.EnumTriangleITCase moved to org.apache.flink.test.example.scala.EnumTriangleITCase |
From |
To |
|
Move Class org.apache.flink.test.javaApiOperators.GroupReduceITCase moved to org.apache.flink.test.operators.GroupReduceITCase |
From |
To |
|
Move Class org.apache.flink.test.javaApiOperators.MapPartitionITCase moved to org.apache.flink.test.operators.MapPartitionITCase |
From |
To |
|
Move Class org.apache.flink.test.javaApiOperators.AggregateITCase moved to org.apache.flink.test.operators.AggregateITCase |
From |
To |
|
Move Class org.apache.flink.test.failingPrograms.JobSubmissionFailsITCase moved to org.apache.flink.test.example.failing.JobSubmissionFailsITCase |
From |
To |
|
Move Class org.apache.flink.test.javaApiOperators.DistinctITCase moved to org.apache.flink.test.operators.DistinctITCase |
From |
To |
|
Move Class org.apache.flink.test.javaApiOperators.PartitionITCase moved to org.apache.flink.test.operators.PartitionITCase |
From |
To |
|
Move Class org.apache.flink.test.exampleJavaPrograms.WordCountWithCollectionITCase moved to org.apache.flink.test.example.java.WordCountWithCollectionITCase |
From |
To |
|
Move Class org.apache.flink.test.exampleJavaPrograms.EnumTriangleBasicITCase moved to org.apache.flink.test.example.java.EnumTriangleBasicITCase |
From |
To |
|
Move Class org.apache.flink.test.exampleScalaPrograms.ConnectedComponentsITCase moved to org.apache.flink.test.example.scala.ConnectedComponentsITCase |
From |
To |
|
Move Class org.apache.flink.test.javaApiOperators.FlatMapITCase moved to org.apache.flink.test.operators.FlatMapITCase |
From |
To |
|
Move Class org.apache.flink.test.clients.examples.LocalExecutorITCase moved to org.apache.flink.test.example.client.LocalExecutorITCase |
From |
To |
|
Move Class org.apache.flink.test.exampleJavaPrograms.TransitiveClosureITCase moved to org.apache.flink.test.example.java.TransitiveClosureITCase |
From |
To |
|
Rename Attribute CHECK_CORRECT_SNAPSHOT : int[] to checkCorrectSnapshot : int[] in class org.apache.flink.test.checkpointing.RescalingITCase.PartitionedStateSourceListCheckpointed |
From |
To |
|
Rename Attribute TEST_ACTOR_SYSTEM : ActorSystem to testActorSystem : ActorSystem in class org.apache.flink.test.query.AbstractQueryableStateITCase |
From |
To |
|
Rename Attribute NoOpIntMap : MapFunction<Integer,Integer> to noOpIntMap : MapFunction<Integer,Integer> in class org.apache.flink.test.streaming.runtime.IterateITCase |
From |
To |
|
Rename Attribute RecoveredStates : AtomicLongArray to recoveredStates : AtomicLongArray in class org.apache.flink.test.recovery.JobManagerHACheckpointRecoveryITCase |
From |
To |
|
Rename Attribute CHECK_CORRECT_RESTORE : int[] to checkCorrectRestore : int[] in class org.apache.flink.test.checkpointing.RescalingITCase.PartitionedStateSourceListCheckpointed |
From |
To |
|
Rename Attribute completedCheckpoints : List<Long>[] to COMPLETED_CHECKPOINTS : List<Long>[] in class org.apache.flink.test.checkpointing.StreamCheckpointNotifierITCase.GeneratingSourceFunction |
From |
To |
|
Rename Attribute FinalCount : AtomicReference<Long> to finalCount : AtomicReference<Long> in class org.apache.flink.test.recovery.JobManagerHACheckpointRecoveryITCase |
From |
To |
|
Rename Attribute NoOpStrMap : MapFunction<String,String> to noOpStrMap : MapFunction<String,String> in class org.apache.flink.test.streaming.runtime.IterateITCase |
From |
To |
|
Rename Attribute nest_Lvl2 : CrazyNestedL2 to nestLvl2 : CrazyNestedL2 in class org.apache.flink.test.operators.util.CollectionDataSets.CrazyNestedL1 |
From |
To |
|
Rename Attribute descriptor : ValueStateDescriptor<Boolean> to DESCRIPTOR : ValueStateDescriptor<Boolean> in class org.apache.flink.test.checkpointing.SavepointITCase.DuplicateFilter |
From |
To |
|
Rename Attribute CHECKPOINTED_STRING : String to checkpointedString : String in class org.apache.flink.test.checkpointing.utils.StatefulJobSavepointFrom11MigrationITCase.LegacyCheckpointedSource |
From |
To |
|
Rename Attribute NoOpCoMap : CoMapFunction<Integer,String,String> to noOpCoMap : CoMapFunction<Integer,String,String> in class org.apache.flink.test.streaming.runtime.IterateITCase |
From |
To |
|
Rename Attribute NoOpIntCoMap : CoMapFunction<Integer,Integer,Integer> to noOpIntCoMap : CoMapFunction<Integer,Integer,Integer> in class org.apache.flink.test.streaming.runtime.IterateITCase |
From |
To |
|
Rename Attribute CHECKPOINTED_TUPLE : Tuple2<String,Long> to checkpointedTuple : Tuple2<String,Long> in class org.apache.flink.test.checkpointing.utils.StatefulJobSavepointFrom11MigrationITCase.LegacyCheckpointedFlatMap |
From |
To |
|
Rename Attribute nest_Lvl1 : CrazyNestedL1 to nestLvl1 : CrazyNestedL1 in class org.apache.flink.test.operators.util.CollectionDataSets.CrazyNested |
From |
To |
|
Rename Attribute NoOpBoolMap : MapFunction<Boolean,Boolean> to noOpBoolMap : MapFunction<Boolean,Boolean> in class org.apache.flink.test.streaming.runtime.IterateITCase |
From |
To |