1010426455f95e293cf3986ef456db454aa4ef07
Files Diff
- Added: 11
- Removed: 11
- Renamed: 0
- Modified: 41
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Method | 3 | ||
| Rename Method public testGenerateShuffleStags() : void renamed to public testBatchGenerateShuffleStags() : void in class org.apache.flink.table.plan.nodes.resource.parallelism.ShuffleStageGeneratorTest | From | To | |
| Rename Method public testSourceAndCalc() : void renamed to public testBatchSourceAndCalc() : void in class org.apache.flink.table.plan.nodes.resource.parallelism.ShuffleStageParallelismCalculatorTest | From | To | |
| Rename Method public testOnlySource() : void renamed to public testOnlyBatchSource() : void in class org.apache.flink.table.plan.nodes.resource.parallelism.ShuffleStageParallelismCalculatorTest | From | To | |
| Change Parameter Type | 2 | ||
| Change Parameter Type tEnv : TableEnvironment to env : StreamExecutionEnvironment in method private FinalParallelismSetter(env StreamExecutionEnvironment) in class org.apache.flink.table.plan.nodes.resource.parallelism.FinalParallelismSetter | From | To | |
| Change Parameter Type tEnv : TableEnvironment to env : StreamExecutionEnvironment in method public calculate(env StreamExecutionEnvironment, sinkNodes List<ExecNode<?,?>>) : Map<ExecNode<?,?>,Integer> in class org.apache.flink.table.plan.nodes.resource.parallelism.FinalParallelismSetter | From | To | |
| Move And Rename Class | 5 | ||
| Move And Rename Class org.apache.flink.table.plan.nodes.resource.batch.parallelism.BatchShuffleStageParallelismCalculator moved and renamed to org.apache.flink.table.plan.nodes.resource.parallelism.ShuffleStageParallelismCalculator | From | To | |
| Move And Rename Class org.apache.flink.table.plan.nodes.resource.batch.parallelism.BatchShuffleStageParallelismCalculatorTest moved and renamed to org.apache.flink.table.plan.nodes.resource.parallelism.ShuffleStageParallelismCalculatorTest | From | To | |
| Move And Rename Class org.apache.flink.table.plan.nodes.resource.batch.parallelism.BatchFinalParallelismSetter moved and renamed to org.apache.flink.table.plan.nodes.resource.parallelism.FinalParallelismSetter | From | To | |
| Move And Rename Class org.apache.flink.table.plan.nodes.resource.batch.parallelism.BatchFinalParallelismSetterTest moved and renamed to org.apache.flink.table.plan.nodes.resource.parallelism.FinalParallelismSetterTest | From | To | |
| Move And Rename Class org.apache.flink.table.plan.nodes.resource.batch.parallelism.BatchParallelismProcessor moved and renamed to org.apache.flink.table.plan.nodes.resource.parallelism.ParallelismProcessor | From | To | |
| Move Class | 4 | ||
| Move Class org.apache.flink.table.plan.nodes.resource.batch.parallelism.ShuffleStage moved to org.apache.flink.table.plan.nodes.resource.parallelism.ShuffleStage | From | To | |
| Move Class org.apache.flink.table.plan.nodes.resource.batch.parallelism.NodeResourceConfig moved to org.apache.flink.table.plan.nodes.resource.NodeResourceConfig | From | To | |
| Move Class org.apache.flink.table.plan.nodes.resource.batch.parallelism.ShuffleStageGenerator moved to org.apache.flink.table.plan.nodes.resource.parallelism.ShuffleStageGenerator | From | To | |
| Move Class org.apache.flink.table.plan.nodes.resource.batch.parallelism.ShuffleStageGeneratorTest moved to org.apache.flink.table.plan.nodes.resource.parallelism.ShuffleStageGeneratorTest | From | To | |
| Rename Attribute | 2 | ||
| Rename Attribute tableSourceScan : BatchExecTableSourceScan to batchTableSourceScan : BatchExecTableSourceScan in class org.apache.flink.table.plan.nodes.resource.parallelism.ShuffleStageParallelismCalculatorTest | From | To | |
| Rename Attribute tEnv : TableEnvironment to env : StreamExecutionEnvironment in class org.apache.flink.table.plan.nodes.resource.parallelism.FinalParallelismSetter | From | To | |
| Change Variable Type | 1 | ||
| Change Variable Type setter : BatchFinalParallelismSetter to setter : FinalParallelismSetter in method public calculate(env StreamExecutionEnvironment, sinkNodes List<ExecNode<?,?>>) : Map<ExecNode<?,?>,Integer> in class org.apache.flink.table.plan.nodes.resource.parallelism.FinalParallelismSetter | From | To | |
| Change Attribute Type | 1 | ||
| Change Attribute Type tEnv : TableEnvironment to env : StreamExecutionEnvironment in class org.apache.flink.table.plan.nodes.resource.parallelism.FinalParallelismSetter | From | To | |
| Extract And Move Method | 5 | ||
| Extract And Move Method public calculate(tableConf Configuration, envParallelism int, shuffleStages Collection<ShuffleStage>) : void extracted from public testNoSource() : void in class org.apache.flink.table.plan.nodes.resource.batch.parallelism.BatchShuffleStageParallelismCalculatorTest & moved to class org.apache.flink.table.plan.nodes.resource.parallelism.ShuffleStageParallelismCalculator | From | To | |
| Extract And Move Method public calculate(tableConf Configuration, envParallelism int, shuffleStages Collection<ShuffleStage>) : void extracted from public process(sinkNodes List<ExecNode<?,?>>, context DAGProcessContext) : List<ExecNode<?,?>> in class org.apache.flink.table.plan.nodes.resource.batch.parallelism.BatchParallelismProcessor & moved to class org.apache.flink.table.plan.nodes.resource.parallelism.ShuffleStageParallelismCalculator | From | To | |
| Extract And Move Method public calculate(tableConf Configuration, envParallelism int, shuffleStages Collection<ShuffleStage>) : void extracted from public testOnlySource() : void in class org.apache.flink.table.plan.nodes.resource.batch.parallelism.BatchShuffleStageParallelismCalculatorTest & moved to class org.apache.flink.table.plan.nodes.resource.parallelism.ShuffleStageParallelismCalculator | From | To | |
| Extract And Move Method public calculate(tableConf Configuration, envParallelism int, shuffleStages Collection<ShuffleStage>) : void extracted from public testEnvParallelism() : void in class org.apache.flink.table.plan.nodes.resource.batch.parallelism.BatchShuffleStageParallelismCalculatorTest & moved to class org.apache.flink.table.plan.nodes.resource.parallelism.ShuffleStageParallelismCalculator | From | To | |
| Extract And Move Method public calculate(tableConf Configuration, envParallelism int, shuffleStages Collection<ShuffleStage>) : void extracted from public testSourceAndCalc() : void in class org.apache.flink.table.plan.nodes.resource.batch.parallelism.BatchShuffleStageParallelismCalculatorTest & moved to class org.apache.flink.table.plan.nodes.resource.parallelism.ShuffleStageParallelismCalculator | From | To | |
| Rename Parameter | 3 | ||
| Rename Parameter tEnv : TableEnvironment to env : StreamExecutionEnvironment in method private FinalParallelismSetter(env StreamExecutionEnvironment) in class org.apache.flink.table.plan.nodes.resource.parallelism.FinalParallelismSetter | From | To | |
| Rename Parameter tEnv : TableEnvironment to env : StreamExecutionEnvironment in method public calculate(env StreamExecutionEnvironment, sinkNodes List<ExecNode<?,?>>) : Map<ExecNode<?,?>,Integer> in class org.apache.flink.table.plan.nodes.resource.parallelism.FinalParallelismSetter | From | To | |
| Rename Parameter batchExecNode : ExecNode<?,?> to execNode : ExecNode<?,?> in method private calculate(execNode ExecNode<?,?>) : void in class org.apache.flink.table.plan.nodes.resource.parallelism.FinalParallelismSetter | From | To |