flink 1c50d87c190f4845161bb3e281a5904efb32a605

1c50d87c190f4845161bb3e281a5904efb32a605

Files Diff

Added: 7
Removed: 0
Renamed: 0
Modified: 25

Link to commit

Dependency Action

Refactorings reported:

	Refactoring Name	Occurences
	Rename Attribute	1
	Rename Attribute pactPlan : Plan to originalProgram : Plan in class org.apache.flink.compiler.plan.OptimizedPlan	From	To
	Change Variable Type	1
	Change Variable Type buf : StringBuffer to buf : StringBuilder in method public toString() : String in class org.apache.flink.api.common.operators.Ordering	From	To
	Extract Variable	3
	Extract Variable shipType : ShipStrategyType in method public getAlternativePlans(estimator CostEstimator) : List<PlanNode> from class org.apache.flink.compiler.dag.TwoInputNode	From	To
	Extract Variable shipStrategy : ShipStrategyType in method public getAlternativePlans(estimator CostEstimator) : List<PlanNode> from class org.apache.flink.compiler.dag.SingleInputNode	From	To
	Rename Parameter	4
	Rename Parameter pactPlan : Plan to programPlan : Plan in method public OptimizedPlan(sources Collection<SourcePlanNode>, sinks Collection<SinkPlanNode>, allNodes Collection<PlanNode>, jobName String, programPlan Plan) in class org.apache.flink.compiler.plan.OptimizedPlan	From	To
	Rename Parameter contractToNode : Map<Operator<?>,OptimizerNode> to operatorToNode : Map<Operator<?>,OptimizerNode> in method public abstract setInput(operatorToNode Map<Operator<?>,OptimizerNode>, defaultExchangeMode ExecutionMode) : void in class org.apache.flink.compiler.dag.OptimizerNode	From	To
	Rename Parameter degreeOfParallelism : int to parallelism : int in method public setDegreeOfParallelism(parallelism int) : void in class org.apache.flink.compiler.dag.OptimizerNode	From	To
	Rename Parameter pactContract : SingleInputOperator<?,?,?> to programOperator : SingleInputOperator<?,?,?> in method protected SingleInputNode(programOperator SingleInputOperator<?,?,?>) in class org.apache.flink.compiler.dag.SingleInputNode	From	To