|
Change Variable Type plan : JavaPlan to plan : Plan in method public reuseSinglePartitioningCoGroup5() : void in class org.apache.flink.optimizer.PartitioningReusageTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public checkSinglePartitionedOrderedSource2() : void in class org.apache.flink.optimizer.PropertyDataSourceTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public checkPropertyHandlingWithIncreasingLocalParallelism() : void in class org.apache.flink.optimizer.ParallelismChangeTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public checkSinglePartitionedGroupedSource7() : void in class org.apache.flink.optimizer.PropertyDataSourceTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public checkCoPartitionedSources2() : void in class org.apache.flink.optimizer.PropertyDataSourceTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public reuseBothPartitioningJoin1() : void in class org.apache.flink.optimizer.PartitioningReusageTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public reuseBothPartitioningCoGroup2() : void in class org.apache.flink.optimizer.PartitioningReusageTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public checkJoinWithReplicatedSourceInputBehindMapChangingparallelism() : void in class org.apache.flink.optimizer.ReplicatingDataSourceTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public testReduceWithGroupOrder() : void in class org.apache.flink.optimizer.GroupOrderTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public reuseSinglePartitioningJoin4() : void in class org.apache.flink.optimizer.PartitioningReusageTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public testBranchingDisjointPlan() : void in class org.apache.flink.optimizer.BranchingPlansCompilerTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public checkSinglePartitionedSource4() : void in class org.apache.flink.optimizer.PropertyDataSourceTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public checkJoinWithReplicatedSourceInput() : void in class org.apache.flink.optimizer.ReplicatingDataSourceTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public testCoGroupWithGroupOrder() : void in class org.apache.flink.optimizer.GroupOrderTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public reuseBothPartitioningJoin6() : void in class org.apache.flink.optimizer.PartitioningReusageTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public reuseBothPartitioningCoGroup7() : void in class org.apache.flink.optimizer.PartitioningReusageTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public checkSinglePartitionedOrderedSource1() : void in class org.apache.flink.optimizer.PropertyDataSourceTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public checkCoPartitionedSources1() : void in class org.apache.flink.optimizer.PropertyDataSourceTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public checkSinglePartitionedGroupedSource6() : void in class org.apache.flink.optimizer.PropertyDataSourceTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public checkJoinWithReplicatedSourceInputChangingparallelism() : void in class org.apache.flink.optimizer.ReplicatingDataSourceTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public reuseSinglePartitioningCoGroup3() : void in class org.apache.flink.optimizer.PartitioningReusageTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public checkSinglePartitionedSource3() : void in class org.apache.flink.optimizer.PropertyDataSourceTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public reuseSinglePartitioningJoin2() : void in class org.apache.flink.optimizer.PartitioningReusageTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public checkCrossWithReplicatedSourceInput() : void in class org.apache.flink.optimizer.ReplicatingDataSourceTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public checkSinglePartitionedGroupedSource5() : void in class org.apache.flink.optimizer.PropertyDataSourceTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public reuseBothPartitioningJoin4() : void in class org.apache.flink.optimizer.PartitioningReusageTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public reuseBothPartitioningCoGroup5() : void in class org.apache.flink.optimizer.PartitioningReusageTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public checkPropertyHandlingWithDecreasingParallelism() : void in class org.apache.flink.optimizer.ParallelismChangeTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public testReduce() : void in class org.apache.flink.optimizer.ReduceAllTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public forwardFieldsTestJoin() : void in class org.apache.flink.optimizer.SemanticPropertiesAPIToPlanTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public checkSinglePartitionedSource2() : void in class org.apache.flink.optimizer.PropertyDataSourceTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public reuseSinglePartitioningCoGroup1() : void in class org.apache.flink.optimizer.PartitioningReusageTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public checkSinglePartitionedGroupedSource4() : void in class org.apache.flink.optimizer.PropertyDataSourceTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public createProgramPlan(jobName String, clearSinks boolean) : Plan in class org.apache.flink.api.java.ExecutionEnvironment |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public noPreviousPartitioningJoin1() : void in class org.apache.flink.optimizer.PartitioningReusageTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public forwardFieldsTestMapReduce() : void in class org.apache.flink.optimizer.SemanticPropertiesAPIToPlanTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public checkSinglePartitionedOrderedSource7() : void in class org.apache.flink.optimizer.PropertyDataSourceTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public checkSinglePartitionedSource1() : void in class org.apache.flink.optimizer.PropertyDataSourceTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public reuseBothPartitioningCoGroup3() : void in class org.apache.flink.optimizer.PartitioningReusageTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public reuseBothPartitioningJoin2() : void in class org.apache.flink.optimizer.PartitioningReusageTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public reuseSinglePartitioningJoin5() : void in class org.apache.flink.optimizer.PartitioningReusageTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public checkJoinWithReplicatedSourceInputBehindMap() : void in class org.apache.flink.optimizer.ReplicatingDataSourceTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public testTempInIterationTest() : void in class org.apache.flink.optimizer.plantranslate.TempInIterationsTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public noPreviousPartitioningCoGroup1() : void in class org.apache.flink.optimizer.PartitioningReusageTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public checkJoinWithReplicatedSourceInputBehindMultiMaps() : void in class org.apache.flink.optimizer.ReplicatingDataSourceTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public testCrossWithSmall() : void in class org.apache.flink.optimizer.AdditionalOperatorsTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public checkSinglePartitionedGroupedSource3() : void in class org.apache.flink.optimizer.PropertyDataSourceTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public testGivenName() : void in class org.apache.flink.api.java.operators.NamesTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public testBranchAfterIteration() : void in class org.apache.flink.optimizer.BranchingPlansCompilerTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public reuseBothPartitioningJoin7() : void in class org.apache.flink.optimizer.PartitioningReusageTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public checkPropertyHandlingWithIncreasingGlobalParallelism2() : void in class org.apache.flink.optimizer.ParallelismChangeTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public checkPropertyHandlingWithIncreasingGlobalParallelism1() : void in class org.apache.flink.optimizer.ParallelismChangeTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public checkSinglePartitionedOrderedSource6() : void in class org.apache.flink.optimizer.PropertyDataSourceTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public checkJoinWithReplicatedSourceInputBehindReduce() : void in class org.apache.flink.optimizer.ReplicatingDataSourceTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public checkJoinWithReplicatedSourceInputBehindMapPartition() : void in class org.apache.flink.optimizer.ReplicatingDataSourceTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public testBranchEachContractType() : void in class org.apache.flink.optimizer.BranchingPlansCompilerTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public testCrossWithLarge() : void in class org.apache.flink.optimizer.AdditionalOperatorsTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public reuseSinglePartitioningCoGroup4() : void in class org.apache.flink.optimizer.PartitioningReusageTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public testDeltaIterationWithStaticInput() : void in class org.apache.flink.optimizer.BranchingPlansCompilerTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public testTicket158() : void in class org.apache.flink.optimizer.HardPlansCompilationTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public testUnion1() : void in class org.apache.flink.optimizer.UnionPropertyPropagationTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public checkSinglePartitionedGroupedSource2() : void in class org.apache.flink.optimizer.PropertyDataSourceTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public reuseBothPartitioningCoGroup1() : void in class org.apache.flink.optimizer.PartitioningReusageTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public reuseSinglePartitioningJoin3() : void in class org.apache.flink.optimizer.PartitioningReusageTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public checkSinglePartitionedOrderedSource5() : void in class org.apache.flink.optimizer.PropertyDataSourceTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public reuseBothPartitioningJoin5() : void in class org.apache.flink.optimizer.PartitioningReusageTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public reuseBothPartitioningCoGroup6() : void in class org.apache.flink.optimizer.PartitioningReusageTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public testClosureDeltaIteration() : void in class org.apache.flink.optimizer.BranchingPlansCompilerTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public checkPropertyHandlingWithTwoInputs() : void in class org.apache.flink.optimizer.ParallelismChangeTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public testBranchingUnion() : void in class org.apache.flink.optimizer.BranchingPlansCompilerTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public checkSinglePartitionedGroupedSource1() : void in class org.apache.flink.optimizer.PropertyDataSourceTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public checkSinglePartitionedSource7() : void in class org.apache.flink.optimizer.PropertyDataSourceTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public checkJoinWithReplicatedSourceInputBehindFilter() : void in class org.apache.flink.optimizer.ReplicatingDataSourceTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public reuseSinglePartitioningCoGroup2() : void in class org.apache.flink.optimizer.PartitioningReusageTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public checkJoinWithReplicatedSourceInputBehindRebalance() : void in class org.apache.flink.optimizer.ReplicatingDataSourceTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public checkSinglePartitionedOrderedSource4() : void in class org.apache.flink.optimizer.PropertyDataSourceTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public reuseSinglePartitioningJoin1() : void in class org.apache.flink.optimizer.PartitioningReusageTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public checkJoinWithReplicatedSourceInputBehindFlatMap() : void in class org.apache.flink.optimizer.ReplicatingDataSourceTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public testBranchingWithMultipleDataSinksSmall() : void in class org.apache.flink.optimizer.BranchingPlansCompilerTest |
From |
To |
|
Change Variable Type p : JavaPlan to p : Plan in method public translateToPlan(sinks List<DataSink<?>>, jobName String) : Plan in class org.apache.flink.api.java.operators.OperatorTranslation |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public checkCrossWithReplicatedSourceInputBehindMap() : void in class org.apache.flink.optimizer.ReplicatingDataSourceTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public noPreviousPartitioningJoin2() : void in class org.apache.flink.optimizer.PartitioningReusageTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public testDefaultName() : void in class org.apache.flink.api.java.operators.NamesTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public checkSinglePartitionedSource6() : void in class org.apache.flink.optimizer.PropertyDataSourceTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public reuseBothPartitioningJoin3() : void in class org.apache.flink.optimizer.PartitioningReusageTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public reuseBothPartitioningCoGroup4() : void in class org.apache.flink.optimizer.PartitioningReusageTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public testBranchBeforeIteration() : void in class org.apache.flink.optimizer.BranchingPlansCompilerTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public noPreviousPartitioningCoGroup2() : void in class org.apache.flink.optimizer.PartitioningReusageTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public testJoinWith() : void in class org.apache.flink.api.java.operators.NamesTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public checkSinglePartitionedOrderedSource3() : void in class org.apache.flink.optimizer.PropertyDataSourceTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public checkSinglePartitionedGroupedSource8() : void in class org.apache.flink.optimizer.PropertyDataSourceTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public testClosure() : void in class org.apache.flink.optimizer.BranchingPlansCompilerTest |
From |
To |
|
Change Variable Type plan : JavaPlan to plan : Plan in method public checkSinglePartitionedSource5() : void in class org.apache.flink.optimizer.PropertyDataSourceTest |
From |
To |