|
Change Parameter Type out : Collector<VV> to out : Collector<Vertex<K,VV>> in method public setOutput(vertex Vertex<K,VV>, out Collector<Vertex<K,VV>>) : void in class org.apache.flink.graph.gsa.ApplyFunction |
From |
To |
|
Change Parameter Type applyFunction : ApplyFunction<VV,EV,M> to applyFunction : ApplyFunction<K,VV,M> in method private ApplyUdf(applyFunction ApplyFunction<K,VV,M>, resultType TypeInformation<Vertex<K,VV>>) in class org.apache.flink.graph.gsa.GatherSumApplyIteration.ApplyUdf |
From |
To |
|
Change Parameter Type applyFunction : ApplyFunction<VV,EV,M> to applyFunction : ApplyFunction<K,VV,M> in method public runGatherSumApplyIteration(gatherFunction GatherFunction<VV,EV,M>, sumFunction SumFunction<VV,EV,M>, applyFunction ApplyFunction<K,VV,M>, maximumNumberOfIterations int) : Graph<K,VV,EV> in class org.apache.flink.graph.Graph |
From |
To |
|
Change Parameter Type apply : ApplyFunction<VV,EV,M> to apply : ApplyFunction<K,VV,M> in method public withEdges(edges DataSet<Edge<K,EV>>, gather GatherFunction<VV,EV,M>, sum SumFunction<VV,EV,M>, apply ApplyFunction<K,VV,M>, maximumNumberOfIterations int) : GatherSumApplyIteration<K,VV,EV,M> in class org.apache.flink.graph.gsa.GatherSumApplyIteration |
From |
To |
|
Change Parameter Type apply : ApplyFunction<VV,EV,M> to apply : ApplyFunction<K,VV,M> in method private GatherSumApplyIteration(gather GatherFunction<VV,EV,M>, sum SumFunction<VV,EV,M>, apply ApplyFunction<K,VV,M>, edges DataSet<Edge<K,EV>>, maximumNumberOfIterations int) in class org.apache.flink.graph.gsa.GatherSumApplyIteration |
From |
To |
|
Rename Parameter message : M to newValue : M in method public abstract apply(newValue M, currentValue VV) : void in class org.apache.flink.graph.gsa.ApplyFunction |
From |
To |
|
Rename Parameter arg0 : Tuple2<K,M> to newValue : Tuple2<K,M> in method public join(newValue Tuple2<K,M>, currentValue Vertex<K,VV>, out Collector<Vertex<K,VV>>) : void in class org.apache.flink.graph.gsa.GatherSumApplyIteration.ApplyUdf |
From |
To |
|
Rename Parameter vertexValue : VV to currentValue : VV in method public abstract apply(newValue M, currentValue VV) : void in class org.apache.flink.graph.gsa.ApplyFunction |
From |
To |
|
Rename Parameter arg1 : Vertex<K,VV> to currentValue : Vertex<K,VV> in method public join(newValue Tuple2<K,M>, currentValue Vertex<K,VV>, out Collector<Vertex<K,VV>>) : void in class org.apache.flink.graph.gsa.GatherSumApplyIteration.ApplyUdf |
From |
To |