|
Change Variable Type sync : AbstractJobVertex to sync : JobVertex in method private createJobGraph(pointsPath String, centersPath String, resultPath String, numSubTasks int, numIterations int) : JobGraph in class org.apache.flink.test.broadcastvars.KMeansIterativeNepheleITCase |
From |
To |
|
Change Variable Type vertex : AbstractJobVertex to vertex : JobVertex in method public testCoordinatorShutsDownOnFailure() : void in class org.apache.flink.runtime.checkpoint.CoordinatorShutdownTest |
From |
To |
|
Change Variable Type v2 : AbstractJobVertex to v2 : JobVertex in method public testRegistrationOfExecutionsFailingFinalize() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphDeploymentTest |
From |
To |
|
Change Variable Type tail : AbstractJobVertex to tail : JobVertex in method private createReducer(jobGraph JobGraph, numSubTasks int, inputSerializer TypeSerializerFactory<?>, inputComparator TypeComparatorFactory<?>, outputSerializer TypeSerializerFactory<?>) : JobVertex in class org.apache.flink.test.broadcastvars.KMeansIterativeNepheleITCase |
From |
To |
|
Change Variable Type v5 : AbstractJobVertex to v5 : JobVertex in method public testAssignSlotSharingGroup() : void in class org.apache.flink.runtime.executiongraph.VertexSlotSharingTest |
From |
To |
|
Change Variable Type intermediate : AbstractJobVertex to intermediate : JobVertex in method public createJobGraphIntermediateWorksetUpdateAndSolutionSetTail(verticesPath String, edgesPath String, resultPath String, numSubTasks int, maxIterations int) : JobGraph in class org.apache.flink.test.iterative.nephele.ConnectedComponentsNepheleITCase |
From |
To |
|
Change Variable Type v3 : AbstractJobVertex to v3 : JobVertex in method public testMoreThanOneConsumerForIntermediateResult() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphConstructionTest |
From |
To |
|
Change Variable Type v1 : AbstractJobVertex to v1 : JobVertex in method public testTopoSortCyclicGraphIntermediateCycle() : void in class org.apache.flink.runtime.jobgraph.JobGraphTest |
From |
To |
|
Change Variable Type previous : AbstractJobVertex to previous : JobVertex in method public addVertex(vertex JobVertex) : void in class org.apache.flink.runtime.jobgraph.JobGraph |
From |
To |
|
Change Variable Type sync : AbstractJobVertex to sync : JobVertex in method private finalizeWorksetIteration(descr IterationDescriptor) : void in class org.apache.flink.optimizer.plantranslate.JobGraphGenerator |
From |
To |
|
Change Variable Type ordered : List<AbstractJobVertex> to ordered : List<JobVertex> in method public test3NToN() : void in class org.apache.flink.runtime.executiongraph.PointwisePatternTest |
From |
To |
|
Change Variable Type v3 : AbstractJobVertex to v3 : JobVertex in method public testAllVertices() : void in class org.apache.flink.runtime.executiongraph.AllVerticesIteratorTest |
From |
To |
|
Change Variable Type v5 : AbstractJobVertex to v5 : JobVertex in method public testAttachViaDataSets() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphConstructionTest |
From |
To |
|
Change Variable Type op2 : AbstractJobVertex to op2 : JobVertex in method public testTopologicalSort3() : void in class org.apache.flink.runtime.jobgraph.JobGraphTest |
From |
To |
|
Change Variable Type v1 : AbstractJobVertex to v1 : JobVertex in method public testAssignSlotSharingGroup() : void in class org.apache.flink.runtime.executiongraph.VertexSlotSharingTest |
From |
To |
|
Change Variable Type jobVertex : AbstractJobVertex to jobVertex : JobVertex in method public testFailureWhenJarBlobsMissing() : void in class org.apache.flink.runtime.jobmanager.JobSubmitTest |
From |
To |
|
Change Variable Type v1 : AbstractJobVertex to v1 : JobVertex in method private testLowToHigh(lowDop int, highDop int) : void in class org.apache.flink.runtime.executiongraph.PointwisePatternTest |
From |
To |
|
Change Variable Type v4 : AbstractJobVertex to v4 : JobVertex in method public testTopoSortCyclicGraphIntermediateCycle() : void in class org.apache.flink.runtime.jobgraph.JobGraphTest |
From |
To |
|
Change Variable Type v8 : AbstractJobVertex to v8 : JobVertex in method public testCoLocationConstraintCreation() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphConstructionTest |
From |
To |
|
Change Variable Type target1 : AbstractJobVertex to target1 : JobVertex in method public testConnectMultipleTargets() : void in class org.apache.flink.runtime.jobgraph.JobTaskVertexTest |
From |
To |
|
Change Variable Type v2 : AbstractJobVertex to v2 : JobVertex in method public testCannotConnectWrongOrder() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphConstructionTest |
From |
To |
|
Change Variable Type v3 : AbstractJobVertex to v3 : JobVertex in method public testAttachViaIds() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphConstructionTest |
From |
To |
|
Change Variable Type l2 : AbstractJobVertex to l2 : JobVertex in method public testTopologicalSort2() : void in class org.apache.flink.runtime.jobgraph.JobGraphTest |
From |
To |
|
Change Variable Type ordered : List<AbstractJobVertex> to ordered : List<JobVertex> in method public testAttachViaDataSets() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphConstructionTest |
From |
To |
|
Change Variable Type v1 : AbstractJobVertex to v1 : JobVertex in method public testRegistrationOfExecutionsFailing() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphDeploymentTest |
From |
To |
|
Change Variable Type ordered : List<AbstractJobVertex> to ordered : List<JobVertex> in method public testMoreThanOneConsumerForIntermediateResult() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphConstructionTest |
From |
To |
|
Change Variable Type remaining : Set<AbstractJobVertex> to remaining : Set<JobVertex> in method public getVerticesSortedTopologicallyFromSources() : List<JobVertex> in class org.apache.flink.runtime.jobgraph.JobGraph |
From |
To |
|
Change Variable Type l12 : AbstractJobVertex to l12 : JobVertex in method public testTopologicalSort2() : void in class org.apache.flink.runtime.jobgraph.JobGraphTest |
From |
To |
|
Change Variable Type ajv : AbstractJobVertex to ajv : JobVertex in method public testAccumulatedStateFinished() : void in class org.apache.flink.runtime.executiongraph.ExecutionStateProgressTest |
From |
To |
|
Change Variable Type tail : AbstractJobVertex to tail : JobVertex in method private getTestJobGraph(inputPath String, outputPath String, numSubTasks int, maxIterations int) : JobGraph in class org.apache.flink.test.iterative.nephele.IterationWithChainingNepheleITCase |
From |
To |
|
Change Variable Type intermediate : AbstractJobVertex to intermediate : JobVertex in method public getJobGraph(args String[]) : JobGraph in class org.apache.flink.test.iterative.nephele.customdanglingpagerank.CustomCompensatableDanglingPageRankWithCombiner |
From |
To |
|
Change Variable Type v1 : AbstractJobVertex to v1 : JobVertex in method public testAllVertices() : void in class org.apache.flink.runtime.executiongraph.AllVerticesIteratorTest |
From |
To |
|
Change Variable Type v2 : AbstractJobVertex to v2 : JobVertex in method public testMoreThanOneConsumerForIntermediateResult() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphConstructionTest |
From |
To |
|
Change Variable Type itSource : AbstractJobVertex to itSource : JobVertex in method public testColocation() : void in class org.apache.flink.streaming.api.IterateTest |
From |
To |
|
Change Variable Type v3 : AbstractJobVertex to v3 : JobVertex in method public testSetupInputSplits() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphConstructionTest |
From |
To |
|
Change Variable Type source1 : AbstractJobVertex to source1 : JobVertex in method public testTopologicalSort2() : void in class org.apache.flink.runtime.jobgraph.JobGraphTest |
From |
To |
|
Change Variable Type sync : AbstractJobVertex to sync : JobVertex in method public createJobGraphSeparateTails(verticesPath String, edgesPath String, resultPath String, numSubTasks int, maxIterations int) : JobGraph in class org.apache.flink.test.iterative.nephele.ConnectedComponentsNepheleITCase |
From |
To |
|
Change Variable Type v1 : AbstractJobVertex to v1 : JobVertex in method public test2NToN() : void in class org.apache.flink.runtime.executiongraph.PointwisePatternTest |
From |
To |
|
Change Variable Type rootOfStepFunctionVertex : AbstractJobVertex to rootOfStepFunctionVertex : JobVertex in method private finalizeBulkIteration(descr IterationDescriptor) : void in class org.apache.flink.optimizer.plantranslate.JobGraphGenerator |
From |
To |
|
Change Variable Type target2 : AbstractJobVertex to target2 : JobVertex in method public testTopologicalSort1() : void in class org.apache.flink.runtime.jobgraph.JobGraphTest |
From |
To |
|
Change Variable Type v1 : AbstractJobVertex to v1 : JobVertex in method public testRegistrationOfExecutionsFailingFinalize() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphDeploymentTest |
From |
To |
|
Change Variable Type sorted : List<AbstractJobVertex> to sorted : List<JobVertex> in method public testTopologicalSort1() : void in class org.apache.flink.runtime.jobgraph.JobGraphTest |
From |
To |
|
Change Variable Type sorted : List<AbstractJobVertex> to sorted : List<JobVertex> in method public testTopologicalSort3() : void in class org.apache.flink.runtime.jobgraph.JobGraphTest |
From |
To |
|
Change Variable Type targetVertex : AbstractJobVertex to targetVertex : JobVertex in method public postVisit(node PlanNode) : void in class org.apache.flink.optimizer.plantranslate.JobGraphGenerator |
From |
To |
|
Change Variable Type toReturn : AbstractJobVertex to toReturn : JobVertex in method private createBulkIterationHead(pspn BulkPartialSolutionPlanNode) : JobVertex in class org.apache.flink.optimizer.plantranslate.JobGraphGenerator |
From |
To |
|
Change Variable Type v : AbstractJobVertex to v : JobVertex in method public testTempInIterationTest() : void in class org.apache.flink.optimizer.plantranslate.TempInIterationsTest |
From |
To |
|
Change Variable Type head : AbstractJobVertex to head : JobVertex in method private createIterationHead(jobGraph JobGraph, numSubTasks int, serializer TypeSerializerFactory<?>) : JobVertex in class org.apache.flink.test.broadcastvars.KMeansIterativeNepheleITCase |
From |
To |
|
Change Variable Type tail : AbstractJobVertex to tail : JobVertex in method private setSlotSharing() : void in class org.apache.flink.streaming.api.graph.StreamingJobGraphGenerator |
From |
To |
|
Change Variable Type v1 : AbstractJobVertex to v1 : JobVertex in method public testProvokeDeadlock() : void in class org.apache.flink.runtime.executiongraph.TerminalStateDeadlockTest |
From |
To |
|
Change Variable Type vertex : AbstractJobVertex to vertex : JobVertex in method public testImmediateReleaseTwoLevel() : void in class org.apache.flink.runtime.instance.SharedSlotsTest |
From |
To |
|
Change Variable Type ordered : List<AbstractJobVertex> to ordered : List<JobVertex> in method public testCannotConnectMissingId() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphConstructionTest |
From |
To |
|
Change Variable Type jobVertex1 : AbstractJobVertex to jobVertex1 : JobVertex in method public testScheduleWithConstraintAndSlotSharing() : void in class org.apache.flink.runtime.executiongraph.VertexLocationConstraintTest |
From |
To |
|
Change Variable Type v1 : AbstractJobVertex to v1 : JobVertex in method public testMoreThanOneConsumerForIntermediateResult() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphConstructionTest |
From |
To |
|
Change Variable Type v3 : AbstractJobVertex to v3 : JobVertex in method public testAttachViaDataSets() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphConstructionTest |
From |
To |
|
Change Variable Type sync : AbstractJobVertex to sync : JobVertex in method private finalizeBulkIteration(descr IterationDescriptor) : void in class org.apache.flink.optimizer.plantranslate.JobGraphGenerator |
From |
To |
|
Change Variable Type vertex : AbstractJobVertex to vertex : JobVertex in method public testColocation() : void in class org.apache.flink.streaming.api.IterateTest |
From |
To |
|
Change Variable Type vertex : AbstractJobVertex to vertex : JobVertex in method public testCoordinatorShutsDownOnSuccess() : void in class org.apache.flink.runtime.checkpoint.CoordinatorShutdownTest |
From |
To |
|
Change Variable Type op1 : AbstractJobVertex to op1 : JobVertex in method public testTopologicalSort3() : void in class org.apache.flink.runtime.jobgraph.JobGraphTest |
From |
To |
|
Change Variable Type ordered2 : List<AbstractJobVertex> to ordered2 : List<JobVertex> in method public testAttachViaIds() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphConstructionTest |
From |
To |
|
Change Variable Type intermediate : AbstractJobVertex to intermediate : JobVertex in method private createIterationIntermediate(jobGraph JobGraph, numSubTasks int, serializer TypeSerializerFactory<?>, comparator TypeComparatorFactory<?>) : JobVertex in class org.apache.flink.test.iterative.nephele.ConnectedComponentsNepheleITCase |
From |
To |
|
Change Variable Type v1 : AbstractJobVertex to v1 : JobVertex in method public test3NToN() : void in class org.apache.flink.runtime.executiongraph.PointwisePatternTest |
From |
To |
|
Change Variable Type v1 : AbstractJobVertex to v1 : JobVertex in method public testCannotConnectWrongOrder() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphConstructionTest |
From |
To |
|
Change Variable Type ordered : List<AbstractJobVertex> to ordered : List<JobVertex> in method public testNToN() : void in class org.apache.flink.runtime.executiongraph.PointwisePatternTest |
From |
To |
|
Change Variable Type vertex : AbstractJobVertex to vertex : JobVertex in method private testFailureBehavior(unreachableEndpoint InetSocketAddress) : void in class org.apache.flink.client.program.ClientConnectionTest |
From |
To |
|
Change Variable Type source : AbstractJobVertex to source : JobVertex in method public testConnectMultipleTargets() : void in class org.apache.flink.runtime.jobgraph.JobTaskVertexTest |
From |
To |
|
Change Variable Type jobVertex2 : AbstractJobVertex to jobVertex2 : JobVertex in method public testScheduleWithConstraintAndSlotSharing() : void in class org.apache.flink.runtime.executiongraph.VertexLocationConstraintTest |
From |
To |
|
Change Variable Type head : AbstractJobVertex to head : JobVertex in method public createJobGraphIntermediateWorksetUpdateAndSolutionSetTail(verticesPath String, edgesPath String, resultPath String, numSubTasks int, maxIterations int) : JobGraph in class org.apache.flink.test.iterative.nephele.ConnectedComponentsNepheleITCase |
From |
To |
|
Change Variable Type v4 : AbstractJobVertex to v4 : JobVertex in method public testAssignSlotSharingGroup() : void in class org.apache.flink.runtime.executiongraph.VertexSlotSharingTest |
From |
To |
|
Change Variable Type sync : AbstractJobVertex to sync : JobVertex in method public createSync(jobGraph JobGraph, parallelism int) : JobVertex in class org.apache.flink.test.iterative.nephele.JobGraphUtils |
From |
To |
|
Change Variable Type l11 : AbstractJobVertex to l11 : JobVertex in method public testTopologicalSort2() : void in class org.apache.flink.runtime.jobgraph.JobGraphTest |
From |
To |
|
Change Variable Type v1 : AbstractJobVertex to v1 : JobVertex in method public testNToN() : void in class org.apache.flink.runtime.executiongraph.PointwisePatternTest |
From |
To |
|
Change Variable Type head : AbstractJobVertex to head : JobVertex in method private createIterationHead(jobGraph JobGraph, numSubTasks int, serializer TypeSerializerFactory<?>, comparator TypeComparatorFactory<?>, pairComparator TypePairComparatorFactory<?,?>) : JobVertex in class org.apache.flink.test.iterative.nephele.ConnectedComponentsNepheleITCase |
From |
To |
|
Change Variable Type intermediate : AbstractJobVertex to intermediate : JobVertex in method public createJobGraphSolutionSetUpdateAndWorksetTail(verticesPath String, edgesPath String, resultPath String, numSubTasks int, maxIterations int) : JobGraph in class org.apache.flink.test.iterative.nephele.ConnectedComponentsNepheleITCase |
From |
To |
|
Change Variable Type tail : AbstractJobVertex to tail : JobVertex in method public getJobGraph(args String[]) : JobGraph in class org.apache.flink.test.iterative.nephele.customdanglingpagerank.CustomCompensatableDanglingPageRank |
From |
To |
|
Change Variable Type vertex : AbstractJobVertex to vertex : JobVertex in method public getVerticesSortedTopologicallyFromSources() : List<JobVertex> in class org.apache.flink.runtime.jobgraph.JobGraph |
From |
To |
|
Change Variable Type v2 : AbstractJobVertex to v2 : JobVertex in method public testNTo7N() : void in class org.apache.flink.runtime.executiongraph.PointwisePatternTest |
From |
To |
|
Change Variable Type sync : AbstractJobVertex to sync : JobVertex in method private createSync(jobGraph JobGraph, numSubTasks int, maxIterations int) : JobVertex in class org.apache.flink.test.iterative.nephele.ConnectedComponentsNepheleITCase |
From |
To |
|
Change Variable Type jobVertex : AbstractJobVertex to jobVertex : JobVertex in method public attachJobGraph(topologiallySorted List<JobVertex>) : void in class org.apache.flink.runtime.executiongraph.ExecutionGraph |
From |
To |
|
Change Variable Type forwarder : AbstractJobVertex to forwarder : JobVertex in method private createJobGraph(dataVolumeGb int, useForwarder boolean, isSlowSender boolean, isSlowReceiver boolean, numSubtasks int) : JobGraph in class org.apache.flink.test.runtime.NetworkStackThroughputITCase.TestBaseWrapper |
From |
To |
|
Change Variable Type head : AbstractJobVertex to head : JobVertex in method private createJobGraph(pointsPath String, centersPath String, resultPath String, numSubTasks int, numIterations int) : JobGraph in class org.apache.flink.test.broadcastvars.KMeansIterativeNepheleITCase |
From |
To |
|
Change Variable Type target2 : AbstractJobVertex to target2 : JobVertex in method public testConnectMultipleTargets() : void in class org.apache.flink.runtime.jobgraph.JobTaskVertexTest |
From |
To |
|
Change Variable Type sender : AbstractJobVertex to sender : JobVertex in method private createTestJobGraph(jobName String, senderParallelism int, receiverParallelism int) : JobGraph in class org.apache.flink.runtime.jobmanager.SlotCountExceedingParallelismTest |
From |
To |
|
Change Variable Type sync : AbstractJobVertex to sync : JobVertex in method public getJobGraph(args String[]) : JobGraph in class org.apache.flink.test.iterative.nephele.customdanglingpagerank.CustomCompensatableDanglingPageRankWithCombiner |
From |
To |
|
Change Variable Type target1 : AbstractJobVertex to target1 : JobVertex in method public testTopologicalSort1() : void in class org.apache.flink.runtime.jobgraph.JobGraphTest |
From |
To |
|
Change Variable Type ordered : List<AbstractJobVertex> to ordered : List<JobVertex> in method public testCreateSimpleGraphBipartite() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphConstructionTest |
From |
To |
|
Change Variable Type target : AbstractJobVertex to target : JobVertex in method public testConnectDirectly() : void in class org.apache.flink.runtime.jobgraph.JobTaskVertexTest |
From |
To |
|
Change Variable Type jobVertex : AbstractJobVertex to jobVertex : JobVertex in method public testScheduleWithConstraint1() : void in class org.apache.flink.runtime.executiongraph.VertexLocationConstraintTest |
From |
To |
|
Change Variable Type root : AbstractJobVertex to root : JobVertex in method public testTopologicalSort2() : void in class org.apache.flink.runtime.jobgraph.JobGraphTest |
From |
To |
|
Change Variable Type v1 : AbstractJobVertex to v1 : JobVertex in method public testAttachViaDataSets() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphConstructionTest |
From |
To |
|
Change Variable Type sender : AbstractJobVertex to sender : JobVertex in method public testPartialConsumePipelinedResultReceiver() : void in class org.apache.flink.runtime.io.network.partition.PartialConsumePipelinedResultTest |
From |
To |
|
Change Variable Type mapper : AbstractJobVertex to mapper : JobVertex in method private createJobGraphV1(pointsPath String, centersPath String, resultPath String, numSubTasks int) : JobGraph in class org.apache.flink.test.broadcastvars.BroadcastVarsNepheleITCase |
From |
To |
|
Change Variable Type rootOfTerminationCriterionVertex : AbstractJobVertex to rootOfTerminationCriterionVertex : JobVertex in method private finalizeBulkIteration(descr IterationDescriptor) : void in class org.apache.flink.optimizer.plantranslate.JobGraphGenerator |
From |
To |
|
Change Variable Type sync : AbstractJobVertex to sync : JobVertex in method public createJobGraphSolutionSetUpdateAndWorksetTail(verticesPath String, edgesPath String, resultPath String, numSubTasks int, maxIterations int) : JobGraph in class org.apache.flink.test.iterative.nephele.ConnectedComponentsNepheleITCase |
From |
To |
|
Change Variable Type vertex : AbstractJobVertex to vertex : JobVertex in method public JobGraph(jobId JobID, jobName String, vertices JobVertex...) in class org.apache.flink.runtime.jobgraph.JobGraph |
From |
To |
|
Change Variable Type accessingVertex : AbstractJobVertex to accessingVertex : JobVertex in method public preVisit(node PlanNode) : boolean in class org.apache.flink.optimizer.plantranslate.JobGraphGenerator |
From |
To |
|
Change Variable Type sync : AbstractJobVertex to sync : JobVertex in method public createJobGraphUnifiedTails(verticesPath String, edgesPath String, resultPath String, numSubTasks int, maxIterations int) : JobGraph in class org.apache.flink.test.iterative.nephele.ConnectedComponentsNepheleITCase |
From |
To |
|
Change Variable Type v2 : AbstractJobVertex to v2 : JobVertex in method public testTopoSortCyclicGraphIntermediateCycle() : void in class org.apache.flink.runtime.jobgraph.JobGraphTest |
From |
To |
|
Change Variable Type v4 : AbstractJobVertex to v4 : JobVertex in method public testBuildDeploymentDescriptor() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphDeploymentTest |
From |
To |
|
Change Variable Type tailOp : AbstractJobVertex to tailOp : JobVertex in method public testColocation() : void in class org.apache.flink.streaming.api.IterateTest |
From |
To |
|
Change Variable Type toReturn : AbstractJobVertex to toReturn : JobVertex in method private createWorksetIterationHead(wspn WorksetPlanNode) : JobVertex in class org.apache.flink.optimizer.plantranslate.JobGraphGenerator |
From |
To |
|
Change Variable Type v1 : AbstractJobVertex to v1 : JobVertex in method public testCreateSimpleGraphBipartite() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphConstructionTest |
From |
To |
|
Change Variable Type v1 : AbstractJobVertex to v1 : JobVertex in method public testAttachViaIds() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphConstructionTest |
From |
To |
|
Change Variable Type vertices : List<AbstractJobVertex> to vertices : List<JobVertex> in method public test() : void in class org.apache.flink.streaming.api.graph.SlotAllocationTest |
From |
To |
|
Change Variable Type v1 : AbstractJobVertex to v1 : JobVertex in method public testRegistrationOfExecutionsFailedExternally() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphDeploymentTest |
From |
To |
|
Change Variable Type v2 : AbstractJobVertex to v2 : JobVertex in method public testCreateSimpleGraphBipartite() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphConstructionTest |
From |
To |
|
Change Variable Type v3 : AbstractJobVertex to v3 : JobVertex in method public testTopoSortCyclicGraphNoSources() : void in class org.apache.flink.runtime.jobgraph.JobGraphTest |
From |
To |
|
Change Variable Type v3 : AbstractJobVertex to v3 : JobVertex in method public testCreateSimpleGraphBipartite() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphConstructionTest |
From |
To |
|
Change Variable Type v1 : AbstractJobVertex to v1 : JobVertex in method public testCoLocationConstraintCreation() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphConstructionTest |
From |
To |
|
Change Variable Type head : AbstractJobVertex to head : JobVertex in method public createJobGraphSeparateTails(verticesPath String, edgesPath String, resultPath String, numSubTasks int, maxIterations int) : JobGraph in class org.apache.flink.test.iterative.nephele.ConnectedComponentsNepheleITCase |
From |
To |
|
Change Variable Type ssJoinIntermediate : AbstractJobVertex to ssJoinIntermediate : JobVertex in method public createJobGraphSolutionSetUpdateAndWorksetTail(verticesPath String, edgesPath String, resultPath String, numSubTasks int, maxIterations int) : JobGraph in class org.apache.flink.test.iterative.nephele.ConnectedComponentsNepheleITCase |
From |
To |
|
Change Variable Type v4 : AbstractJobVertex to v4 : JobVertex in method public testCreateSimpleGraphBipartite() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphConstructionTest |
From |
To |
|
Change Variable Type jobVertex2 : AbstractJobVertex to jobVertex2 : JobVertex in method public testScheduleWithUnfulfillableConstraintInSharingGroup() : void in class org.apache.flink.runtime.executiongraph.VertexLocationConstraintTest |
From |
To |
|
Change Variable Type v5 : AbstractJobVertex to v5 : JobVertex in method public testCreateSimpleGraphBipartite() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphConstructionTest |
From |
To |
|
Change Variable Type head : AbstractJobVertex to head : JobVertex in method private setSlotSharing() : void in class org.apache.flink.streaming.api.graph.StreamingJobGraphGenerator |
From |
To |
|
Change Variable Type ssJoinIntermediate : AbstractJobVertex to ssJoinIntermediate : JobVertex in method public createJobGraphSeparateTails(verticesPath String, edgesPath String, resultPath String, numSubTasks int, maxIterations int) : JobGraph in class org.apache.flink.test.iterative.nephele.ConnectedComponentsNepheleITCase |
From |
To |
|
Change Variable Type vertex : AbstractJobVertex to vertex : JobVertex in method public compileJobGraph(program OptimizedPlan) : JobGraph in class org.apache.flink.optimizer.plantranslate.JobGraphGenerator |
From |
To |
|
Change Variable Type source2 : AbstractJobVertex to source2 : JobVertex in method public testTopologicalSort1() : void in class org.apache.flink.runtime.jobgraph.JobGraphTest |
From |
To |
|
Change Variable Type v4 : AbstractJobVertex to v4 : JobVertex in method public testSetupInputSplits() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphConstructionTest |
From |
To |
|
Change Variable Type v1 : AbstractJobVertex to v1 : JobVertex in method public testRegistrationOfExecutionsCanceled() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphDeploymentTest |
From |
To |
|
Change Variable Type original : AbstractJobVertex to original : JobVertex in method public testSerialization() : void in class org.apache.flink.runtime.jobgraph.JobGraphTest |
From |
To |
|
Change Variable Type head : AbstractJobVertex to head : JobVertex in method public getJobGraph(args String[]) : JobGraph in class org.apache.flink.test.iterative.nephele.danglingpagerank.CompensatableDanglingPageRank |
From |
To |
|
Change Variable Type v : AbstractJobVertex to v : JobVertex in method private assertBefore(v1 JobVertex, v2 JobVertex, list List<JobVertex>) : void in class org.apache.flink.runtime.jobgraph.JobGraphTest |
From |
To |
|
Change Variable Type v2 : AbstractJobVertex to v2 : JobVertex in method public testNTo2N() : void in class org.apache.flink.runtime.executiongraph.PointwisePatternTest |
From |
To |
|
Change Variable Type vertex : AbstractJobVertex to vertex : JobVertex in method public testMultipleInstancesPerHost() : void in class org.apache.flink.runtime.executiongraph.LocalInputSplitsTest |
From |
To |
|
Change Variable Type v2 : AbstractJobVertex to v2 : JobVertex in method public testCannotConnectMissingId() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphConstructionTest |
From |
To |
|
Change Variable Type v4 : AbstractJobVertex to v4 : JobVertex in method public testAttachViaIds() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphConstructionTest |
From |
To |
|
Change Variable Type ssTail : AbstractJobVertex to ssTail : JobVertex in method public createJobGraphSeparateTails(verticesPath String, edgesPath String, resultPath String, numSubTasks int, maxIterations int) : JobGraph in class org.apache.flink.test.iterative.nephele.ConnectedComponentsNepheleITCase |
From |
To |
|
Change Variable Type v2 : AbstractJobVertex to v2 : JobVertex in method public testProvokeDeadlock() : void in class org.apache.flink.runtime.executiongraph.TerminalStateDeadlockTest |
From |
To |
|
Change Variable Type v1 : AbstractJobVertex to v1 : JobVertex in method public testTopoSortCyclicGraphNoSources() : void in class org.apache.flink.runtime.jobgraph.JobGraphTest |
From |
To |
|
Change Variable Type source : AbstractJobVertex to source : JobVertex in method public testTopoSortCyclicGraphIntermediateCycle() : void in class org.apache.flink.runtime.jobgraph.JobGraphTest |
From |
To |
|
Change Variable Type sync : AbstractJobVertex to sync : JobVertex in method private createSync(jobGraph JobGraph, numIterations int, parallelism int) : JobVertex in class org.apache.flink.test.broadcastvars.KMeansIterativeNepheleITCase |
From |
To |
|
Change Variable Type entry : Entry<Integer,AbstractJobVertex> to entry : Entry<Integer,JobVertex> in method private setSlotSharing() : void in class org.apache.flink.streaming.api.graph.StreamingJobGraphGenerator |
From |
To |
|
Change Variable Type head : AbstractJobVertex to head : JobVertex in method public getJobGraph(args String[]) : JobGraph in class org.apache.flink.test.iterative.nephele.customdanglingpagerank.CustomCompensatableDanglingPageRankWithCombiner |
From |
To |
|
Change Variable Type ordered2 : List<AbstractJobVertex> to ordered2 : List<JobVertex> in method public testAttachViaDataSets() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphConstructionTest |
From |
To |
|
Change Variable Type v2 : AbstractJobVertex to v2 : JobVertex in method public testCoLocationConstraintCreation() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphConstructionTest |
From |
To |
|
Change Variable Type jobVertex1 : AbstractJobVertex to jobVertex1 : JobVertex in method public testScheduleWithUnfulfillableConstraintInSharingGroup() : void in class org.apache.flink.runtime.executiongraph.VertexLocationConstraintTest |
From |
To |
|
Change Variable Type ordered : List<AbstractJobVertex> to ordered : List<JobVertex> in method private setupExecution(v1 JobVertex, dop1 int, v2 JobVertex, dop2 int) : Map<ExecutionAttemptID,Execution> in class org.apache.flink.runtime.executiongraph.ExecutionGraphDeploymentTest |
From |
To |
|
Change Variable Type head : AbstractJobVertex to head : JobVertex in method public getJobGraph(args String[]) : JobGraph in class org.apache.flink.test.iterative.nephele.customdanglingpagerank.CustomCompensatableDanglingPageRank |
From |
To |
|
Change Variable Type vertices : List<AbstractJobVertex> to vertices : List<JobVertex> in method public testAssignSlotSharingGroup() : void in class org.apache.flink.runtime.executiongraph.VertexSlotSharingTest |
From |
To |
|
Change Variable Type mapper : AbstractJobVertex to mapper : JobVertex in method private createJobGraph(pointsPath String, centersPath String, resultPath String, numSubTasks int, numIterations int) : JobGraph in class org.apache.flink.test.broadcastvars.KMeansIterativeNepheleITCase |
From |
To |
|
Change Variable Type headVertex : AbstractJobVertex to headVertex : JobVertex in method private createBulkIterationHead(pspn BulkPartialSolutionPlanNode) : JobVertex in class org.apache.flink.optimizer.plantranslate.JobGraphGenerator |
From |
To |
|
Change Variable Type iter : Iterator<AbstractJobVertex> to iter : Iterator<JobVertex> in method public getVerticesSortedTopologicallyFromSources() : List<JobVertex> in class org.apache.flink.runtime.jobgraph.JobGraph |
From |
To |
|
Change Variable Type union : AbstractJobVertex to union : JobVertex in method public testCancelUnion() : void in class org.apache.flink.runtime.taskmanager.TaskCancelTest |
From |
To |
|
Change Variable Type v4 : AbstractJobVertex to v4 : JobVertex in method public testAllVertices() : void in class org.apache.flink.runtime.executiongraph.AllVerticesIteratorTest |
From |
To |
|
Change Variable Type headVertex : AbstractJobVertex to headVertex : JobVertex in method private finalizeBulkIteration(descr IterationDescriptor) : void in class org.apache.flink.optimizer.plantranslate.JobGraphGenerator |
From |
To |
|
Change Variable Type ordered : List<AbstractJobVertex> to ordered : List<JobVertex> in method private testHighToLow(highDop int, lowDop int) : void in class org.apache.flink.runtime.executiongraph.PointwisePatternTest |
From |
To |
|
Change Variable Type jobVertex : AbstractJobVertex to jobVertex : JobVertex in method public setup() : void in class org.apache.flink.test.failingPrograms.JobSubmissionFailsITCase |
From |
To |
|
Change Variable Type v3 : AbstractJobVertex to v3 : JobVertex in method public testAssignSlotSharingGroup() : void in class org.apache.flink.runtime.executiongraph.VertexSlotSharingTest |
From |
To |
|
Change Variable Type v3 : AbstractJobVertex to v3 : JobVertex in method public testBuildDeploymentDescriptor() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphDeploymentTest |
From |
To |
|
Change Variable Type head : AbstractJobVertex to head : JobVertex in method public postVisit(node PlanNode) : void in class org.apache.flink.optimizer.plantranslate.JobGraphGenerator |
From |
To |
|
Change Variable Type vertex1 : AbstractJobVertex to vertex1 : JobVertex in method public testCreateConstraints() : void in class org.apache.flink.runtime.jobmanager.scheduler.CoLocationConstraintTest |
From |
To |
|
Change Variable Type v1 : AbstractJobVertex to v1 : JobVertex in method public testSetupInputSplits() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphConstructionTest |
From |
To |
|
Change Variable Type ordered : List<AbstractJobVertex> to ordered : List<JobVertex> in method public testBuildDeploymentDescriptor() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphDeploymentTest |
From |
To |
|
Change Variable Type intermediate2 : AbstractJobVertex to intermediate2 : JobVertex in method public testTopologicalSort1() : void in class org.apache.flink.runtime.jobgraph.JobGraphTest |
From |
To |
|
Change Variable Type v5 : AbstractJobVertex to v5 : JobVertex in method public testCannotConnectWrongOrder() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphConstructionTest |
From |
To |
|
Change Variable Type wsTail : AbstractJobVertex to wsTail : JobVertex in method public createJobGraphSeparateTails(verticesPath String, edgesPath String, resultPath String, numSubTasks int, maxIterations int) : JobGraph in class org.apache.flink.test.iterative.nephele.ConnectedComponentsNepheleITCase |
From |
To |
|
Change Variable Type vertex : AbstractJobVertex to vertex : JobVertex in method private configureCheckpointing() : void in class org.apache.flink.streaming.api.graph.StreamingJobGraphGenerator |
From |
To |
|
Change Variable Type v2 : AbstractJobVertex to v2 : JobVertex in method public testAllVertices() : void in class org.apache.flink.runtime.executiongraph.AllVerticesIteratorTest |
From |
To |
|
Change Variable Type reducer : AbstractJobVertex to reducer : JobVertex in method private createJobGraph(pointsPath String, centersPath String, resultPath String, numSubTasks int, numIterations int) : JobGraph in class org.apache.flink.test.broadcastvars.KMeansIterativeNepheleITCase |
From |
To |
|
Change Variable Type v2 : AbstractJobVertex to v2 : JobVertex in method public testRegistrationOfExecutionsFailing() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphDeploymentTest |
From |
To |
|
Change Variable Type ordered : List<AbstractJobVertex> to ordered : List<JobVertex> in method public testNTo7N() : void in class org.apache.flink.runtime.executiongraph.PointwisePatternTest |
From |
To |
|
Change Variable Type v3 : AbstractJobVertex to v3 : JobVertex in method public testCoLocationConstraintCreation() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphConstructionTest |
From |
To |
|
Change Variable Type ajv : AbstractJobVertex to ajv : JobVertex in method public getExecutionVertex(id JobVertexID) : ExecutionJobVertex in class org.apache.flink.runtime.executiongraph.ExecutionGraphTestUtils |
From |
To |
|
Change Variable Type vertex : AbstractJobVertex to vertex : JobVertex in method public testSerialization() : void in class org.apache.flink.runtime.jobgraph.JobGraphTest |
From |
To |
|
Change Variable Type intermediate : AbstractJobVertex to intermediate : JobVertex in method public getJobGraph(args String[]) : JobGraph in class org.apache.flink.test.iterative.nephele.customdanglingpagerank.CustomCompensatableDanglingPageRank |
From |
To |
|
Change Variable Type headVertex : AbstractJobVertex to headVertex : JobVertex in method private connect(headOfChain Integer, edge StreamEdge) : void in class org.apache.flink.streaming.api.graph.StreamingJobGraphGenerator |
From |
To |
|
Change Variable Type output : AbstractJobVertex to output : JobVertex in method public createJobGraphSolutionSetUpdateAndWorksetTail(verticesPath String, edgesPath String, resultPath String, numSubTasks int, maxIterations int) : JobGraph in class org.apache.flink.test.iterative.nephele.ConnectedComponentsNepheleITCase |
From |
To |
|
Change Variable Type consumer : AbstractJobVertex to consumer : JobVertex in method private createJobGraph(dataVolumeGb int, useForwarder boolean, isSlowSender boolean, isSlowReceiver boolean, numSubtasks int) : JobGraph in class org.apache.flink.test.runtime.NetworkStackThroughputITCase.TestBaseWrapper |
From |
To |
|
Change Variable Type producer : AbstractJobVertex to producer : JobVertex in method private createJobGraph(dataVolumeGb int, useForwarder boolean, isSlowSender boolean, isSlowReceiver boolean, numSubtasks int) : JobGraph in class org.apache.flink.test.runtime.NetworkStackThroughputITCase.TestBaseWrapper |
From |
To |
|
Change Variable Type pipelinedReceiver : AbstractJobVertex to pipelinedReceiver : JobVertex in method public testMixedPipelinedAndBlockingResults() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleOrUpdateConsumersTest |
From |
To |
|
Change Variable Type source1 : AbstractJobVertex to source1 : JobVertex in method public testTopologicalSort1() : void in class org.apache.flink.runtime.jobgraph.JobGraphTest |
From |
To |
|
Change Variable Type tailVertex : AbstractJobVertex to tailVertex : JobVertex in method public testAllocateAndReleaseTwoLevels() : void in class org.apache.flink.runtime.instance.SharedSlotsTest |
From |
To |
|
Change Variable Type headVertex : AbstractJobVertex to headVertex : JobVertex in method private finalizeWorksetIteration(descr IterationDescriptor) : void in class org.apache.flink.optimizer.plantranslate.JobGraphGenerator |
From |
To |
|
Change Variable Type head : AbstractJobVertex to head : JobVertex in method public createJobGraphUnifiedTails(verticesPath String, edgesPath String, resultPath String, numSubTasks int, maxIterations int) : JobGraph in class org.apache.flink.test.iterative.nephele.ConnectedComponentsNepheleITCase |
From |
To |
|
Change Variable Type source : AbstractJobVertex to source : JobVertex in method public testConnectDirectly() : void in class org.apache.flink.runtime.jobgraph.JobTaskVertexTest |
From |
To |
|
Change Variable Type v4 : AbstractJobVertex to v4 : JobVertex in method public testAttachViaDataSets() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphConstructionTest |
From |
To |
|
Change Variable Type source2 : AbstractJobVertex to source2 : JobVertex in method public testSerialization() : void in class org.apache.flink.runtime.jobgraph.JobGraphTest |
From |
To |
|
Change Variable Type sorted : List<AbstractJobVertex> to sorted : List<JobVertex> in method public testTopologicalSort2() : void in class org.apache.flink.runtime.jobgraph.JobGraphTest |
From |
To |
|
Change Variable Type v2 : AbstractJobVertex to v2 : JobVertex in method public test2NToN() : void in class org.apache.flink.runtime.executiongraph.PointwisePatternTest |
From |
To |
|
Change Variable Type vertex : AbstractJobVertex to vertex : JobVertex in method public preVisit(node PlanNode) : boolean in class org.apache.flink.optimizer.plantranslate.JobGraphGenerator |
From |
To |
|
Change Variable Type target : AbstractJobVertex to target : JobVertex in method public testTopoSortCyclicGraphIntermediateCycle() : void in class org.apache.flink.runtime.jobgraph.JobGraphTest |
From |
To |
|
Change Variable Type jobVertex : AbstractJobVertex to jobVertex : JobVertex in method public testFailureWhenInitializeOnMasterFails() : void in class org.apache.flink.runtime.jobmanager.JobSubmitTest |
From |
To |
|
Change Variable Type jobVertex : AbstractJobVertex to jobVertex : JobVertex in method private createProcessingVertex(vertexID Integer) : StreamConfig in class org.apache.flink.streaming.api.graph.StreamingJobGraphGenerator |
From |
To |
|
Change Variable Type nextWorksetVertex : AbstractJobVertex to nextWorksetVertex : JobVertex in method private finalizeWorksetIteration(descr IterationDescriptor) : void in class org.apache.flink.optimizer.plantranslate.JobGraphGenerator |
From |
To |
|
Change Variable Type v4 : AbstractJobVertex to v4 : JobVertex in method public testCoLocationConstraintCreation() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphConstructionTest |
From |
To |
|
Change Variable Type taskVertex : AbstractJobVertex to taskVertex : JobVertex in method public createTask(task Class<? extends RegularPactTask>, name String, graph JobGraph, parallelism int) : JobVertex in class org.apache.flink.test.iterative.nephele.JobGraphUtils |
From |
To |
|
Change Variable Type v2 : AbstractJobVertex to v2 : JobVertex in method private testHighToLow(highDop int, lowDop int) : void in class org.apache.flink.runtime.executiongraph.PointwisePatternTest |
From |
To |
|
Change Variable Type current : AbstractJobVertex to current : JobVertex in method public getVerticesSortedTopologicallyFromSources() : List<JobVertex> in class org.apache.flink.runtime.jobgraph.JobGraph |
From |
To |
|
Change Variable Type sourceVertex : AbstractJobVertex to sourceVertex : JobVertex in method private translateChannel(input Channel, inputIndex int, targetVertex JobVertex, targetVertexConfig TaskConfig, isBroadcast boolean) : int in class org.apache.flink.optimizer.plantranslate.JobGraphGenerator |
From |
To |
|
Change Variable Type v5 : AbstractJobVertex to v5 : JobVertex in method public testSetupInputSplits() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphConstructionTest |
From |
To |
|
Change Variable Type sync : AbstractJobVertex to sync : JobVertex in method public getJobGraph(args String[]) : JobGraph in class org.apache.flink.test.iterative.nephele.customdanglingpagerank.CustomCompensatableDanglingPageRank |
From |
To |
|
Change Variable Type tail : AbstractJobVertex to tail : JobVertex in method public getJobGraph(args String[]) : JobGraph in class org.apache.flink.test.iterative.nephele.danglingpagerank.CompensatableDanglingPageRank |
From |
To |
|
Change Variable Type vertices : List<AbstractJobVertex> to vertices : List<JobVertex> in method public testProvokeDeadlock() : void in class org.apache.flink.runtime.executiongraph.TerminalStateDeadlockTest |
From |
To |
|
Change Variable Type ordered : List<AbstractJobVertex> to ordered : List<JobVertex> in method public testNTo2N() : void in class org.apache.flink.runtime.executiongraph.PointwisePatternTest |
From |
To |
|
Change Variable Type v2 : AbstractJobVertex to v2 : JobVertex in method public testRegistrationOfExecutionsFailedExternally() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphDeploymentTest |
From |
To |
|
Change Variable Type ordered : List<AbstractJobVertex> to ordered : List<JobVertex> in method public testSetupInputSplits() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphConstructionTest |
From |
To |
|
Change Variable Type output : AbstractJobVertex to output : JobVertex in method public createJobGraphIntermediateWorksetUpdateAndSolutionSetTail(verticesPath String, edgesPath String, resultPath String, numSubTasks int, maxIterations int) : JobGraph in class org.apache.flink.test.iterative.nephele.ConnectedComponentsNepheleITCase |
From |
To |
|
Change Variable Type v2 : AbstractJobVertex to v2 : JobVertex in method public testBuildDeploymentDescriptor() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphDeploymentTest |
From |
To |
|
Change Variable Type headVertex : AbstractJobVertex to headVertex : JobVertex in method public testAllocateAndReleaseTwoLevels() : void in class org.apache.flink.runtime.instance.SharedSlotsTest |
From |
To |
|
Change Variable Type sync : AbstractJobVertex to sync : JobVertex in method private getTestJobGraph(inputPath String, outputPath String, numSubTasks int, maxIterations int) : JobGraph in class org.apache.flink.test.iterative.nephele.IterationWithChainingNepheleITCase |
From |
To |
|
Change Variable Type v3 : AbstractJobVertex to v3 : JobVertex in method public testTopoSortCyclicGraphIntermediateCycle() : void in class org.apache.flink.runtime.jobgraph.JobGraphTest |
From |
To |
|
Change Variable Type sync : AbstractJobVertex to sync : JobVertex in method public createJobGraphIntermediateWorksetUpdateAndSolutionSetTail(verticesPath String, edgesPath String, resultPath String, numSubTasks int, maxIterations int) : JobGraph in class org.apache.flink.test.iterative.nephele.ConnectedComponentsNepheleITCase |
From |
To |
|
Change Variable Type headOp : AbstractJobVertex to headOp : JobVertex in method public testColocation() : void in class org.apache.flink.streaming.api.IterateTest |
From |
To |
|
Change Variable Type v2 : AbstractJobVertex to v2 : JobVertex in method public testAttachViaIds() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphConstructionTest |
From |
To |
|
Change Variable Type source1 : AbstractJobVertex to source1 : JobVertex in method public testSerialization() : void in class org.apache.flink.runtime.jobgraph.JobGraphTest |
From |
To |
|
Change Variable Type intermediate : AbstractJobVertex to intermediate : JobVertex in method public createJobGraphSeparateTails(verticesPath String, edgesPath String, resultPath String, numSubTasks int, maxIterations int) : JobGraph in class org.apache.flink.test.iterative.nephele.ConnectedComponentsNepheleITCase |
From |
To |
|
Change Variable Type v4 : AbstractJobVertex to v4 : JobVertex in method public testCannotConnectWrongOrder() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphConstructionTest |
From |
To |
|
Change Variable Type ordered : List<AbstractJobVertex> to ordered : List<JobVertex> in method private testLowToHigh(lowDop int, highDop int) : void in class org.apache.flink.runtime.executiongraph.PointwisePatternTest |
From |
To |
|
Change Variable Type tail : AbstractJobVertex to tail : JobVertex in method public getJobGraph(args String[]) : JobGraph in class org.apache.flink.test.iterative.nephele.customdanglingpagerank.CustomCompensatableDanglingPageRankWithCombiner |
From |
To |
|
Change Variable Type v : AbstractJobVertex to v : JobVertex in method public CoLocationGroup(vertices JobVertex...) in class org.apache.flink.runtime.jobmanager.scheduler.CoLocationGroup |
From |
To |
|
Change Variable Type v1 : AbstractJobVertex to v1 : JobVertex in method public testRegistrationOfExecutionsFinishing() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphDeploymentTest |
From |
To |
|
Change Variable Type source : AbstractJobVertex to source : JobVertex in method public testTopologicalSort3() : void in class org.apache.flink.runtime.jobgraph.JobGraphTest |
From |
To |
|
Change Variable Type pointsInput : AbstractJobVertex to pointsInput : JobVertex in method private createMapper(jobGraph JobGraph, numSubTasks int, serializer TypeSerializerFactory<?>) : JobVertex in class org.apache.flink.test.broadcastvars.BroadcastVarsNepheleITCase |
From |
To |
|
Change Variable Type v2 : AbstractJobVertex to v2 : JobVertex in method public test3NToN() : void in class org.apache.flink.runtime.executiongraph.PointwisePatternTest |
From |
To |
|
Change Variable Type vertex : AbstractJobVertex to vertex : JobVertex in method public testArchivingClearsFields() : void in class org.apache.flink.runtime.executiongraph.VertexLocationConstraintTest |
From |
To |
|
Change Variable Type v5 : AbstractJobVertex to v5 : JobVertex in method public testAttachViaIds() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphConstructionTest |
From |
To |
|
Change Variable Type failingJobVertex : AbstractJobVertex to failingJobVertex : JobVertex in method public testExceptionInInitializeOnMaster() : void in class org.apache.flink.test.failingPrograms.JobSubmissionFailsITCase |
From |
To |
|
Change Variable Type headVertex : AbstractJobVertex to headVertex : JobVertex in method public postVisit(node PlanNode) : void in class org.apache.flink.optimizer.plantranslate.JobGraphGenerator |
From |
To |
|
Change Variable Type v2 : AbstractJobVertex to v2 : JobVertex in method public testAttachViaDataSets() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphConstructionTest |
From |
To |
|
Change Variable Type v1 : AbstractJobVertex to v1 : JobVertex in method public testNTo7N() : void in class org.apache.flink.runtime.executiongraph.PointwisePatternTest |
From |
To |
|
Change Variable Type v5 : AbstractJobVertex to v5 : JobVertex in method public testCoLocationConstraintCreation() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphConstructionTest |
From |
To |
|
Change Variable Type receiver : AbstractJobVertex to receiver : JobVertex in method private createTestJobGraph(jobName String, senderParallelism int, receiverParallelism int) : JobGraph in class org.apache.flink.runtime.jobmanager.SlotCountExceedingParallelismTest |
From |
To |
|
Change Variable Type v2 : AbstractJobVertex to v2 : JobVertex in method public testNToN() : void in class org.apache.flink.runtime.executiongraph.PointwisePatternTest |
From |
To |
|
Change Variable Type headVertex : AbstractJobVertex to headVertex : JobVertex in method public testReleaseTwoLevelsFromRoot() : void in class org.apache.flink.runtime.instance.SharedSlotsTest |
From |
To |
|
Change Variable Type vertex : AbstractJobVertex to vertex : JobVertex in method private createDualInputVertex(node DualInputPlanNode) : JobVertex in class org.apache.flink.optimizer.plantranslate.JobGraphGenerator |
From |
To |
|
Change Variable Type v2 : AbstractJobVertex to v2 : JobVertex in method public testAssignSlotSharingGroup() : void in class org.apache.flink.runtime.executiongraph.VertexSlotSharingTest |
From |
To |
|
Change Variable Type sender : AbstractJobVertex to sender : JobVertex in method public testMixedPipelinedAndBlockingResults() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleOrUpdateConsumersTest |
From |
To |
|
Change Variable Type jobVertex : AbstractJobVertex to jobVertex : JobVertex in method public testScheduleWithConstraint2() : void in class org.apache.flink.runtime.executiongraph.VertexLocationConstraintTest |
From |
To |
|
Change Variable Type v : AbstractJobVertex to v : JobVertex in method private addNodesThatHaveNoNewPredecessors(start JobVertex, target List<JobVertex>, remaining Set<JobVertex>) : void in class org.apache.flink.runtime.jobgraph.JobGraph |
From |
To |
|
Change Variable Type itSink : AbstractJobVertex to itSink : JobVertex in method public testColocation() : void in class org.apache.flink.streaming.api.IterateTest |
From |
To |
|
Change Variable Type tailVertex : AbstractJobVertex to tailVertex : JobVertex in method public testReleaseTwoLevelsFromRoot() : void in class org.apache.flink.runtime.instance.SharedSlotsTest |
From |
To |
|
Change Variable Type target : AbstractJobVertex to target : JobVertex in method public testSerialization() : void in class org.apache.flink.runtime.jobgraph.JobGraphTest |
From |
To |
|
Change Variable Type v2 : AbstractJobVertex to v2 : JobVertex in method public testSetupInputSplits() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphConstructionTest |
From |
To |
|
Change Variable Type wsTail : AbstractJobVertex to wsTail : JobVertex in method public createJobGraphSolutionSetUpdateAndWorksetTail(verticesPath String, edgesPath String, resultPath String, numSubTasks int, maxIterations int) : JobGraph in class org.apache.flink.test.iterative.nephele.ConnectedComponentsNepheleITCase |
From |
To |
|
Change Variable Type container : AbstractJobVertex to container : JobVertex in method public postVisit(node PlanNode) : void in class org.apache.flink.optimizer.plantranslate.JobGraphGenerator |
From |
To |
|
Change Variable Type head : AbstractJobVertex to head : JobVertex in method public createJobGraphSolutionSetUpdateAndWorksetTail(verticesPath String, edgesPath String, resultPath String, numSubTasks int, maxIterations int) : JobGraph in class org.apache.flink.test.iterative.nephele.ConnectedComponentsNepheleITCase |
From |
To |
|
Change Variable Type v1 : AbstractJobVertex to v1 : JobVertex in method private testHighToLow(highDop int, lowDop int) : void in class org.apache.flink.runtime.executiongraph.PointwisePatternTest |
From |
To |
|
Change Variable Type v2 : AbstractJobVertex to v2 : JobVertex in method public testRegistrationOfExecutionsCanceled() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphDeploymentTest |
From |
To |
|
Change Variable Type v1 : AbstractJobVertex to v1 : JobVertex in method public testCannotConnectMissingId() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphConstructionTest |
From |
To |
|
Change Variable Type v4 : AbstractJobVertex to v4 : JobVertex in method public testTopoSortCyclicGraphNoSources() : void in class org.apache.flink.runtime.jobgraph.JobGraphTest |
From |
To |
|
Change Variable Type vertex : AbstractJobVertex to vertex : JobVertex in method private createSingleInputVertex(node SingleInputPlanNode) : JobVertex in class org.apache.flink.optimizer.plantranslate.JobGraphGenerator |
From |
To |
|
Change Variable Type ssTail : AbstractJobVertex to ssTail : JobVertex in method public createJobGraphIntermediateWorksetUpdateAndSolutionSetTail(verticesPath String, edgesPath String, resultPath String, numSubTasks int, maxIterations int) : JobGraph in class org.apache.flink.test.iterative.nephele.ConnectedComponentsNepheleITCase |
From |
To |
|
Change Variable Type v1 : AbstractJobVertex to v1 : JobVertex in method public testBuildDeploymentDescriptor() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphDeploymentTest |
From |
To |
|
Change Variable Type jobVertex : AbstractJobVertex to jobVertex : JobVertex in method public testScheduleWithUnfulfillableConstraint() : void in class org.apache.flink.runtime.executiongraph.VertexLocationConstraintTest |
From |
To |
|
Change Variable Type v6 : AbstractJobVertex to v6 : JobVertex in method public testCoLocationConstraintCreation() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphConstructionTest |
From |
To |
|
Change Variable Type mapper : AbstractJobVertex to mapper : JobVertex in method private createMapper(jobGraph JobGraph, numSubTasks int, inputSerializer TypeSerializerFactory<?>, broadcastVarSerializer TypeSerializerFactory<?>, outputSerializer TypeSerializerFactory<?>, outputComparator TypeComparatorFactory<?>) : JobVertex in class org.apache.flink.test.broadcastvars.KMeansIterativeNepheleITCase |
From |
To |
|
Change Variable Type op3 : AbstractJobVertex to op3 : JobVertex in method public testTopologicalSort3() : void in class org.apache.flink.runtime.jobgraph.JobGraphTest |
From |
To |
|
Change Variable Type downStreamVertex : AbstractJobVertex to downStreamVertex : JobVertex in method private connect(headOfChain Integer, edge StreamEdge) : void in class org.apache.flink.streaming.api.graph.StreamingJobGraphGenerator |
From |
To |
|
Change Variable Type vertex : AbstractJobVertex to vertex : JobVertex in method public testAssignSlotAndLockLocation() : void in class org.apache.flink.runtime.jobmanager.scheduler.CoLocationConstraintTest |
From |
To |
|
Change Variable Type intermediate1 : AbstractJobVertex to intermediate1 : JobVertex in method public testTopologicalSort1() : void in class org.apache.flink.runtime.jobgraph.JobGraphTest |
From |
To |
|
Change Variable Type v : AbstractJobVertex to v : JobVertex in method public mergeInto(other CoLocationGroup) : void in class org.apache.flink.runtime.jobmanager.scheduler.CoLocationGroup |
From |
To |
|
Change Variable Type vertex2 : AbstractJobVertex to vertex2 : JobVertex in method public testCreateConstraints() : void in class org.apache.flink.runtime.jobmanager.scheduler.CoLocationConstraintTest |
From |
To |
|
Change Variable Type intermediate : AbstractJobVertex to intermediate : JobVertex in method public createJobGraphUnifiedTails(verticesPath String, edgesPath String, resultPath String, numSubTasks int, maxIterations int) : JobGraph in class org.apache.flink.test.iterative.nephele.ConnectedComponentsNepheleITCase |
From |
To |
|
Change Variable Type ordered2 : List<AbstractJobVertex> to ordered2 : List<JobVertex> in method public testCannotConnectMissingId() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphConstructionTest |
From |
To |
|
Change Variable Type v2 : AbstractJobVertex to v2 : JobVertex in method private testLowToHigh(lowDop int, highDop int) : void in class org.apache.flink.runtime.executiongraph.PointwisePatternTest |
From |
To |
|
Change Variable Type v1 : AbstractJobVertex to v1 : JobVertex in method public testNTo2N() : void in class org.apache.flink.runtime.executiongraph.PointwisePatternTest |
From |
To |
|
Change Variable Type tail : AbstractJobVertex to tail : JobVertex in method public createJobGraphUnifiedTails(verticesPath String, edgesPath String, resultPath String, numSubTasks int, maxIterations int) : JobGraph in class org.apache.flink.test.iterative.nephele.ConnectedComponentsNepheleITCase |
From |
To |
|
Change Variable Type ordered : List<AbstractJobVertex> to ordered : List<JobVertex> in method public testAttachViaIds() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphConstructionTest |
From |
To |
|
Change Variable Type v3 : AbstractJobVertex to v3 : JobVertex in method public testCannotConnectWrongOrder() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphConstructionTest |
From |
To |
|
Change Variable Type sync : AbstractJobVertex to sync : JobVertex in method public getJobGraph(args String[]) : JobGraph in class org.apache.flink.test.iterative.nephele.danglingpagerank.CompensatableDanglingPageRank |
From |
To |
|
Change Variable Type source : AbstractJobVertex to source : JobVertex in method public testCancelUnion() : void in class org.apache.flink.runtime.taskmanager.TaskCancelTest |
From |
To |
|
Change Variable Type v2 : AbstractJobVertex to v2 : JobVertex in method public testTopoSortCyclicGraphNoSources() : void in class org.apache.flink.runtime.jobgraph.JobGraphTest |
From |
To |
|
Change Variable Type source2 : AbstractJobVertex to source2 : JobVertex in method public testTopologicalSort2() : void in class org.apache.flink.runtime.jobgraph.JobGraphTest |
From |
To |
|
Change Variable Type ordered : List<AbstractJobVertex> to ordered : List<JobVertex> in method public testCannotConnectWrongOrder() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphConstructionTest |
From |
To |
|
Change Variable Type l13 : AbstractJobVertex to l13 : JobVertex in method public testTopologicalSort2() : void in class org.apache.flink.runtime.jobgraph.JobGraphTest |
From |
To |
|
Change Variable Type ordered : List<AbstractJobVertex> to ordered : List<JobVertex> in method public test2NToN() : void in class org.apache.flink.runtime.executiongraph.PointwisePatternTest |
From |
To |
|
Change Variable Type receiver : AbstractJobVertex to receiver : JobVertex in method public testPartialConsumePipelinedResultReceiver() : void in class org.apache.flink.runtime.io.network.partition.PartialConsumePipelinedResultTest |
From |
To |
|
Change Variable Type intermediate : AbstractJobVertex to intermediate : JobVertex in method public getJobGraph(args String[]) : JobGraph in class org.apache.flink.test.iterative.nephele.danglingpagerank.CompensatableDanglingPageRank |
From |
To |
|
Change Variable Type vertex : AbstractJobVertex to vertex : JobVertex in method private runTests(numHosts int, slotsPerHost int, parallelism int, splits TestLocatableInputSplit[]) : String[] in class org.apache.flink.runtime.executiongraph.LocalInputSplitsTest |
From |
To |
|
Change Variable Type solutionDeltaVertex : AbstractJobVertex to solutionDeltaVertex : JobVertex in method private finalizeWorksetIteration(descr IterationDescriptor) : void in class org.apache.flink.optimizer.plantranslate.JobGraphGenerator |
From |
To |
|
Change Variable Type blockingReceiver : AbstractJobVertex to blockingReceiver : JobVertex in method public testMixedPipelinedAndBlockingResults() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleOrUpdateConsumersTest |
From |
To |
|
Change Variable Type head : AbstractJobVertex to head : JobVertex in method private getTestJobGraph(inputPath String, outputPath String, numSubTasks int, maxIterations int) : JobGraph in class org.apache.flink.test.iterative.nephele.IterationWithChainingNepheleITCase |
From |
To |
|
Change Variable Type v2 : AbstractJobVertex to v2 : JobVertex in method public testRegistrationOfExecutionsFinishing() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphDeploymentTest |
From |
To |
|
Change Variable Type sorted : List<AbstractJobVertex> to sorted : List<JobVertex> in method public getVerticesSortedTopologicallyFromSources() : List<JobVertex> in class org.apache.flink.runtime.jobgraph.JobGraph |
From |
To |
|
Change Variable Type v7 : AbstractJobVertex to v7 : JobVertex in method public testCoLocationConstraintCreation() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphConstructionTest |
From |
To |
|
Change Variable Type headVertex : AbstractJobVertex to headVertex : JobVertex in method private createWorksetIterationHead(wspn WorksetPlanNode) : JobVertex in class org.apache.flink.optimizer.plantranslate.JobGraphGenerator |
From |
To |
|
Change Variable Type wsUpdateIntermediate : AbstractJobVertex to wsUpdateIntermediate : JobVertex in method public createJobGraphIntermediateWorksetUpdateAndSolutionSetTail(verticesPath String, edgesPath String, resultPath String, numSubTasks int, maxIterations int) : JobGraph in class org.apache.flink.test.iterative.nephele.ConnectedComponentsNepheleITCase |
From |
To |