585d27d0d7c882797f813a25d21485187b546145
Files Diff
- Added: 3
- Removed: 0
- Renamed: 0
- Modified: 16
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Method | 1 | ||
| Rename Method public getOutgoingEdges() : Iterable<Edge<VertexKey,EdgeValue>> renamed to public getEdges() : Iterable<Edge<VertexKey,EdgeValue>> in class org.apache.flink.graph.spargel.MessagingFunction | From | To | |
| Push Down Method | 3 | ||
| Push Down Method public coGroup(messages Iterable<Tuple2<VertexKey,Message>>, vertex Iterable<Vertex<VertexKey,VertexValue>>, out Collector<Vertex<VertexKey,VertexValue>>) : void from class org.apache.flink.graph.spargel.VertexCentricIteration.VertexUpdateUdf to public coGroup(messages Iterable<Tuple2<VertexKey,Message>>, vertex Iterable<Vertex<VertexKey,VertexValue>>, out Collector<Vertex<VertexKey,VertexValue>>) : void from class org.apache.flink.graph.spargel.VertexCentricIteration.VertexUpdateUdfSimpleVertexValue | From | To | |
| Push Down Method public coGroup(edges Iterable<Edge<VertexKey,EdgeValue>>, state Iterable<Vertex<VertexKey,VertexValue>>, out Collector<Tuple2<VertexKey,Message>>) : void from class org.apache.flink.graph.spargel.VertexCentricIteration.MessagingUdfWithEdgeValues to public coGroup(edges Iterable<Edge<VertexKey,EdgeValue>>, state Iterable<Vertex<VertexKey,Tuple3<VertexValue,Long,Long>>>, out Collector<Tuple2<VertexKey,Message>>) : void from class org.apache.flink.graph.spargel.VertexCentricIteration.MessagingUdfWithEdgeValuesVertexValueWithDegrees | From | To | |
| Push Down Method public coGroup(edges Iterable<Edge<VertexKey,EdgeValue>>, state Iterable<Vertex<VertexKey,VertexValue>>, out Collector<Tuple2<VertexKey,Message>>) : void from class org.apache.flink.graph.spargel.VertexCentricIteration.MessagingUdfWithEdgeValues to public coGroup(edges Iterable<Edge<VertexKey,EdgeValue>>, state Iterable<Vertex<VertexKey,VertexValue>>, out Collector<Tuple2<VertexKey,Message>>) : void from class org.apache.flink.graph.spargel.VertexCentricIteration.MessagingUdfWithEdgeValuesSimpleVertexValue | From | To | |
| Change Parameter Type | 2 | ||
| Change Parameter Type state : Iterable<Vertex<VertexKey,VertexValue>> to state : Iterable<Vertex<VertexKey,Tuple3<VertexValue,Long,Long>>> in method public coGroup(edges Iterable<Edge<VertexKey,EdgeValue>>, state Iterable<Vertex<VertexKey,Tuple3<VertexValue,Long,Long>>>, out Collector<Tuple2<VertexKey,Message>>) : void in class org.apache.flink.graph.spargel.VertexCentricIteration.MessagingUdfWithEdgeValuesVertexValueWithDegrees | From | To | |
| Change Parameter Type resultType : TypeInformation<Vertex<VertexKey,VertexValue>> to resultType : TypeInformation<Vertex<VertexKey,VV>> in method private VertexUpdateUdf(vertexUpdateFunction VertexUpdateFunction<VertexKey,VertexValue,Message>, resultType TypeInformation<Vertex<VertexKey,VV>>) in class org.apache.flink.graph.spargel.VertexCentricIteration.VertexUpdateUdf | From | To | |
| Change Return Type | 1 | ||
| Change Return Type TypeInformation<Vertex<VertexKey,VertexValue>> to TypeInformation<Vertex<VertexKey,VV>> in method public getProducedType() : TypeInformation<Vertex<VertexKey,VV>> in class org.apache.flink.graph.spargel.VertexCentricIteration.VertexUpdateUdf | From | To | |
| Change Variable Type | 1 | ||
| Change Variable Type iteration : DeltaIteration<Vertex<VertexKey,VertexValue>,Vertex<VertexKey,VertexValue>> to iteration : DeltaIteration<Vertex<VertexKey,VV>,Vertex<VertexKey,VV>> in method private setUpIteration(vertices DataSet<Vertex<VertexKey,VV>>) : DeltaIteration<Vertex<VertexKey,VV>,Vertex<VertexKey,VV>> in class org.apache.flink.graph.spargel.VertexCentricIteration | From | To | |
| Change Attribute Type | 1 | ||
| Change Attribute Type resultType : TypeInformation<Vertex<VertexKey,VertexValue>> to resultType : TypeInformation<Vertex<VertexKey,VV>> in class org.apache.flink.graph.spargel.VertexCentricIteration.VertexUpdateUdf | From | To | |
| Extract Method | 4 | ||
| Extract Method private setUpIteration(vertices DataSet<Vertex<VertexKey,VV>>) : DeltaIteration<Vertex<VertexKey,VV>,Vertex<VertexKey,VV>> extracted from public createResult() : DataSet<Vertex<VertexKey,VertexValue>> in class org.apache.flink.graph.spargel.VertexCentricIteration | From | To | |
| Extract Method private configureUpdateFunction(updates CoGroupOperator<?,?,Vertex<VertexKey,VV>>) : void extracted from public createResult() : DataSet<Vertex<VertexKey,VertexValue>> in class org.apache.flink.graph.spargel.VertexCentricIteration | From | To | |
| Extract Method private buildMessagingFunction(iteration DeltaIteration<Vertex<VertexKey,VertexValue>,Vertex<VertexKey,VertexValue>>, messageTypeInfo TypeInformation<Tuple2<VertexKey,Message>>, whereArg int, equalToArg int) : CoGroupOperator<?,?,Tuple2<VertexKey,Message>> extracted from public createResult() : DataSet<Vertex<VertexKey,VertexValue>> in class org.apache.flink.graph.spargel.VertexCentricIteration | From | To | |
| Extract Method private createResultSimpleVertex(messagingDirection EdgeDirection, messages DataSet<Tuple2<VertexKey,Message>>, messageTypeInfo TypeInformation<Tuple2<VertexKey,Message>>) : DataSet<Vertex<VertexKey,VertexValue>> extracted from public createResult() : DataSet<Vertex<VertexKey,VertexValue>> in class org.apache.flink.graph.spargel.VertexCentricIteration | From | To | |
| Extract And Move Method | 1 | ||
| Extract And Move Method package setNumberOfVertices(numberOfVertices long) : void extracted from public createResult() : DataSet<Vertex<VertexKey,VertexValue>> in class org.apache.flink.graph.spargel.VertexCentricIteration & moved to class org.apache.flink.graph.spargel.MessagingFunction | From | To | |
| Rename Parameter | 1 | ||
| Rename Parameter val : Vertex<VertexKey,VertexValue> to outVal : Vertex<VertexKey,VertexValue> in method package setOutput(outVal Vertex<VertexKey,VertexValue>, out Collector<Vertex<VertexKey,VertexValue>>) : void in class org.apache.flink.graph.spargel.VertexUpdateFunction | From | To |