|
Rename Method public getPactContract() : GenericDataSinkBase<?> renamed to public getOperator() : GenericDataSinkBase<?> in class org.apache.flink.optimizer.dag.DataSinkNode |
From |
To |
|
Rename Method public getPactContract() : GroupReduceOperatorBase<?,?,?> renamed to public getOperator() : GroupReduceOperatorBase<?,?,?> in class org.apache.flink.optimizer.dag.GroupReduceNode |
From |
To |
|
Rename Method public getPactContract() : SortPartitionOperatorBase<?> renamed to public getOperator() : SortPartitionOperatorBase<?> in class org.apache.flink.optimizer.dag.SortPartitionNode |
From |
To |
|
Rename Method public getPactContract() : FilterOperatorBase<?,?> renamed to public getOperator() : FilterOperatorBase<?,?> in class org.apache.flink.optimizer.dag.FilterNode |
From |
To |
|
Rename Method public setDegreeOfParallelism(parallelism int) : void renamed to public setParallelism(parallelism int) : void in class org.apache.flink.optimizer.plan.PlanNode |
From |
To |
|
Rename Method public getPactContract() : CoGroupOperatorBase<?,?,?,?> renamed to public getOperator() : CoGroupOperatorBase<?,?,?,?> in class org.apache.flink.optimizer.dag.CoGroupNode |
From |
To |
|
Rename Method public getPactContract() : ReduceOperatorBase<?,?> renamed to public getOperator() : ReduceOperatorBase<?,?> in class org.apache.flink.optimizer.dag.ReduceNode |
From |
To |
|
Rename Method public getPactContract() : FlatMapOperatorBase<?,?,?> renamed to public getOperator() : FlatMapOperatorBase<?,?,?> in class org.apache.flink.optimizer.dag.FlatMapNode |
From |
To |
|
Rename Method public getDegreeOfParallelism() : int renamed to public getParallelism() : int in class org.apache.flink.optimizer.dag.OptimizerNode |
From |
To |
|
Rename Method public getPactContract() : JoinOperatorBase<?,?,?,?> renamed to public getOperator() : JoinOperatorBase<?,?,?,?> in class org.apache.flink.optimizer.dag.MatchNode |
From |
To |
|
Rename Method public getPactContract() : GroupCombineOperatorBase<?,?,?> renamed to public getOperator() : GroupCombineOperatorBase<?,?,?> in class org.apache.flink.optimizer.dag.GroupCombineNode |
From |
To |
|
Rename Method public getDegreeOfParallelism() : int renamed to public getParallelism() : int in class org.apache.flink.optimizer.plan.PlanNode |
From |
To |
|
Rename Method public getPactContract() : SolutionSetPlaceHolder<?> renamed to public getOperator() : SolutionSetPlaceHolder<?> in class org.apache.flink.optimizer.dag.SolutionSetNode |
From |
To |
|
Rename Method public getPactContract() : PartialSolutionPlaceHolder<?> renamed to public getOperator() : PartialSolutionPlaceHolder<?> in class org.apache.flink.optimizer.dag.BulkPartialSolutionNode |
From |
To |
|
Rename Method public getPactContract() : SingleInputOperator<?,?,?> renamed to public getOperator() : SingleInputOperator<?,?,?> in class org.apache.flink.optimizer.dag.SingleInputNode |
From |
To |
|
Rename Method public getPactContract() : CrossOperatorBase<?,?,?,?> renamed to public getOperator() : CrossOperatorBase<?,?,?,?> in class org.apache.flink.optimizer.dag.CrossNode |
From |
To |
|
Rename Method public getPactContract() : Operator<?> renamed to public getProgramOperator() : Operator<?> in class org.apache.flink.optimizer.plan.PlanNode |
From |
To |
|
Rename Method public getPactContract() : Operator<?> renamed to public getOperator() : Operator<?> in class org.apache.flink.optimizer.dag.OptimizerNode |
From |
To |
|
Rename Method public getPactContract() : GenericDataSourceBase<?,?> renamed to public getOperator() : GenericDataSourceBase<?,?> in class org.apache.flink.optimizer.dag.DataSourceNode |
From |
To |
|
Rename Method public getPactContract() : WorksetPlaceHolder<?> renamed to public getOperator() : WorksetPlaceHolder<?> in class org.apache.flink.optimizer.dag.WorksetNode |
From |
To |
|
Rename Method public getPactContract() : PartitionOperatorBase<?> renamed to public getOperator() : PartitionOperatorBase<?> in class org.apache.flink.optimizer.dag.PartitionNode |
From |
To |
|
Rename Method public getPactContract() : JoinOperatorBase<?,?,?,?> renamed to public getOperator() : JoinOperatorBase<?,?,?,?> in class org.apache.flink.optimizer.dag.JoinNode |
From |
To |
|
Rename Method public getPactContract() : DualInputOperator<?,?,?,?> renamed to public getOperator() : DualInputOperator<?,?,?,?> in class org.apache.flink.optimizer.dag.TwoInputNode |
From |
To |
|
Change Variable Type conn : PactConnection to conn : DagConnection in method public computeInterestingPropertiesForInputs(estimator CostEstimator) : void in class org.apache.flink.optimizer.dag.TwoInputNode |
From |
To |
|
Change Variable Type jobGen : NepheleJobGraphGenerator to jobGen : JobGraphGenerator in method public testReduce() : void in class org.apache.flink.optimizer.ReduceAllTest |
From |
To |
|
Change Variable Type jgg : NepheleJobGraphGenerator to jgg : JobGraphGenerator in method public testWorksetConnectedComponentsWithSolutionSetAsFirstInput() : void in class org.apache.flink.test.compiler.iterations.ConnectedComponentsTest |
From |
To |
|
Change Variable Type jgg : NepheleJobGraphGenerator to jgg : JobGraphGenerator in method protected getJobGraph() : JobGraph in class org.apache.flink.test.util.RecordAPITestBase |
From |
To |
|
Change Variable Type broadcastConnections : List<PactConnection> to broadcastConnections : List<DagConnection> in method public getAlternativePlans(estimator CostEstimator) : List<PlanNode> in class org.apache.flink.optimizer.dag.BinaryUnionNode |
From |
To |
|
Change Variable Type conn : PactConnection to conn : DagConnection in method public postVisit(visitable OptimizerNode) : void in class org.apache.flink.optimizer.Optimizer.IdAndEstimatesVisitor |
From |
To |
|
Change Variable Type jgg : NepheleJobGraphGenerator to jgg : JobGraphGenerator in method private getJobGraph(plan Plan) : JobGraph in class org.apache.flink.test.cancelling.CancellingTestBase |
From |
To |
|
Change Variable Type conn1 : PactConnection to conn1 : DagConnection in method public setInput(contractToNode Map<Operator<?>,OptimizerNode>, defaultExecutionMode ExecutionMode) : void in class org.apache.flink.optimizer.dag.TwoInputNode |
From |
To |
|
Change Variable Type pc : PactCompiler to pc : Optimizer in method private getJobGraph(plan Plan) : JobGraph in class org.apache.flink.test.cancelling.CancellingTestBase |
From |
To |
|
Change Variable Type broadcastConnections : List<PactConnection> to broadcastConnections : List<DagConnection> in method public getAlternativePlans(estimator CostEstimator) : List<PlanNode> in class org.apache.flink.optimizer.dag.SingleInputNode |
From |
To |
|
Change Variable Type pc : PactCompiler to pc : Optimizer in method protected getJobGraph() : JobGraph in class org.apache.flink.test.util.RecordAPITestBase |
From |
To |
|
Change Variable Type jgg : NepheleJobGraphGenerator to jgg : JobGraphGenerator in method public testWorksetConnectedComponents() : void in class org.apache.flink.test.compiler.iterations.ConnectedComponentsTest |
From |
To |
|
Change Variable Type dagCreator : PactCompiler.GraphCreatingVisitor to dagCreator : Optimizer.GraphCreatingVisitor in method private convertPlan(p Plan) : List<DataSinkNode> in class org.apache.flink.optimizer.dataexchange.PipelineBreakingTest |
From |
To |
|
Change Variable Type pc : PactCompiler to pc : Optimizer in method public executePlan(plan Plan) : JobExecutionResult in class org.apache.flink.client.LocalExecutor |
From |
To |
|
Change Variable Type jobGen : NepheleJobGraphGenerator to jobGen : JobGraphGenerator in method public testUnionNewApiAssembly() : void in class org.apache.flink.optimizer.UnionPropertyPropagationTest |
From |
To |
|
Change Variable Type jgg : NepheleJobGraphGenerator to jgg : JobGraphGenerator in method protected getFailingJobGraph() : JobGraph in class org.apache.flink.test.failingPrograms.TaskFailureITCase |
From |
To |
|
Change Variable Type jobGen : NepheleJobGraphGenerator to jobGen : JobGraphGenerator in method public testBranchingSourceMultipleTimes() : void in class org.apache.flink.optimizer.BranchingPlansCompilerTest |
From |
To |
|
Change Variable Type conn : PactConnection to conn : DagConnection in method public computeInterestingPropertiesForInputs(estimator CostEstimator) : void in class org.apache.flink.optimizer.dag.SingleInputNode |
From |
To |
|
Change Variable Type broadcastConnection : PactConnection to broadcastConnection : DagConnection in method public getAlternativePlans(estimator CostEstimator) : List<PlanNode> in class org.apache.flink.optimizer.dag.TwoInputNode |
From |
To |
|
Change Variable Type pc : PactCompiler to pc : Optimizer in method protected getJobGraph() : JobGraph in class org.apache.flink.test.failingPrograms.TaskFailureITCase |
From |
To |
|
Change Variable Type jgg : NepheleJobGraphGenerator to jgg : JobGraphGenerator in method protected getJobGraph() : JobGraph in class org.apache.flink.test.failingPrograms.TaskFailureITCase |
From |
To |
|
Change Variable Type inputs : ArrayList<PactConnection> to inputs : ArrayList<DagConnection> in method public getIncomingConnections() : List<DagConnection> in class org.apache.flink.optimizer.dag.TwoInputNode |
From |
To |
|
Change Variable Type jobGen : NepheleJobGraphGenerator to jobGen : JobGraphGenerator in method public testCostComputationWithMultipleDataSinks() : void in class org.apache.flink.optimizer.BranchingPlansCompilerTest |
From |
To |
|
Change Variable Type jgg : NepheleJobGraphGenerator to jgg : JobGraphGenerator in method public testWorksetIterationNotDependingOnSolutionSet() : void in class org.apache.flink.optimizer.WorksetIterationCornerCasesTest |
From |
To |
|
Change Variable Type pc : PactCompiler to pc : Optimizer in method private compileProgram(jobName String) : OptimizedPlan in class org.apache.flink.test.util.TestEnvironment |
From |
To |
|
Change Variable Type pc : PactCompiler to pc : Optimizer in method public optimizerPlanAsJSON(plan Plan) : String in class org.apache.flink.client.LocalExecutor |
From |
To |
|
Change Variable Type jgg : NepheleJobGraphGenerator to jgg : JobGraphGenerator in method public testWorksetConnectedComponents() : void in class org.apache.flink.test.compiler.iterations.ConnectedComponentsCoGroupTest |
From |
To |
|
Change Variable Type broadcastConnections : List<PactConnection> to broadcastConnections : List<DagConnection> in method public getAlternativePlans(estimator CostEstimator) : List<PlanNode> in class org.apache.flink.optimizer.dag.TwoInputNode |
From |
To |
|
Change Variable Type jobGen : NepheleJobGraphGenerator to jobGen : JobGraphGenerator in method public testBranchEachContractType() : void in class org.apache.flink.optimizer.BranchingPlansCompilerTest |
From |
To |
|
Change Variable Type jobGen : NepheleJobGraphGenerator to jobGen : JobGraphGenerator in method public testBranchingWithMultipleDataSinks2() : void in class org.apache.flink.optimizer.BranchingPlansCompilerTest |
From |
To |
|
Change Variable Type c : PactConnection to c : DagConnection in method public computeOutputEstimates(statistics DataStatistics) : void in class org.apache.flink.optimizer.dag.OptimizerNode |
From |
To |
|
Change Variable Type broadcastInput : PactConnection to broadcastInput : DagConnection in method protected computeUnclosedBranchStackForBroadcastInputs(branchesSoFar List<UnclosedBranchDescriptor>) : List<UnclosedBranchDescriptor> in class org.apache.flink.optimizer.dag.OptimizerNode |
From |
To |
|
Change Variable Type conn : PactConnection to conn : DagConnection in method public getMaxDepth() : int in class org.apache.flink.optimizer.dag.OptimizerNode |
From |
To |
|
Change Variable Type pactConnection : PactConnection to dagConnection : DagConnection in method public getPredecessors() : Iterable<OptimizerNode> in class org.apache.flink.optimizer.dag.OptimizerNode |
From |
To |
|
Change Variable Type broadcastConnection : PactConnection to broadcastConnection : DagConnection in method public getAlternativePlans(estimator CostEstimator) : List<PlanNode> in class org.apache.flink.optimizer.dag.SingleInputNode |
From |
To |
|
Change Variable Type conns : List<PactConnection> to conns : List<DagConnection> in method public computeUnionOfInterestingPropertiesFromSuccessors() : void in class org.apache.flink.optimizer.dag.OptimizerNode |
From |
To |
|
Change Variable Type jgg : NepheleJobGraphGenerator to jgg : JobGraphGenerator in method public executePlan(plan Plan) : JobExecutionResult in class org.apache.flink.client.LocalExecutor |
From |
To |
|
Change Variable Type jobGen : NepheleJobGraphGenerator to jobGen : JobGraphGenerator in method public testUnionPropertyOldApiPropagation() : void in class org.apache.flink.optimizer.UnionPropertyPropagationTest |
From |
To |
|
Change Variable Type noOpConn : PactConnection to noOpConn : DagConnection in method public setNextPartialSolution(solutionSetDelta OptimizerNode, nextWorkset OptimizerNode, executionMode ExecutionMode) : void in class org.apache.flink.optimizer.dag.WorksetIterationNode |
From |
To |
|
Change Variable Type worksetInput : PactConnection to worksetInput : DagConnection in method public computeUnclosedBranchStack() : void in class org.apache.flink.optimizer.dag.WorksetNode |
From |
To |
|
Change Variable Type pc : PactCompiler to pc : Optimizer in method public getOptimizerPlanAsJSON(plan Plan) : String in class org.apache.flink.client.LocalExecutor |
From |
To |
|
Change Variable Type connection : PactConnection to connection : DagConnection in method public accept(visitor Visitor<OptimizerNode>) : void in class org.apache.flink.optimizer.dag.SingleInputNode |
From |
To |
|
Change Variable Type solutionSetInput : PactConnection to solutionSetInput : DagConnection in method public computeUnclosedBranchStack() : void in class org.apache.flink.optimizer.dag.SolutionSetNode |
From |
To |
|
Change Variable Type conn : PactConnection to conn : DagConnection in method public haveAllOutputConnectionInterestingProperties() : boolean in class org.apache.flink.optimizer.dag.OptimizerNode |
From |
To |
|
Change Variable Type jobGen : NepheleJobGraphGenerator to jobGen : JobGraphGenerator in method public checkPropertyHandlingWithTwoInputs() : void in class org.apache.flink.optimizer.DOPChangeTest |
From |
To |
|
Change Variable Type conn1 : PactConnection to conn1 : DagConnection in method public SinkJoiner(input1 OptimizerNode, input2 OptimizerNode) in class org.apache.flink.optimizer.dag.SinkJoiner |
From |
To |
|
Change Variable Type jgg : NepheleJobGraphGenerator to jgg : JobGraphGenerator in method protected getJobGraph() : JobGraph in class org.apache.flink.test.operators.ReduceITCase |
From |
To |
|
Change Variable Type pc : PactCompiler to pc : Optimizer in method protected getJobGraph() : JobGraph in class org.apache.flink.test.operators.UnionSinkITCase |
From |
To |
|
Change Variable Type jobGen : NepheleJobGraphGenerator to jobGen : JobGraphGenerator in method public testBranchingWithMultipleDataSinksSmall() : void in class org.apache.flink.optimizer.BranchingPlansCompilerTest |
From |
To |
|
Change Variable Type jobGen : NepheleJobGraphGenerator to jobGen : JobGraphGenerator in method public testBranchingUnion() : void in class org.apache.flink.optimizer.BranchingPlansCompilerTest |
From |
To |
|
Change Variable Type conn : PactConnection to conn : DagConnection in method public clearInterestingProperties() : void in class org.apache.flink.optimizer.dag.OptimizerNode |
From |
To |
|
Change Variable Type conn : PactConnection to conn : DagConnection in method public setNextPartialSolution(solutionSetDelta OptimizerNode, nextWorkset OptimizerNode, executionMode ExecutionMode) : void in class org.apache.flink.optimizer.dag.WorksetIterationNode |
From |
To |
|
Change Variable Type jobGen : NepheleJobGraphGenerator to jobGen : JobGraphGenerator in method public testUnionReplacement() : void in class org.apache.flink.optimizer.UnionReplacementTest |
From |
To |
|
Change Variable Type noOpConn : PactConnection to noOpConn : DagConnection in method public setNextPartialSolution(nextPartialSolution OptimizerNode, terminationCriterion OptimizerNode) : void in class org.apache.flink.optimizer.dag.BulkIterationNode |
From |
To |
|
Change Variable Type pc : PactCompiler to pc : Optimizer in method protected getJobGraph() : JobGraph in class org.apache.flink.test.operators.ReduceITCase |
From |
To |
|
Change Variable Type conn : PactConnection to conn : DagConnection in method public markAllOutgoingConnectionsAsPipelineBreaking() : void in class org.apache.flink.optimizer.dag.OptimizerNode |
From |
To |
|
Change Variable Type conn2 : PactConnection to conn2 : DagConnection in method public SinkJoiner(input1 OptimizerNode, input2 OptimizerNode) in class org.apache.flink.optimizer.dag.SinkJoiner |
From |
To |
|
Change Variable Type connection : PactConnection to connection : DagConnection in method public accept(visitor Visitor<OptimizerNode>) : void in class org.apache.flink.optimizer.dag.TwoInputNode |
From |
To |
|
Change Variable Type pc : PactCompiler to pc : Optimizer in method protected getFailingJobGraph() : JobGraph in class org.apache.flink.test.failingPrograms.TaskFailureITCase |
From |
To |
|
Change Variable Type conn2 : PactConnection to conn2 : DagConnection in method public setInput(contractToNode Map<Operator<?>,OptimizerNode>, defaultExecutionMode ExecutionMode) : void in class org.apache.flink.optimizer.dag.TwoInputNode |
From |
To |
|
Change Variable Type jgg : NepheleJobGraphGenerator to jgg : JobGraphGenerator in method public execute(jobName String) : JobExecutionResult in class org.apache.flink.test.util.TestEnvironment |
From |
To |
|
Change Variable Type jobGen : NepheleJobGraphGenerator to jobGen : JobGraphGenerator in method public testTicket158() : void in class org.apache.flink.optimizer.HardPlansCompilationTest |
From |
To |
|
Change Variable Type connection : PactConnection to connection : DagConnection in method public setBroadcastInputs(operatorToNode Map<Operator<?>,OptimizerNode>, defaultExchangeMode ExecutionMode) : void in class org.apache.flink.optimizer.dag.OptimizerNode |
From |
To |
|
Change Variable Type conn : PactConnection to conn : DagConnection in method public identifyDynamicPath(costWeight int) : void in class org.apache.flink.optimizer.dag.OptimizerNode |
From |
To |
|
Change Variable Type jobGen : NepheleJobGraphGenerator to jobGen : JobGraphGenerator in method public testBranchingWithMultipleDataSinks() : void in class org.apache.flink.optimizer.BranchingPlansCompilerTest |
From |
To |
|
Change Variable Type conn : PactConnection to conn : DagConnection in method public setInput(contractToNode Map<Operator<?>,OptimizerNode>, defaultExchangeMode ExecutionMode) : void in class org.apache.flink.optimizer.dag.DataSinkNode |
From |
To |
|
Change Variable Type conn : PactConnection to conn : DagConnection in method public toString() : String in class org.apache.flink.optimizer.dag.OptimizerNode |
From |
To |
|
Change Variable Type conn : PactConnection to conn : DagConnection in method public getPredecessors() : Iterable<OptimizerNode> in class org.apache.flink.optimizer.dag.OptimizerNode |
From |
To |
|
Change Variable Type jgg : NepheleJobGraphGenerator to jgg : JobGraphGenerator in method protected getJobGraph() : JobGraph in class org.apache.flink.test.operators.UnionSinkITCase |
From |
To |
|
Change Variable Type conn : PactConnection to conn : DagConnection in method public postVisit(c Operator<?>) : void in class org.apache.flink.optimizer.Optimizer.GraphCreatingVisitor |
From |
To |
|
Change Variable Type conn : PactConnection to conn : DagConnection in method public setInput(contractToNode Map<Operator<?>,OptimizerNode>, defaultExchangeMode ExecutionMode) : void in class org.apache.flink.optimizer.dag.SingleInputNode |
From |
To |
|
Change Variable Type gen : NepheleJobGraphGenerator to gen : JobGraphGenerator in method private getJobGraph(optPlan FlinkPlan, jarFiles List<File>) : JobGraph in class org.apache.flink.client.program.Client |
From |
To |
|
Change Attribute Type withStatsCompiler : PactCompiler to withStatsCompiler : Optimizer in class org.apache.flink.test.compiler.util.CompilerTestBase |
From |
To |
|
Change Attribute Type nextWorksetRootConnection : PactConnection to nextWorksetRootConnection : DagConnection in class org.apache.flink.optimizer.dag.WorksetIterationNode |
From |
To |
|
Change Attribute Type noStatsCompiler : PactCompiler to noStatsCompiler : Optimizer in class org.apache.flink.test.compiler.util.CompilerTestBase |
From |
To |
|
Change Attribute Type input : PactConnection to input : DagConnection in class org.apache.flink.optimizer.dag.DataSinkNode |
From |
To |
|
Change Attribute Type solutionSetDeltaRootConnection : PactConnection to solutionSetDeltaRootConnection : DagConnection in class org.apache.flink.optimizer.dag.WorksetIterationNode |
From |
To |
|
Change Attribute Type input2 : PactConnection to input2 : DagConnection in class org.apache.flink.optimizer.dag.TwoInputNode |
From |
To |
|
Change Attribute Type terminationCriterionRootConnection : PactConnection to terminationCriterionRootConnection : DagConnection in class org.apache.flink.optimizer.dag.BulkIterationNode |
From |
To |
|
Change Attribute Type generatorMock : NepheleJobGraphGenerator to generatorMock : JobGraphGenerator in class org.apache.flink.client.program.ClientTest |
From |
To |
|
Change Attribute Type withStatsCompiler : PactCompiler to withStatsCompiler : Optimizer in class org.apache.flink.optimizer.CompilerTestBase |
From |
To |
|
Change Attribute Type rootConnection : PactConnection to rootConnection : DagConnection in class org.apache.flink.optimizer.dag.BulkIterationNode |
From |
To |
|
Change Attribute Type compilerMock : PactCompiler to compilerMock : Optimizer in class org.apache.flink.client.program.ClientTest |
From |
To |
|
Change Attribute Type compiler : PactCompiler to compiler : Optimizer in class org.apache.flink.client.program.Client |
From |
To |
|
Change Attribute Type compiler : PactCompiler to compiler : Optimizer in class org.apache.flink.client.program.Client.OptimizerPlanEnvironment |
From |
To |
|
Change Attribute Type noStatsCompiler : PactCompiler to noStatsCompiler : Optimizer in class org.apache.flink.optimizer.CompilerTestBase |
From |
To |
|
Change Attribute Type outgoingConnections : List<PactConnection> to outgoingConnections : List<DagConnection> in class org.apache.flink.optimizer.dag.OptimizerNode |
From |
To |
|
Change Attribute Type broadcastConnections : List<PactConnection> to broadcastConnections : List<DagConnection> in class org.apache.flink.optimizer.dag.OptimizerNode |
From |
To |
|
Change Attribute Type inConn : PactConnection to inConn : DagConnection in class org.apache.flink.optimizer.dag.SingleInputNode |
From |
To |
|
Change Attribute Type input1 : PactConnection to input1 : DagConnection in class org.apache.flink.optimizer.dag.TwoInputNode |
From |
To |