|
Rename Method public checkJoinWithReplicatedSourceInputBehindMapChangingDOP() : void renamed to public checkJoinWithReplicatedSourceInputBehindMapChangingparallelism() : void in class org.apache.flink.optimizer.ReplicatingDataSourceTest |
From |
To |
|
Rename Method public testPojoSortingNestedDOP1() : void renamed to public testPojoSortingNestedParallelism1() : void in class org.apache.flink.test.javaApiOperators.DataSinkITCase |
From |
To |
|
Rename Method public testTupleSortingNestedDOP1_2() : void renamed to public testTupleSortingNestedParallelism1_2() : void in class org.apache.flink.test.javaApiOperators.DataSinkITCase |
From |
To |
|
Rename Method public setDefaultDegreeOfParallelism(defaultDegreeOfParallelism int) : void renamed to public setDefaultParallelism(defaultParallelism int) : void in class org.apache.flink.optimizer.Optimizer |
From |
To |
|
Rename Method public testPojoSortingDualDOP1() : void renamed to public testPojoSortingDualParallelism1() : void in class org.apache.flink.test.javaApiOperators.DataSinkITCase |
From |
To |
|
Rename Method public testPojoSortingSingleDOP1() : void renamed to public testPojoSortingSingleParallelism1() : void in class org.apache.flink.test.javaApiOperators.DataSinkITCase |
From |
To |
|
Rename Method public getDegreeOfParallelism() : int renamed to public getParallelism() : int in class org.apache.flink.test.util.JavaProgramTestBase |
From |
To |
|
Rename Method public testHashPartitionByKeyFieldAndDifferentDOP() : void renamed to public testHashPartitionByKeyFieldAndDifferentParallelism() : void in class org.apache.flink.test.javaApiOperators.PartitionITCase |
From |
To |
|
Rename Method public checkPropertyHandlingWithDecreasingDegreeOfParallelism() : void renamed to public checkPropertyHandlingWithDecreasingParallelism() : void in class org.apache.flink.optimizer.ParallelismChangeTest |
From |
To |
|
Rename Method public testStringSortingDOP1() : void renamed to public testStringSortingParallelism1() : void in class org.apache.flink.test.javaApiOperators.DataSinkITCase |
From |
To |
|
Rename Method public testTupleSortingSingleAscDOP1() : void renamed to public testTupleSortingSingleAscParallelism1() : void in class org.apache.flink.test.javaApiOperators.DataSinkITCase |
From |
To |
|
Rename Method public setDegreeOfParallelism(degreeOfParallelism int) : void renamed to public setParallelism(parallelism int) : void in class org.apache.flink.streaming.util.StreamingProgramTestBase |
From |
To |
|
Rename Method public getDefaultDegreeOfParallelism() : int renamed to public getDefaultParallelism() : int in class org.apache.flink.optimizer.Optimizer |
From |
To |
|
Rename Method public testSortingDOP4() : void renamed to public testSortingParallelism4() : void in class org.apache.flink.test.javaApiOperators.DataSinkITCase |
From |
To |
|
Rename Method public testTupleSortingSingleDescDOP1() : void renamed to public testTupleSortingSingleDescParallelism1() : void in class org.apache.flink.test.javaApiOperators.DataSinkITCase |
From |
To |
|
Rename Method public testIntSortingDOP1() : void renamed to public testIntSortingParallelism1() : void in class org.apache.flink.test.javaApiOperators.DataSinkITCase |
From |
To |
|
Rename Method public testTupleSortingDualDOP1() : void renamed to public testTupleSortingDualParallelism1() : void in class org.apache.flink.test.javaApiOperators.DataSinkITCase |
From |
To |
|
Rename Method public setDegreeOfParallelism(parallelism int) : void renamed to public setParallelism(parallelism int) : void in class org.apache.flink.optimizer.dag.OptimizerNode |
From |
To |
|
Rename Method public setDegreeOfParallelism(degreeOfParallelism int) : void renamed to public setParallelism(parallelism int) : void in class org.apache.flink.test.util.JavaProgramTestBase |
From |
To |
|
Rename Method public getDegreeOfParallelism() : int renamed to public getParallelism() : int in class org.apache.flink.streaming.util.StreamingProgramTestBase |
From |
To |
|
Rename Method public setDegreeOfParallelism(degreeOfParallelism int) : void renamed to public setParallelism(parallelism int) : void in class org.apache.flink.optimizer.dag.DataSourceNode |
From |
To |
|
Rename Method public testTupleSortingNestedDOP1() : void renamed to public testTupleSortingNestedParallelism1() : void in class org.apache.flink.test.javaApiOperators.DataSinkITCase |
From |
To |
|
Rename Method public testCancelSortMatchWithHighDOP() : void renamed to public testCancelSortMatchWithHighparallelism() : void in class org.apache.flink.test.cancelling.MatchJoinCancelingITCase |
From |
To |
|
Rename Method public checkJoinWithReplicatedSourceInputChangingDOP() : void renamed to public checkJoinWithReplicatedSourceInputChangingparallelism() : void in class org.apache.flink.optimizer.ReplicatingDataSourceTest |
From |
To |
|
Rename Method public testSortPartitionDOPChange() : void renamed to public testSortPartitionParallelismChange() : void in class org.apache.flink.test.javaApiOperators.SortPartitionITCase |
From |
To |
|
Rename Variable degreeOfParallelism : int to parallelism : int in method public getJobGraph(args String[]) : JobGraph in class org.apache.flink.test.iterative.nephele.danglingpagerank.CompensatableDanglingPageRank |
From |
To |
|
Rename Variable dop : int to parallelism : int in method public getAlternativePlans(estimator CostEstimator) : List<PlanNode> in class org.apache.flink.optimizer.dag.DataSinkNode |
From |
To |
|
Rename Variable degreeOfParallelism : int to parallelism : int in method public getJobGraph(args String[]) : JobGraph in class org.apache.flink.test.iterative.nephele.customdanglingpagerank.CustomCompensatableDanglingPageRank |
From |
To |
|
Rename Variable dop : int to parallelism : int in method protected StreamPlanEnvironment(env ExecutionEnvironment) in class org.apache.flink.streaming.api.environment.StreamPlanEnvironment |
From |
To |
|
Rename Variable dop : int to parallelism : int in method protected getTestJob() : Plan in class org.apache.flink.test.recordJobTests.GroupOrderReduceITCase |
From |
To |
|
Rename Variable inDop2 : int to inParallelism2 : int in method public getAlternativePlans(estimator CostEstimator) : List<PlanNode> in class org.apache.flink.optimizer.dag.BinaryUnionNode |
From |
To |
|
Rename Variable inDop1 : int to inParallelism1 : int in method public getAlternativePlans(estimator CostEstimator) : List<PlanNode> in class org.apache.flink.optimizer.dag.TwoInputNode |
From |
To |
|
Rename Variable dop : int to parallelism : int in method public getAlternativePlans(estimator CostEstimator) : List<PlanNode> in class org.apache.flink.optimizer.dag.TwoInputNode |
From |
To |
|
Rename Variable paraDegree : int to parallelism : int in method public CliFrontend(configDir String) in class org.apache.flink.client.CliFrontend |
From |
To |
|
Rename Variable inDop2 : int to inParallelism2 : int in method public getAlternativePlans(estimator CostEstimator) : List<PlanNode> in class org.apache.flink.optimizer.dag.TwoInputNode |
From |
To |
|
Rename Variable dop : int to parallelism : int in method public getParameters() : List<Object[]> in class org.apache.flink.api.common.io.SequentialFormatTestBase |
From |
To |
|
Rename Variable ITERATION_DOP : int to ITERATION_parallelism : int in method public testTranslationPlainEdges() : void in class org.apache.flink.spargel.java.SpargelTranslationTest |
From |
To |
|
Rename Variable dop : int to parallelism : int in method public getPlan(args String...) : Plan in class org.apache.flink.test.recordJobs.graph.DanglingPageRank |
From |
To |
|
Rename Variable dop : int to parallelism : int in method private addSource(function SourceFunction<OUT>, outTypeInfo TypeInformation<OUT>, sourceName String) : DataStreamSource<OUT> in class org.apache.flink.streaming.api.environment.StreamExecutionEnvironment |
From |
To |
|
Rename Variable dop : int to parallelism : int in method public getAlternativePlans(estimator CostEstimator) : List<PlanNode> in class org.apache.flink.optimizer.dag.BinaryUnionNode |
From |
To |
|
Rename Variable ITERATION_DOP : int to ITERATION_parallelism : int in method public testTranslationPlainEdgesWithForkedBroadcastVariable() : void in class org.apache.flink.spargel.java.SpargelTranslationTest |
From |
To |
|
Rename Variable degreeOfParallelism : int to parallelism : int in method public getPlan(args String...) : Plan in class org.apache.flink.test.recordJobs.relational.TPCHQuery10 |
From |
To |
|
Rename Variable dop : int to parallelism : int in method public getAlternativePlans(estimator CostEstimator) : List<PlanNode> in class org.apache.flink.optimizer.dag.SingleInputNode |
From |
To |
|
Rename Variable DEFAULT_DOP : int to DEFAULT_parallelism : int in method public testCorrectTranslation() : void in class org.apache.flink.api.java.operators.translation.DeltaIterationTranslationTest |
From |
To |
|
Rename Variable dopChange : boolean to parallelismChange : boolean in method public getAlternativePlans(estimator CostEstimator) : List<PlanNode> in class org.apache.flink.optimizer.dag.SingleInputNode |
From |
To |
|
Rename Variable dop : int to parallelism : int in method public getPlan(args String...) : Plan in class org.apache.flink.test.recordJobs.graph.SimplePageRank |
From |
To |
|
Rename Variable propDegree : String to propParallelism : String in method public CliFrontend(configDir String) in class org.apache.flink.client.CliFrontend |
From |
To |
|
Rename Variable degreeOfParallelism : int to parallelism : int in method public getPlan(args String...) : Plan in class org.apache.flink.test.recordJobs.kmeans.KMeansBroadcast |
From |
To |
|
Rename Variable degreeOfParallelism : int to parallelism : int in method public getJobGraph(args String[]) : JobGraph in class org.apache.flink.test.iterative.nephele.customdanglingpagerank.CustomCompensatableDanglingPageRankWithCombiner |
From |
To |
|
Rename Variable ITERATION_DOP : int to ITERATION_parallelism : int in method public testCorrectTranslation() : void in class org.apache.flink.api.java.operators.translation.DeltaIterationTranslationTest |
From |
To |
|
Rename Variable inDop : int to inParallelism : int in method public getAlternativePlans(estimator CostEstimator) : List<PlanNode> in class org.apache.flink.optimizer.dag.SingleInputNode |
From |
To |
|
Rename Variable degreeOfParallelism : String to parallelism : String in method public run(args String[]) : int in class org.apache.flink.client.FlinkYarnSessionCli |
From |
To |
|
Rename Variable inDop1 : int to inParallelism1 : int in method public getAlternativePlans(estimator CostEstimator) : List<PlanNode> in class org.apache.flink.optimizer.dag.BinaryUnionNode |
From |
To |
|
Rename Attribute degreeOfParallelism : int to parallelism : int in class org.apache.flink.test.recordJobs.relational.TPCHQuery9 |
From |
To |
|
Rename Attribute dop : int to parallelism : int in class org.apache.flink.api.java.operators.Operator |
From |
To |
|
Rename Attribute DEFAULT_PARALLELIZATION_DEGREE : int to DEFAULT_PARALLELISM : int in class org.apache.flink.configuration.ConfigConstants |
From |
To |
|
Rename Attribute DEFAULT_PARALLELIZATION_DEGREE_KEY : String to DEFAULT_PARALLELISM_KEY : String in class org.apache.flink.configuration.ConfigConstants |
From |
To |
|
Rename Attribute DOP : int to parallelism : int in class org.apache.flink.test.util.RecordAPITestBase |
From |
To |
|
Rename Attribute defaultLocalDop : int to defaultLocalParallelism : int in class org.apache.flink.streaming.api.environment.StreamExecutionEnvironment |
From |
To |
|
Rename Attribute degreeOfParallelism : int to parallelism : int in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Rename Attribute YARN_PROPERTIES_DOP : String to YARN_PROPERTIES_PARALLELISM : String in class org.apache.flink.client.CliFrontend |
From |
To |
|
Rename Attribute degreeOfParallelism : int to parallelism : int in class org.apache.flink.api.common.io.SequentialFormatTestBase |
From |
To |
|
Rename Attribute dop : int to parallelism : int in class org.apache.flink.api.java.operators.DataSink |
From |
To |
|
Rename Attribute DOP : int to parallelism : int in class org.apache.flink.test.clients.examples.LocalExecutorITCase |
From |
To |
|
Rename Attribute degreeOfParallelism : int to parallelism : int in class org.apache.flink.test.recordJobs.relational.TPCHQuery1 |
From |
To |
|
Rename Attribute degreeOfParallelism : int to parallelism : int in class org.apache.flink.test.recordJobs.relational.TPCHQuery4 |
From |
To |
|
Rename Attribute forceDOP : boolean to forceParallelism : boolean in class org.apache.flink.optimizer.traversals.GraphCreatingVisitor |
From |
To |
|
Rename Attribute degreeOfParallelism : int to parallelism : int in class org.apache.flink.streaming.util.StreamingProgramTestBase |
From |
To |
|
Rename Attribute defaultDegreeOfParallelism : int to defaultParallelism : int in class org.apache.flink.optimizer.Optimizer |
From |
To |
|
Rename Attribute degreeOfParallelism : int to parallelism : int in class org.apache.flink.test.util.JavaProgramTestBase |
From |
To |
|
Rename Parameter degreeOfParallelism : int to parallelism : int in method private createInput(stub UserCodeWrapper<T>, name String, graph JobGraph, parallelism int) : InputFormatVertex in class org.apache.flink.test.iterative.nephele.JobGraphUtils |
From |
To |
|
Rename Parameter dop : int to parallelism : int in method private translateSelectorFunctionReducer(rawKeys Keys.SelectorFunctionKeys<T,?>, function ReduceFunction<T>, inputType TypeInformation<T>, name String, input Operator<T>, parallelism int) : MapOperatorBase<Tuple2<K,T>,T,?> in class org.apache.flink.api.java.operators.ReduceOperator |
From |
To |
|
Rename Parameter dop : int to parallelism : int in method private createContextEnvironment(client Client, jars List<File>, parallelism int) : StreamExecutionEnvironment in class org.apache.flink.streaming.api.environment.StreamExecutionEnvironment |
From |
To |
|
Rename Parameter degreeOfParallelism : int to parallelism : int in method public TestStreamEnvironment(parallelism int, memorySize long) in class org.apache.flink.streaming.util.TestStreamEnvironment |
From |
To |
|
Rename Parameter degreeOfParallelism : int to parallelism : int in method public createRemoteEnvironment(host String, port int, parallelism int, jarFiles String...) : StreamExecutionEnvironment in class org.apache.flink.streaming.api.environment.StreamExecutionEnvironment |
From |
To |
|
Rename Parameter dop : int to parallelism : int in method public setParallelism(parallelism int) : SingleOutputStreamOperator<OUT,O> in class org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator |
From |
To |
|
Rename Parameter degreeOfParallelism : int to parallelism : int in method public setDefaultLocalParallelism(parallelism int) : void in class org.apache.flink.api.java.ExecutionEnvironment |
From |
To |
|
Rename Parameter forceDOP : boolean to forceParallelism : boolean in method private GraphCreatingVisitor(parent GraphCreatingVisitor, forceParallelism boolean, defaultParallelism int, dataExchangeMode ExecutionMode, closure HashMap<Operator<?>,OptimizerNode>) in class org.apache.flink.optimizer.traversals.GraphCreatingVisitor |
From |
To |
|
Rename Parameter dop : int to parallelism : int in method protected StreamContextEnvironment(client Client, jars List<File>, parallelism int) in class org.apache.flink.streaming.api.environment.StreamContextEnvironment |
From |
To |
|
Rename Parameter degreeOfParallelism : int to parallelism : int in method public createLocalEnvironment(parallelism int) : LocalEnvironment in class org.apache.flink.api.java.ExecutionEnvironment |
From |
To |
|
Rename Parameter degreeOfParallelism : int to parallelism : int in method public runOnMiniCluster(jobGraph JobGraph, parallelism int, memorySize long) : void in class org.apache.flink.streaming.util.ClusterUtil |
From |
To |
|
Rename Parameter degreeOfParallelism : int to parallelism : int in method public SequentialFormatTestBase(numberOfTuples int, blockSize long, parallelism int) in class org.apache.flink.api.common.io.SequentialFormatTestBase |
From |
To |
|
Rename Parameter dop : int to parallelism : int in method private createSync(jobGraph JobGraph, numIterations int, parallelism int) : AbstractJobVertex in class org.apache.flink.test.broadcastvars.KMeansIterativeNepheleITCase |
From |
To |
|
Rename Parameter dop : int to parallelism : int in method public setParallelism(parallelism int) : DataSink<T> in class org.apache.flink.api.java.operators.DataSink |
From |
To |
|
Rename Parameter defaultDegreeOfParallelism : int to defaultParallelism : int in method public setDefaultParallelism(defaultParallelism int) : void in class org.apache.flink.optimizer.Optimizer |
From |
To |
|
Rename Parameter dop : int to parallelism : int in method public TestStreamEnvironment(executor ForkableFlinkMiniCluster, parallelism int) in class org.apache.flink.streaming.util.TestStreamEnvironment |
From |
To |
|
Rename Parameter degreeOfParallelism : int to parallelism : int in method public setParallelism(parallelism int) : void in class org.apache.flink.optimizer.dag.DataSourceNode |
From |
To |
|
Rename Parameter degreeOfParallelism : int to parallelism : int in method public createLocalEnvironment(parallelism int) : LocalStreamEnvironment in class org.apache.flink.streaming.api.environment.StreamExecutionEnvironment |
From |
To |
|
Rename Parameter degreeOfParallelism : int to parallelism : int in method public setDefaultLocalParallelism(parallelism int) : void in class org.apache.flink.streaming.api.environment.StreamExecutionEnvironment |
From |
To |
|
Rename Parameter degreeOfParallelism : int to parallelism : int in method public createRemoteEnvironment(host String, port int, parallelism int, jarFiles String...) : ExecutionEnvironment in class org.apache.flink.api.java.ExecutionEnvironment |
From |
To |
|
Rename Parameter degreeOfParallelism : int to parallelism : int in method public SerializedFormatTest(numberOfRecords int, blockSize long, parallelism int) in class org.apache.flink.api.common.io.SerializedFormatTest |
From |
To |
|
Rename Parameter dop : int to parallelism : int in method public setParallelism(parallelism int) : DataStreamSource<OUT> in class org.apache.flink.streaming.api.datastream.DataStreamSource |
From |
To |
|
Rename Parameter degreeOfParallelism : int to parallelism : int in method public createInput(stub T, path String, name String, graph JobGraph, parallelism int) : InputFormatVertex in class org.apache.flink.test.iterative.nephele.JobGraphUtils |
From |
To |
|
Rename Parameter degreeOfParallelism : int to parallelism : int in method public TestEnvironment(executor ForkableFlinkMiniCluster, parallelism int) in class org.apache.flink.test.util.TestEnvironment |
From |
To |
|
Rename Parameter dop : int to parallelism : int in method public setParallelism(parallelism int) : O in class org.apache.flink.api.java.operators.Operator |
From |
To |
|
Rename Parameter degreeOfParallelism : int to parallelism : int in method public setParallelism(parallelism int) : void in class org.apache.flink.streaming.util.StreamingProgramTestBase |
From |
To |
|
Rename Parameter degreeOfParallelism : int to parallelism : int in method public TypeSerializerFormatTest(numberOfTuples int, blockSize long, parallelism int) in class org.apache.flink.api.java.io.TypeSerializerFormatTest |
From |
To |
|
Rename Parameter degreeOfParallelism : int to parallelism : int in method public setParallelism(parallelism int) : void in class org.apache.flink.test.util.JavaProgramTestBase |
From |
To |