|
Rename Variable out1Path : String to outPath1 : String in method public testBranchingWithMultipleDataSinksSmall() : void in class org.apache.flink.optimizer.BranchingPlansCompilerTest |
From |
To |
|
Rename Variable map1 : MapOperator to env : ExecutionEnvironment in method public checkPropertyHandlingWithIncreasingLocalParallelism() : void in class org.apache.flink.optimizer.ParallelismChangeTest |
From |
To |
|
Rename Variable out2Path : String to outPath2 : String in method public testBranchingWithMultipleDataSinksSmall() : void in class org.apache.flink.optimizer.BranchingPlansCompilerTest |
From |
To |
|
Rename Variable degOfPar : int to p : int in method public checkPropertyHandlingWithIncreasingLocalParallelism() : void in class org.apache.flink.optimizer.ParallelismChangeTest |
From |
To |
|
Rename Variable degOfPar : int to p : int in method public checkPropertyHandlingWithIncreasingGlobalParallelism2() : void in class org.apache.flink.optimizer.ParallelismChangeTest |
From |
To |
|
Rename Variable map1 : MapOperator to env : ExecutionEnvironment in method public checkPropertyHandlingWithIncreasingGlobalParallelism2() : void in class org.apache.flink.optimizer.ParallelismChangeTest |
From |
To |
|
Rename Variable redA : ReduceOperator to env : ExecutionEnvironment in method public checkPropertyHandlingWithTwoInputs() : void in class org.apache.flink.optimizer.ParallelismChangeTest |
From |
To |
|
Rename Variable degOfPar : int to p : int in method public checkPropertyHandlingWithDecreasingParallelism() : void in class org.apache.flink.optimizer.ParallelismChangeTest |
From |
To |
|
Rename Variable degOfPar : int to p : int in method public checkPropertyHandlingWithIncreasingGlobalParallelism1() : void in class org.apache.flink.optimizer.ParallelismChangeTest |
From |
To |
|
Rename Variable map1 : MapOperator to env : ExecutionEnvironment in method public checkPropertyHandlingWithIncreasingGlobalParallelism1() : void in class org.apache.flink.optimizer.ParallelismChangeTest |
From |
To |
|
Rename Variable sink : FileDataSink to env : ExecutionEnvironment in method public checkPropertyHandlingWithDecreasingParallelism() : void in class org.apache.flink.optimizer.ParallelismChangeTest |
From |
To |