|
Rename Method public addBroadcastSetForUpdateFunction(name String, data DataSet<?>) : void renamed to public addBroadcastSetForGatherFunction(name String, data DataSet<?>) : void in class org.apache.flink.graph.spargel.ScatterGatherConfiguration |
From |
To |
|
Rename Method public addBroadcastSetForMessagingFunction(name String, data DataSet<?>) : void renamed to public addBroadcastSetForScatterFunction(name String, data DataSet<?>) : void in class org.apache.flink.graph.spargel.ScatterGatherConfiguration |
From |
To |
|
Rename Method private buildMessagingFunctionVerticesWithDegrees(iteration DeltaIteration<Vertex<K,Tuple3<VV,LongValue,LongValue>>,Vertex<K,Tuple3<VV,LongValue,LongValue>>>, messageTypeInfo TypeInformation<Tuple2<K,Message>>, whereArg int, equalToArg int, numberOfVertices DataSet<LongValue>) : CoGroupOperator<?,?,Tuple2<K,Message>> renamed to private buildScatterFunctionVerticesWithDegrees(iteration DeltaIteration<Vertex<K,Tuple3<VV,LongValue,LongValue>>,Vertex<K,Tuple3<VV,LongValue,LongValue>>>, messageTypeInfo TypeInformation<Tuple2<K,Message>>, whereArg int, equalToArg int, numberOfVertices DataSet<LongValue>) : CoGroupOperator<?,?,Tuple2<K,Message>> in class org.apache.flink.graph.spargel.ScatterGatherIteration |
From |
To |
|
Rename Method private buildMessagingFunction(iteration DeltaIteration<Vertex<K,VV>,Vertex<K,VV>>, messageTypeInfo TypeInformation<Tuple2<K,Message>>, whereArg int, equalToArg int, numberOfVertices DataSet<LongValue>) : CoGroupOperator<?,?,Tuple2<K,Message>> renamed to private buildScatterFunction(iteration DeltaIteration<Vertex<K,VV>,Vertex<K,VV>>, messageTypeInfo TypeInformation<Tuple2<K,Message>>, whereArg int, equalToArg int, numberOfVertices DataSet<LongValue>) : CoGroupOperator<?,?,Tuple2<K,Message>> in class org.apache.flink.graph.spargel.ScatterGatherIteration |
From |
To |
|
Rename Method public getUpdateBcastVars() : List<Tuple2<String,DataSet<?>>> renamed to public getScatterBcastVars() : List<Tuple2<String,DataSet<?>>> in class org.apache.flink.graph.spargel.ScatterGatherConfiguration |
From |
To |
|
Rename Method public getMessagingBcastVars() : List<Tuple2<String,DataSet<?>>> renamed to public getGatherBcastVars() : List<Tuple2<String,DataSet<?>>> in class org.apache.flink.graph.spargel.ScatterGatherConfiguration |
From |
To |
|
Change Parameter Type mf : MessagingFunction<K,VV,Message,EV> to mf : ScatterFunction<K,VV,Message,EV> in method private getMessageType(mf ScatterFunction<K,VV,Message,EV>) : TypeInformation<Message> in class org.apache.flink.graph.spargel.ScatterGatherIteration |
From |
To |
|
Change Parameter Type messagingFunction : MessagingFunction<K,VV,Message,EV> to scatterFunction : ScatterFunction<K,VV,Message,EV> in method private ScatterUdfWithEVsSimpleVV(scatterFunction ScatterFunction<K,VV,Message,EV>, resultType TypeInformation<Tuple2<K,Message>>) in class org.apache.flink.graph.spargel.ScatterGatherIteration.ScatterUdfWithEVsSimpleVV |
From |
To |
|
Change Parameter Type vertexUpdateFunction : VertexUpdateFunction<K,VV,M> to scatterFunction : ScatterFunction<K,VV,M,EV> in method public runScatterGatherIteration(scatterFunction ScatterFunction<K,VV,M,EV>, gatherFunction GatherFunction<K,VV,M>, maximumNumberOfIterations int, parameters ScatterGatherConfiguration) : Graph<K,VV,EV> in class org.apache.flink.graph.Graph |
From |
To |
|
Change Parameter Type messagingFunction : MessagingFunction<K,VV,Message,EV> to scatterFunction : ScatterFunction<K,VV,Message,EV> in method private ScatterUdfWithEVsVVWithDegrees(scatterFunction ScatterFunction<K,VV,Message,EV>, resultType TypeInformation<Tuple2<K,Message>>) in class org.apache.flink.graph.spargel.ScatterGatherIteration.ScatterUdfWithEVsVVWithDegrees |
From |
To |
|
Change Parameter Type vertexUpdateFunction : VertexUpdateFunction<K,VV,M> to scatterFunction : ScatterFunction<K,VV,M,EV> in method public runScatterGatherIteration(scatterFunction ScatterFunction<K,VV,M,EV>, gatherFunction GatherFunction<K,VV,M>, maximumNumberOfIterations int) : Graph<K,VV,EV> in class org.apache.flink.graph.Graph |
From |
To |
|
Change Parameter Type gatherFunction : GatherFunction<VV,EV,M> to gatherFunction : GatherFunction in method public runGatherSumApplyIteration(gatherFunction GatherFunction, 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 vertexUpdateFunction : VertexUpdateFunction<K,VV,Message> to gatherFunction : GatherFunction<K,VV,Message> in method private GatherUdfSimpleVV(gatherFunction GatherFunction<K,VV,Message>, resultType TypeInformation<Vertex<K,VV>>) in class org.apache.flink.graph.spargel.ScatterGatherIteration.GatherUdfSimpleVV |
From |
To |
|
Change Parameter Type messagingFunction : MessagingFunction<K,VV,M,EV> to gatherFunction : GatherFunction<K,VV,M> in method public runScatterGatherIteration(scatterFunction ScatterFunction<K,VV,M,EV>, gatherFunction GatherFunction<K,VV,M>, maximumNumberOfIterations int) : Graph<K,VV,EV> in class org.apache.flink.graph.Graph |
From |
To |
|
Change Parameter Type uf : VertexUpdateFunction<K,VV,Message> to sf : ScatterFunction<K,VV,Message,EV> in method public withEdges(edgesWithValue DataSet<Edge<K,EV>>, sf ScatterFunction<K,VV,Message,EV>, gf GatherFunction<K,VV,Message>, maximumNumberOfIterations int) : ScatterGatherIteration<K,VV,Message,EV> in class org.apache.flink.graph.spargel.ScatterGatherIteration |
From |
To |
|
Change Parameter Type mf : MessagingFunction<K,VV,Message,EV> to gf : GatherFunction<K,VV,Message> in method public withEdges(edgesWithValue DataSet<Edge<K,EV>>, sf ScatterFunction<K,VV,Message,EV>, gf GatherFunction<K,VV,Message>, maximumNumberOfIterations int) : ScatterGatherIteration<K,VV,Message,EV> in class org.apache.flink.graph.spargel.ScatterGatherIteration |
From |
To |
|
Change Parameter Type messagingFunction : MessagingFunction<K,VV,Message,EV> to scatterFunction : ScatterFunction<K,VV,Message,EV> in method private ScatterUdfWithEdgeValues(scatterFunction ScatterFunction<K,VV,Message,EV>, resultType TypeInformation<Tuple2<K,Message>>) in class org.apache.flink.graph.spargel.ScatterGatherIteration.ScatterUdfWithEdgeValues |
From |
To |
|
Change Parameter Type gatherFunction : GatherFunction<VV,EV,M> to gatherFunction : GatherFunction in method public runGatherSumApplyIteration(gatherFunction GatherFunction, sumFunction SumFunction<VV,EV,M>, applyFunction ApplyFunction<K,VV,M>, maximumNumberOfIterations int, parameters GSAConfiguration) : Graph<K,VV,EV> in class org.apache.flink.graph.Graph |
From |
To |
|
Change Parameter Type messagingFunction : MessagingFunction<K,VV,M,EV> to gatherFunction : GatherFunction<K,VV,M> in method public runScatterGatherIteration(scatterFunction ScatterFunction<K,VV,M,EV>, gatherFunction GatherFunction<K,VV,M>, maximumNumberOfIterations int, parameters ScatterGatherConfiguration) : Graph<K,VV,EV> in class org.apache.flink.graph.Graph |
From |
To |
|
Change Parameter Type vertexUpdateFunction : VertexUpdateFunction<K,VVWithDegrees,Message> to gatherFunction : GatherFunction<K,VVWithDegrees,Message> in method private GatherUdf(gatherFunction GatherFunction<K,VVWithDegrees,Message>, resultType TypeInformation<Vertex<K,VVWithDegrees>>) in class org.apache.flink.graph.spargel.ScatterGatherIteration.GatherUdf |
From |
To |
|
Change Parameter Type vertexUpdateFunction : VertexUpdateFunction<K,Tuple3<VV,LongValue,LongValue>,Message> to gatherFunction : GatherFunction<K,Tuple3<VV,LongValue,LongValue>,Message> in method private GatherUdfVVWithDegrees(gatherFunction GatherFunction<K,Tuple3<VV,LongValue,LongValue>,Message>, resultType TypeInformation<Vertex<K,Tuple3<VV,LongValue,LongValue>>>) in class org.apache.flink.graph.spargel.ScatterGatherIteration.GatherUdfVVWithDegrees |
From |
To |
|
Change Variable Type messenger : MessagingUdfWithEdgeValues<K,Tuple3<VV,LongValue,LongValue>,VV,Message,EV> to messenger : ScatterUdfWithEdgeValues<K,Tuple3<VV,LongValue,LongValue>,VV,Message,EV> in method private buildScatterFunctionVerticesWithDegrees(iteration DeltaIteration<Vertex<K,Tuple3<VV,LongValue,LongValue>>,Vertex<K,Tuple3<VV,LongValue,LongValue>>>, messageTypeInfo TypeInformation<Tuple2<K,Message>>, whereArg int, equalToArg int, numberOfVertices DataSet<LongValue>) : CoGroupOperator<?,?,Tuple2<K,Message>> in class org.apache.flink.graph.spargel.ScatterGatherIteration |
From |
To |
|
Change Variable Type updateUdf : VertexUpdateUdf<K,VV,Message> to updateUdf : GatherUdf<K,VV,Message> in method private createResultSimpleVertex(messagingDirection EdgeDirection, messageTypeInfo TypeInformation<Tuple2<K,Message>>, numberOfVertices DataSet<LongValue>) : DataSet<Vertex<K,VV>> in class org.apache.flink.graph.spargel.ScatterGatherIteration |
From |
To |
|
Change Variable Type messenger : MessagingUdfWithEdgeValues<K,VV,VV,Message,EV> to messenger : ScatterUdfWithEdgeValues<K,VV,VV,Message,EV> in method private buildScatterFunction(iteration DeltaIteration<Vertex<K,VV>,Vertex<K,VV>>, messageTypeInfo TypeInformation<Tuple2<K,Message>>, whereArg int, equalToArg int, numberOfVertices DataSet<LongValue>) : CoGroupOperator<?,?,Tuple2<K,Message>> in class org.apache.flink.graph.spargel.ScatterGatherIteration |
From |
To |
|
Change Variable Type updateUdf : VertexUpdateUdf<K,Tuple3<VV,LongValue,LongValue>,Message> to updateUdf : GatherUdf<K,Tuple3<VV,LongValue,LongValue>,Message> in method private createResultVerticesWithDegrees(graph Graph<K,VV,EV>, messagingDirection EdgeDirection, messageTypeInfo TypeInformation<Tuple2<K,Message>>, numberOfVertices DataSet<LongValue>) : DataSet<Vertex<K,VV>> in class org.apache.flink.graph.spargel.ScatterGatherIteration |
From |
To |
|
Rename Parameter messagingFunction : MessagingFunction<K,VV,Message,EV> to scatterFunction : ScatterFunction<K,VV,Message,EV> in method private ScatterUdfWithEdgeValues(scatterFunction ScatterFunction<K,VV,Message,EV>, resultType TypeInformation<Tuple2<K,Message>>) in class org.apache.flink.graph.spargel.ScatterGatherIteration.ScatterUdfWithEdgeValues |
From |
To |
|
Rename Parameter vertexUpdateFunction : VertexUpdateFunction<K,VV,M> to scatterFunction : ScatterFunction<K,VV,M,EV> in method public runScatterGatherIteration(scatterFunction ScatterFunction<K,VV,M,EV>, gatherFunction GatherFunction<K,VV,M>, maximumNumberOfIterations int) : Graph<K,VV,EV> in class org.apache.flink.graph.Graph |
From |
To |
|
Rename Parameter messagingFunction : MessagingFunction<K,VV,M,EV> to gatherFunction : GatherFunction<K,VV,M> in method public runScatterGatherIteration(scatterFunction ScatterFunction<K,VV,M,EV>, gatherFunction GatherFunction<K,VV,M>, maximumNumberOfIterations int, parameters ScatterGatherConfiguration) : Graph<K,VV,EV> in class org.apache.flink.graph.Graph |
From |
To |
|
Rename Parameter vertexUpdateFunction : VertexUpdateFunction<K,VVWithDegrees,Message> to gatherFunction : GatherFunction<K,VVWithDegrees,Message> in method private GatherUdf(gatherFunction GatherFunction<K,VVWithDegrees,Message>, resultType TypeInformation<Vertex<K,VVWithDegrees>>) in class org.apache.flink.graph.spargel.ScatterGatherIteration.GatherUdf |
From |
To |
|
Rename Parameter vertexUpdateFunction : VertexUpdateFunction<K,Tuple3<VV,LongValue,LongValue>,Message> to gatherFunction : GatherFunction<K,Tuple3<VV,LongValue,LongValue>,Message> in method private GatherUdfVVWithDegrees(gatherFunction GatherFunction<K,Tuple3<VV,LongValue,LongValue>,Message>, resultType TypeInformation<Vertex<K,Tuple3<VV,LongValue,LongValue>>>) in class org.apache.flink.graph.spargel.ScatterGatherIteration.GatherUdfVVWithDegrees |
From |
To |
|
Rename Parameter messagingFunction : MessagingFunction<K,VV,M,EV> to gatherFunction : GatherFunction<K,VV,M> in method public runScatterGatherIteration(scatterFunction ScatterFunction<K,VV,M,EV>, gatherFunction GatherFunction<K,VV,M>, maximumNumberOfIterations int) : Graph<K,VV,EV> in class org.apache.flink.graph.Graph |
From |
To |
|
Rename Parameter messagingFunction : MessagingFunction<K,VV,Message,EV> to scatterFunction : ScatterFunction<K,VV,Message,EV> in method private ScatterUdfWithEVsSimpleVV(scatterFunction ScatterFunction<K,VV,Message,EV>, resultType TypeInformation<Tuple2<K,Message>>) in class org.apache.flink.graph.spargel.ScatterGatherIteration.ScatterUdfWithEVsSimpleVV |
From |
To |
|
Rename Parameter uf : VertexUpdateFunction<K,VV,Message> to sf : ScatterFunction<K,VV,Message,EV> in method public withEdges(edgesWithValue DataSet<Edge<K,EV>>, sf ScatterFunction<K,VV,Message,EV>, gf GatherFunction<K,VV,Message>, maximumNumberOfIterations int) : ScatterGatherIteration<K,VV,Message,EV> in class org.apache.flink.graph.spargel.ScatterGatherIteration |
From |
To |
|
Rename Parameter vertexUpdateFunction : VertexUpdateFunction<K,VV,M> to scatterFunction : ScatterFunction<K,VV,M,EV> in method public runScatterGatherIteration(scatterFunction ScatterFunction<K,VV,M,EV>, gatherFunction GatherFunction<K,VV,M>, maximumNumberOfIterations int, parameters ScatterGatherConfiguration) : Graph<K,VV,EV> in class org.apache.flink.graph.Graph |
From |
To |
|
Rename Parameter mf : MessagingFunction<K,VV,Message,EV> to gf : GatherFunction<K,VV,Message> in method public withEdges(edgesWithValue DataSet<Edge<K,EV>>, sf ScatterFunction<K,VV,Message,EV>, gf GatherFunction<K,VV,Message>, maximumNumberOfIterations int) : ScatterGatherIteration<K,VV,Message,EV> in class org.apache.flink.graph.spargel.ScatterGatherIteration |
From |
To |
|
Rename Parameter messagingFunction : MessagingFunction<K,VV,Message,EV> to scatterFunction : ScatterFunction<K,VV,Message,EV> in method private ScatterUdfWithEVsVVWithDegrees(scatterFunction ScatterFunction<K,VV,Message,EV>, resultType TypeInformation<Tuple2<K,Message>>) in class org.apache.flink.graph.spargel.ScatterGatherIteration.ScatterUdfWithEVsVVWithDegrees |
From |
To |
|
Rename Parameter vertexUpdateFunction : VertexUpdateFunction<K,VV,Message> to gatherFunction : GatherFunction<K,VV,Message> in method private GatherUdfSimpleVV(gatherFunction GatherFunction<K,VV,Message>, resultType TypeInformation<Vertex<K,VV>>) in class org.apache.flink.graph.spargel.ScatterGatherIteration.GatherUdfSimpleVV |
From |
To |