02f99c39d3fe92a31eafcff4ac5fc62f548658b3
Files Diff
- Added: 5
- Removed: 2
- Renamed: 0
- Modified: 13
Refactorings reported:
Refactoring Name | Occurences | ||
---|---|---|---|
Rename Method | 2 | ||
Rename Method public testOutputFormatVertex() : void renamed to public testOutputFormat() : void in class org.apache.flink.runtime.jobgraph.JobTaskVertexTest | From | To | |
Rename Method public testInputFormatVertex() : void renamed to public testInputFormat() : void in class org.apache.flink.runtime.jobgraph.JobTaskVertexTest | From | To | |
Rename Variable | 3 | ||
Rename Variable prevContextCl : ClassLoader to original : ClassLoader in method public finalizeOnMaster(loader ClassLoader) : void in class org.apache.flink.runtime.jobgraph.InputOutputFormatVertex | From | To | |
Rename Variable of : OutputFormatVertex to vertex : InputOutputFormatVertex in method public testOutputFormat() : void in class org.apache.flink.runtime.jobgraph.JobTaskVertexTest | From | To | |
Rename Variable prevContextCl : ClassLoader to original : ClassLoader in method public initializeOnMaster(loader ClassLoader) : void in class org.apache.flink.runtime.jobgraph.InputOutputFormatVertex | From | To | |
Change Return Type | 1 | ||
Change Return Type InputFormatVertex to JobVertex in method private createDataSourceVertex(node SourcePlanNode) : JobVertex in class org.apache.flink.optimizer.plantranslate.JobGraphGenerator | From | To | |
Rename Class | 2 | ||
Rename Class org.apache.flink.runtime.jobgraph.InputFormatVertex renamed to org.apache.flink.runtime.jobgraph.InputOutputFormatVertex | From | To | |
Rename Class org.apache.flink.runtime.jobgraph.OutputFormatVertex renamed to org.apache.flink.runtime.jobgraph.InputOutputFormatVertex | From | To | |
Extract Variable | 2 | ||
Extract Variable currentOperatorId : OperatorID in method private createChain(startNodeId Integer, currentNodeId Integer, hashes Map<Integer,byte[]>, legacyHashes List<Map<Integer,byte[]>>, chainIndex int, chainedOperatorHashes Map<Integer,List<Tuple2<byte[],byte[]>>>) : List<StreamEdge> from class org.apache.flink.streaming.api.graph.StreamingJobGraphGenerator | From | To | |
Extract Variable currentNode : StreamNode in method private createChain(startNodeId Integer, currentNodeId Integer, hashes Map<Integer,byte[]>, legacyHashes List<Map<Integer,byte[]>>, chainIndex int, chainedOperatorHashes Map<Integer,List<Tuple2<byte[],byte[]>>>) : List<StreamEdge> from class org.apache.flink.streaming.api.graph.StreamingJobGraphGenerator | From | To | |
Change Variable Type | 5 | ||
Change Variable Type copy : OutputFormatVertex to copy : InputOutputFormatVertex in method public testOutputFormat() : void in class org.apache.flink.runtime.jobgraph.JobTaskVertexTest | From | To | |
Change Variable Type vertex : InputFormatVertex to vertex : InputOutputFormatVertex in method public testInputFormat() : void in class org.apache.flink.runtime.jobgraph.JobTaskVertexTest | From | To | |
Change Variable Type of : OutputFormatVertex to vertex : InputOutputFormatVertex in method public testOutputFormat() : void in class org.apache.flink.runtime.jobgraph.JobTaskVertexTest | From | To | |
Change Variable Type vertex : InputFormatVertex to vertex : InputOutputFormatVertex in method private createDataSourceVertex(node SourcePlanNode) : JobVertex in class org.apache.flink.optimizer.plantranslate.JobGraphGenerator | From | To | |
Change Variable Type vertex : OutputFormatVertex to vertex : InputOutputFormatVertex in method private createDataSinkVertex(node SinkPlanNode) : JobVertex in class org.apache.flink.optimizer.plantranslate.JobGraphGenerator | From | To | |
Extract Method | 1 | ||
Extract Method private initInputOutputformatContainer(classLoader ClassLoader) : InputOutputFormatContainer extracted from public initializeOnMaster(loader ClassLoader) : void in class org.apache.flink.runtime.jobgraph.InputOutputFormatVertex | From | To |