|
Change Parameter Type target : VertexKey to target : K in method public sendMessageTo(target K, m Message) : void in class org.apache.flink.graph.spargel.MessagingFunction |
From |
To |
|
Change Parameter Type outVal : Vertex<VertexKey,VertexValue> to outVal : Vertex<K,ValueWithDegree> in method package setOutputWithDegrees(outVal Vertex<K,ValueWithDegree>, out Collector) : void in class org.apache.flink.graph.spargel.VertexUpdateFunction |
From |
To |
|
Change Parameter Type mf : MessagingFunction<VertexKey,VertexValue,Message,EdgeValue> to mf : MessagingFunction<K,VV,Message,EV> in method private getMessageType(mf MessagingFunction<K,VV,Message,EV>) : TypeInformation<Message> in class org.apache.flink.graph.spargel.VertexCentricIteration |
From |
To |
|
Change Parameter Type graph : Graph<VertexKey,VertexValue,EdgeValue> to graph : Graph<K,VV,EV> in method private createResultVerticesWithDegrees(graph Graph<K,VV,EV>, messagingDirection EdgeDirection, messageTypeInfo TypeInformation<Tuple2<K,Message>>) : DataSet<Vertex<K,VV>> in class org.apache.flink.graph.spargel.VertexCentricIteration |
From |
To |
|
Change Parameter Type resultType : TypeInformation<Tuple2<VertexKey,Message>> to resultType : TypeInformation<Tuple2<K,Message>> in method private MessagingUdfWithEdgeValues(messagingFunction MessagingFunction<K,VV,Message,EV>, resultType TypeInformation<Tuple2<K,Message>>) in class org.apache.flink.graph.spargel.VertexCentricIteration.MessagingUdfWithEdgeValues |
From |
To |
|
Change Parameter Type out : Collector<Vertex<VertexKey,VertexValue>> to out : Collector in method package setOutputWithDegrees(outVal Vertex<K,ValueWithDegree>, out Collector) : void in class org.apache.flink.graph.spargel.VertexUpdateFunction |
From |
To |
|
Change Parameter Type vertex : Vertex<Long,Tuple3<Long,Long,Boolean>> to vertex : Vertex<Long,Long> in method public sendMessages(vertex Vertex<Long,Long>) : void in class org.apache.flink.graph.test.VertexCentricConfigurationITCase.DegreesMessageFunction |
From |
To |
|
Change Parameter Type outDegree : Long to outDegree : long in method package setOutDegree(outDegree long) : void in class org.apache.flink.graph.spargel.MessagingFunction |
From |
To |
|
Change Parameter Type edgesWithValue : DataSet<Edge<VertexKey,EdgeValue>> to edgesWithValue : DataSet<Edge<K,EV>> in method private VertexCentricIteration(uf VertexUpdateFunction<K,VV,Message>, mf MessagingFunction<K,VV,Message,EV>, edgesWithValue DataSet<Edge<K,EV>>, maximumNumberOfIterations int) in class org.apache.flink.graph.spargel.VertexCentricIteration |
From |
To |
|
Change Parameter Type messageTypeInfo : TypeInformation<Tuple2<VertexKey,Message>> to messageTypeInfo : TypeInformation<Tuple2<K,Message>> in method private buildMessagingFunction(iteration DeltaIteration<Vertex<K,VV>,Vertex<K,VV>>, messageTypeInfo TypeInformation<Tuple2<K,Message>>, whereArg int, equalToArg int) : CoGroupOperator<?,?,Tuple2<K,Message>> in class org.apache.flink.graph.spargel.VertexCentricIteration |
From |
To |
|
Change Parameter Type messageTypeInfo : TypeInformation<Tuple2<VertexKey,Message>> to messageTypeInfo : TypeInformation<Tuple2<K,Message>> in method private createResultSimpleVertex(messagingDirection EdgeDirection, messageTypeInfo TypeInformation<Tuple2<K,Message>>) : DataSet<Vertex<K,VV>> in class org.apache.flink.graph.spargel.VertexCentricIteration |
From |
To |
|
Change Parameter Type newValue : VertexValue to newValue : VV in method public setNewVertexValue(newValue VV) : void in class org.apache.flink.graph.spargel.VertexUpdateFunction |
From |
To |
|
Change Parameter Type iteration : DeltaIteration<Vertex<VertexKey,VertexValue>,Vertex<VertexKey,VertexValue>> to iteration : DeltaIteration<Vertex<K,VV>,Vertex<K,VV>> in method private buildMessagingFunction(iteration DeltaIteration<Vertex<K,VV>,Vertex<K,VV>>, messageTypeInfo TypeInformation<Tuple2<K,Message>>, whereArg int, equalToArg int) : CoGroupOperator<?,?,Tuple2<K,Message>> in class org.apache.flink.graph.spargel.VertexCentricIteration |
From |
To |
|
Change Parameter Type mf : MessagingFunction<VertexKey,VertexValue,Message,EdgeValue> to mf : MessagingFunction<K,VV,Message,EV> in method private VertexCentricIteration(uf VertexUpdateFunction<K,VV,Message>, mf MessagingFunction<K,VV,Message,EV>, edgesWithValue DataSet<Edge<K,EV>>, maximumNumberOfIterations int) in class org.apache.flink.graph.spargel.VertexCentricIteration |
From |
To |
|
Change Parameter Type resultType : TypeInformation<Vertex<VertexKey,VV>> to resultType : TypeInformation<Vertex<K,VVWithDegrees>> in method private VertexUpdateUdf(vertexUpdateFunction VertexUpdateFunction<K,VVWithDegrees,Message>, resultType TypeInformation<Vertex<K,VVWithDegrees>>) in class org.apache.flink.graph.spargel.VertexCentricIteration.VertexUpdateUdf |
From |
To |
|
Change Parameter Type input : Iterator<Edge<VertexKey,EdgeValue>> to input : Iterator<Edge<K,EV>> in method package set(input Iterator<Edge<K,EV>>) : void in class org.apache.flink.graph.spargel.MessagingFunction.EdgesIterator |
From |
To |
|
Change Parameter Type messageTypeInfo : TypeInformation<Tuple2<VertexKey,Message>> to messageTypeInfo : TypeInformation<Tuple2<K,Message>> in method private createResultVerticesWithDegrees(graph Graph<K,VV,EV>, messagingDirection EdgeDirection, messageTypeInfo TypeInformation<Tuple2<K,Message>>) : DataSet<Vertex<K,VV>> in class org.apache.flink.graph.spargel.VertexCentricIteration |
From |
To |
|
Change Parameter Type vertexUpdateFunction : VertexUpdateFunction<VertexKey,VertexValue,Message> to vertexUpdateFunction : VertexUpdateFunction<K,VVWithDegrees,Message> in method private VertexUpdateUdf(vertexUpdateFunction VertexUpdateFunction<K,VVWithDegrees,Message>, resultType TypeInformation<Vertex<K,VVWithDegrees>>) in class org.apache.flink.graph.spargel.VertexCentricIteration.VertexUpdateUdf |
From |
To |
|
Change Parameter Type messagingFunction : MessagingFunction<VertexKey,VertexValue,Message,EdgeValue> to messagingFunction : MessagingFunction<K,VV,Message,EV> in method private MessagingUdfWithEdgeValues(messagingFunction MessagingFunction<K,VV,Message,EV>, resultType TypeInformation<Tuple2<K,Message>>) in class org.apache.flink.graph.spargel.VertexCentricIteration.MessagingUdfWithEdgeValues |
From |
To |
|
Change Parameter Type iteration : DeltaIteration<Vertex<VertexKey,Tuple3<VertexValue,Long,Long>>,Vertex<VertexKey,Tuple3<VertexValue,Long,Long>>> to iteration : DeltaIteration<Vertex<K,Tuple3<VV,Long,Long>>,Vertex<K,Tuple3<VV,Long,Long>>> in method private buildMessagingFunctionVerticesWithDegrees(iteration DeltaIteration<Vertex<K,Tuple3<VV,Long,Long>>,Vertex<K,Tuple3<VV,Long,Long>>>, messageTypeInfo TypeInformation<Tuple2<K,Message>>, whereArg int, equalToArg int) : CoGroupOperator<?,?,Tuple2<K,Message>> in class org.apache.flink.graph.spargel.VertexCentricIteration |
From |
To |
|
Change Parameter Type inDegree : Long to inDegree : long in method package setInDegree(inDegree long) : void in class org.apache.flink.graph.spargel.MessagingFunction |
From |
To |
|
Change Parameter Type uf : VertexUpdateFunction<VertexKey,VertexValue,Message> to uf : VertexUpdateFunction<K,VV,Message> in method public withEdges(edgesWithValue DataSet<Edge<K,EV>>, uf VertexUpdateFunction<K,VV,Message>, mf MessagingFunction<K,VV,Message,EV>, maximumNumberOfIterations int) : VertexCentricIteration<K,VV,Message,EV> in class org.apache.flink.graph.spargel.VertexCentricIteration |
From |
To |
|
Change Parameter Type inputData : DataSet<Vertex<VertexKey,VertexValue>> to inputData : DataSet<Vertex<K,VV>> in method public setInput(inputData DataSet<Vertex<K,VV>>) : void in class org.apache.flink.graph.spargel.VertexCentricIteration |
From |
To |
|
Change Parameter Type messageTypeInfo : TypeInformation<Tuple2<VertexKey,Message>> to messageTypeInfo : TypeInformation<Tuple2<K,Message>> in method private buildMessagingFunctionVerticesWithDegrees(iteration DeltaIteration<Vertex<K,Tuple3<VV,Long,Long>>,Vertex<K,Tuple3<VV,Long,Long>>>, messageTypeInfo TypeInformation<Tuple2<K,Message>>, whereArg int, equalToArg int) : CoGroupOperator<?,?,Tuple2<K,Message>> in class org.apache.flink.graph.spargel.VertexCentricIteration |
From |
To |
|
Change Parameter Type mf : MessagingFunction<VertexKey,VertexValue,Message,EdgeValue> to mf : MessagingFunction<K,VV,Message,EV> in method public withEdges(edgesWithValue DataSet<Edge<K,EV>>, uf VertexUpdateFunction<K,VV,Message>, mf MessagingFunction<K,VV,Message,EV>, maximumNumberOfIterations int) : VertexCentricIteration<K,VV,Message,EV> in class org.apache.flink.graph.spargel.VertexCentricIteration |
From |
To |
|
Change Parameter Type uf : VertexUpdateFunction<VertexKey,VertexValue,Message> to uf : VertexUpdateFunction<K,VV,Message> in method private VertexCentricIteration(uf VertexUpdateFunction<K,VV,Message>, mf MessagingFunction<K,VV,Message,EV>, edgesWithValue DataSet<Edge<K,EV>>, maximumNumberOfIterations int) in class org.apache.flink.graph.spargel.VertexCentricIteration |
From |
To |
|
Change Parameter Type updates : CoGroupOperator<?,?,Vertex<VertexKey,VV>> to updates : CoGroupOperator<?,?,Vertex<K,VVWithDegree>> in method private configureUpdateFunction(updates CoGroupOperator<?,?,Vertex<K,VVWithDegree>>) : void in class org.apache.flink.graph.spargel.VertexCentricIteration |
From |
To |
|
Change Parameter Type vertices : DataSet<Vertex<VertexKey,VV>> to iteration : DeltaIteration<?,?> in method private setUpIteration(iteration DeltaIteration<?,?>) : void in class org.apache.flink.graph.spargel.VertexCentricIteration |
From |
To |
|
Change Parameter Type edgesWithValue : DataSet<Edge<VertexKey,EdgeValue>> to edgesWithValue : DataSet<Edge<K,EV>> in method public withEdges(edgesWithValue DataSet<Edge<K,EV>>, uf VertexUpdateFunction<K,VV,Message>, mf MessagingFunction<K,VV,Message,EV>, maximumNumberOfIterations int) : VertexCentricIteration<K,VV,Message,EV> in class org.apache.flink.graph.spargel.VertexCentricIteration |
From |
To |
|
Change Parameter Type out : Collector<Tuple2<VertexKey,Message>> to out : Collector<Tuple2<K,Message>> in method package set(edges Iterator<?>, out Collector<Tuple2<K,Message>>) : void in class org.apache.flink.graph.spargel.MessagingFunction |
From |
To |
|
Change Return Type CoGroupOperator<?,?,Tuple2<VertexKey,Message>> to CoGroupOperator<?,?,Tuple2<K,Message>> in method private buildMessagingFunctionVerticesWithDegrees(iteration DeltaIteration<Vertex<K,Tuple3<VV,Long,Long>>,Vertex<K,Tuple3<VV,Long,Long>>>, messageTypeInfo TypeInformation<Tuple2<K,Message>>, whereArg int, equalToArg int) : CoGroupOperator<?,?,Tuple2<K,Message>> in class org.apache.flink.graph.spargel.VertexCentricIteration |
From |
To |
|
Change Return Type Iterable<Edge<VertexKey,EdgeValue>> to Iterable<Edge<K,EV>> in method public getEdges() : Iterable<Edge<K,EV>> in class org.apache.flink.graph.spargel.MessagingFunction |
From |
To |
|
Change Return Type TypeInformation<Tuple2<VertexKey,Message>> to TypeInformation<Tuple2<K,Message>> in method public getProducedType() : TypeInformation<Tuple2<K,Message>> in class org.apache.flink.graph.spargel.VertexCentricIteration.MessagingUdfWithEdgeValues |
From |
To |
|
Change Return Type VertexCentricIteration<VertexKey,VertexValue,Message,EdgeValue> to VertexCentricIteration<K,VV,Message,EV> in method public withEdges(edgesWithValue DataSet<Edge<K,EV>>, uf VertexUpdateFunction<K,VV,Message>, mf MessagingFunction<K,VV,Message,EV>, maximumNumberOfIterations int) : VertexCentricIteration<K,VV,Message,EV> in class org.apache.flink.graph.spargel.VertexCentricIteration |
From |
To |
|
Change Return Type CoGroupOperator<?,?,Tuple2<VertexKey,Message>> to CoGroupOperator<?,?,Tuple2<K,Message>> in method private buildMessagingFunction(iteration DeltaIteration<Vertex<K,VV>,Vertex<K,VV>>, messageTypeInfo TypeInformation<Tuple2<K,Message>>, whereArg int, equalToArg int) : CoGroupOperator<?,?,Tuple2<K,Message>> in class org.apache.flink.graph.spargel.VertexCentricIteration |
From |
To |
|
Change Return Type DataSet<Vertex<VertexKey,VertexValue>> to DataSet<Vertex<K,VV>> in method public createResult() : DataSet<Vertex<K,VV>> in class org.apache.flink.graph.spargel.VertexCentricIteration |
From |
To |
|
Change Return Type Iterator<Edge<VertexKey,EdgeValue>> to Iterator<Edge<K,EV>> in method public iterator() : Iterator<Edge<K,EV>> in class org.apache.flink.graph.spargel.MessagingFunction.EdgesIterator |
From |
To |
|
Change Return Type DataSet<Vertex<VertexKey,VertexValue>> to DataSet<Vertex<K,VV>> in method private createResultVerticesWithDegrees(graph Graph<K,VV,EV>, messagingDirection EdgeDirection, messageTypeInfo TypeInformation<Tuple2<K,Message>>) : DataSet<Vertex<K,VV>> in class org.apache.flink.graph.spargel.VertexCentricIteration |
From |
To |
|
Change Return Type Edge<VertexKey,EdgeValue> to Edge<K,EV> in method public next() : Edge<K,EV> in class org.apache.flink.graph.spargel.MessagingFunction.EdgesIterator |
From |
To |
|
Change Return Type DeltaIteration<Vertex<VertexKey,VV>,Vertex<VertexKey,VV>> to void in method private setUpIteration(iteration DeltaIteration<?,?>) : void in class org.apache.flink.graph.spargel.VertexCentricIteration |
From |
To |
|
Change Return Type DataSet<Vertex<VertexKey,VertexValue>> to DataSet<Vertex<K,VV>> in method private createResultSimpleVertex(messagingDirection EdgeDirection, messageTypeInfo TypeInformation<Tuple2<K,Message>>) : DataSet<Vertex<K,VV>> in class org.apache.flink.graph.spargel.VertexCentricIteration |
From |
To |
|
Change Return Type TypeInformation<Vertex<VertexKey,VV>> to TypeInformation<Vertex<K,VVWithDegrees>> in method public getProducedType() : TypeInformation<Vertex<K,VVWithDegrees>> in class org.apache.flink.graph.spargel.VertexCentricIteration.VertexUpdateUdf |
From |
To |
|
Change Variable Type inDegrees : DataSet<Tuple2<VertexKey,Long>> to inDegrees : DataSet<Tuple2<K,Long>> in method private createResultVerticesWithDegrees(graph Graph<K,VV,EV>, messagingDirection EdgeDirection, messageTypeInfo TypeInformation<Tuple2<K,Message>>) : DataSet<Vertex<K,VV>> in class org.apache.flink.graph.spargel.VertexCentricIteration |
From |
To |
|
Change Variable Type parameters : IterationConfiguration to parameters : VertexCentricConfiguration in method public testIterationINDirection() : void in class org.apache.flink.graph.test.VertexCentricConfigurationITCase |
From |
To |
|
Change Variable Type messages : DataSet<Tuple2<VertexKey,Message>> to messages : DataSet<Tuple2<K,Message>> in method private createResultVerticesWithDegrees(graph Graph<K,VV,EV>, messagingDirection EdgeDirection, messageTypeInfo TypeInformation<Tuple2<K,Message>>) : DataSet<Vertex<K,VV>> in class org.apache.flink.graph.spargel.VertexCentricIteration |
From |
To |
|
Change Variable Type messages : CoGroupOperator<?,?,Tuple2<VertexKey,Message>> to messages : CoGroupOperator<?,?,Tuple2<K,Message>> in method private buildMessagingFunctionVerticesWithDegrees(iteration DeltaIteration<Vertex<K,Tuple3<VV,Long,Long>>,Vertex<K,Tuple3<VV,Long,Long>>>, messageTypeInfo TypeInformation<Tuple2<K,Message>>, whereArg int, equalToArg int) : CoGroupOperator<?,?,Tuple2<K,Message>> in class org.apache.flink.graph.spargel.VertexCentricIteration |
From |
To |
|
Change Variable Type graph : Graph<Long,Tuple3<Long,Long,Boolean>,Long> to graph : Graph<Long,Long,Long> in method public testInDegreesNotSet() : void in class org.apache.flink.graph.test.VertexCentricConfigurationITCase |
From |
To |
|
Change Variable Type degrees : DataSet<Tuple3<VertexKey,Long,Long>> to degrees : DataSet<Tuple3<K,Long,Long>> in method private createResultVerticesWithDegrees(graph Graph<K,VV,EV>, messagingDirection EdgeDirection, messageTypeInfo TypeInformation<Tuple2<K,Message>>) : DataSet<Vertex<K,VV>> in class org.apache.flink.graph.spargel.VertexCentricIteration |
From |
To |
|
Change Variable Type verticesWithDegrees : DataSet<Vertex<VertexKey,Tuple3<VertexValue,Long,Long>>> to verticesWithDegrees : DataSet<Vertex<K,Tuple3<VV,Long,Long>>> in method private createResultVerticesWithDegrees(graph Graph<K,VV,EV>, messagingDirection EdgeDirection, messageTypeInfo TypeInformation<Tuple2<K,Message>>) : DataSet<Vertex<K,VV>> in class org.apache.flink.graph.spargel.VertexCentricIteration |
From |
To |
|
Change Variable Type updateUdf : VertexUpdateUdf<VertexKey,Tuple3<VertexValue,Long,Long>,VertexValue,Message> to updateUdf : VertexUpdateUdf<K,Tuple3<VV,Long,Long>,Message> in method private createResultVerticesWithDegrees(graph Graph<K,VV,EV>, messagingDirection EdgeDirection, messageTypeInfo TypeInformation<Tuple2<K,Message>>) : DataSet<Vertex<K,VV>> in class org.apache.flink.graph.spargel.VertexCentricIteration |
From |
To |
|
Change Variable Type updateUdf : VertexUpdateUdf<VertexKey,VertexValue,VertexValue,Message> to updateUdf : VertexUpdateUdf<K,VV,Message> in method private createResultSimpleVertex(messagingDirection EdgeDirection, messageTypeInfo TypeInformation<Tuple2<K,Message>>) : DataSet<Vertex<K,VV>> in class org.apache.flink.graph.spargel.VertexCentricIteration |
From |
To |
|
Change Variable Type parameters : IterationConfiguration to parameters : VertexCentricConfiguration in method public testIncrementalSSSPNonSPEdge() : void in class org.apache.flink.graph.test.example.IncrementalSSSPITCase |
From |
To |
|
Change Variable Type graph : Graph<VertexKey,VertexValue,EdgeValue> to graph : Graph<K,VV,EV> in method public createResult() : DataSet<Vertex<K,VV>> in class org.apache.flink.graph.spargel.VertexCentricIteration |
From |
To |
|
Change Variable Type parameters : IterationConfiguration to parameters : VertexCentricConfiguration in method public testIterationALLDirection() : void in class org.apache.flink.graph.test.VertexCentricConfigurationITCase |
From |
To |
|
Change Variable Type verticesWithDegrees : DataSet<Vertex<Long,Tuple3<Long,Long,Boolean>>> to verticesWithDegrees : DataSet<Vertex<Long,Long>> in method public testInDegreesNotSet() : void in class org.apache.flink.graph.test.VertexCentricConfigurationITCase |
From |
To |
|
Change Variable Type updates : CoGroupOperator<?,?,Vertex<VertexKey,VertexValue>> to updates : CoGroupOperator<?,?,Vertex<K,VV>> in method private createResultSimpleVertex(messagingDirection EdgeDirection, messageTypeInfo TypeInformation<Tuple2<K,Message>>) : DataSet<Vertex<K,VV>> in class org.apache.flink.graph.spargel.VertexCentricIteration |
From |
To |
|
Change Variable Type messages : DataSet<Tuple2<VertexKey,Message>> to messages : DataSet<Tuple2<K,Message>> in method private createResultSimpleVertex(messagingDirection EdgeDirection, messageTypeInfo TypeInformation<Tuple2<K,Message>>) : DataSet<Vertex<K,VV>> in class org.apache.flink.graph.spargel.VertexCentricIteration |
From |
To |
|
Change Variable Type messageTypeInfo : TypeInformation<Tuple2<VertexKey,Message>> to messageTypeInfo : TypeInformation<Tuple2<K,Message>> in method public createResult() : DataSet<Vertex<K,VV>> in class org.apache.flink.graph.spargel.VertexCentricIteration |
From |
To |
|
Change Variable Type parameters : IterationConfiguration to parameters : VertexCentricConfiguration in method public main(args String[]) : void in class org.apache.flink.graph.example.IncrementalSSSPExample |
From |
To |
|
Change Variable Type parameters : IterationConfiguration to parameters : VertexCentricConfiguration in method public testInDegreesSet() : void in class org.apache.flink.graph.test.VertexCentricConfigurationITCase |
From |
To |
|
Change Variable Type k : VertexKey to k : K in method public sendMessageToAllNeighbors(m Message) : void in class org.apache.flink.graph.spargel.MessagingFunction |
From |
To |
|
Change Variable Type messenger : MessagingUdfWithEdgeValues<VertexKey,Tuple3<VertexValue,Long,Long>,VertexValue,Message,EdgeValue> to messenger : MessagingUdfWithEdgeValues<K,Tuple3<VV,Long,Long>,VV,Message,EV> in method private buildMessagingFunctionVerticesWithDegrees(iteration DeltaIteration<Vertex<K,Tuple3<VV,Long,Long>>,Vertex<K,Tuple3<VV,Long,Long>>>, messageTypeInfo TypeInformation<Tuple2<K,Message>>, whereArg int, equalToArg int) : CoGroupOperator<?,?,Tuple2<K,Message>> in class org.apache.flink.graph.spargel.VertexCentricIteration |
From |
To |
|
Change Variable Type messenger : MessagingUdfWithEdgeValues<VertexKey,VertexValue,VertexValue,Message,EdgeValue> to messenger : MessagingUdfWithEdgeValues<K,VV,VV,Message,EV> in method private buildMessagingFunction(iteration DeltaIteration<Vertex<K,VV>,Vertex<K,VV>>, messageTypeInfo TypeInformation<Tuple2<K,Message>>, whereArg int, equalToArg int) : CoGroupOperator<?,?,Tuple2<K,Message>> in class org.apache.flink.graph.spargel.VertexCentricIteration |
From |
To |
|
Change Variable Type updates : CoGroupOperator<?,?,Vertex<VertexKey,Tuple3<VertexValue,Long,Long>>> to updates : CoGroupOperator<?,?,Vertex<K,Tuple3<VV,Long,Long>>> in method private createResultVerticesWithDegrees(graph Graph<K,VV,EV>, messagingDirection EdgeDirection, messageTypeInfo TypeInformation<Tuple2<K,Message>>) : DataSet<Vertex<K,VV>> in class org.apache.flink.graph.spargel.VertexCentricIteration |
From |
To |
|
Change Variable Type keyType : TypeInformation<VertexKey> to keyType : TypeInformation<K> in method public createResult() : DataSet<Vertex<K,VV>> in class org.apache.flink.graph.spargel.VertexCentricIteration |
From |
To |
|
Change Variable Type messages : CoGroupOperator<?,?,Tuple2<VertexKey,Message>> to messages : CoGroupOperator<?,?,Tuple2<K,Message>> in method private buildMessagingFunction(iteration DeltaIteration<Vertex<K,VV>,Vertex<K,VV>>, messageTypeInfo TypeInformation<Tuple2<K,Message>>, whereArg int, equalToArg int) : CoGroupOperator<?,?,Tuple2<K,Message>> in class org.apache.flink.graph.spargel.VertexCentricIteration |
From |
To |
|
Change Variable Type parameters : IterationConfiguration to parameters : VertexCentricConfiguration in method public testDirectionALLAndDegrees() : void in class org.apache.flink.graph.test.VertexCentricConfigurationITCase |
From |
To |
|
Change Variable Type vertexTypes : TypeInformation<Vertex<VertexKey,VertexValue>> to vertexTypes : TypeInformation<Vertex<K,VV>> in method private createResultSimpleVertex(messagingDirection EdgeDirection, messageTypeInfo TypeInformation<Tuple2<K,Message>>) : DataSet<Vertex<K,VV>> in class org.apache.flink.graph.spargel.VertexCentricIteration |
From |
To |
|
Change Variable Type parameters : IterationConfiguration to parameters : VertexCentricConfiguration in method public testOutDegreesSet() : void in class org.apache.flink.graph.test.VertexCentricConfigurationITCase |
From |
To |
|
Change Variable Type next : Edge<VertexKey,EdgeValue> to next : Edge<K,EV> in method public next() : Edge<K,EV> in class org.apache.flink.graph.spargel.MessagingFunction.EdgesIterator |
From |
To |
|
Change Variable Type vertexTypes : TypeInformation<Vertex<VertexKey,Tuple3<VertexValue,Long,Long>>> to vertexTypes : TypeInformation<Vertex<K,Tuple3<VV,Long,Long>>> in method private createResultVerticesWithDegrees(graph Graph<K,VV,EV>, messagingDirection EdgeDirection, messageTypeInfo TypeInformation<Tuple2<K,Message>>) : DataSet<Vertex<K,VV>> in class org.apache.flink.graph.spargel.VertexCentricIteration |
From |
To |
|
Change Variable Type outDegrees : DataSet<Tuple2<VertexKey,Long>> to outDegrees : DataSet<Tuple2<K,Long>> in method private createResultVerticesWithDegrees(graph Graph<K,VV,EV>, messagingDirection EdgeDirection, messageTypeInfo TypeInformation<Tuple2<K,Message>>) : DataSet<Vertex<K,VV>> in class org.apache.flink.graph.spargel.VertexCentricIteration |
From |
To |
|
Change Attribute Type messagingFunction : MessagingFunction<VertexKey,VertexValue,Message,EdgeValue> to messagingFunction : MessagingFunction<K,VV,Message,EV> in class org.apache.flink.graph.spargel.VertexCentricIteration |
From |
To |
|
Change Attribute Type resultType : TypeInformation<Vertex<VertexKey,VV>> to resultType : TypeInformation<Vertex<K,VVWithDegrees>> in class org.apache.flink.graph.spargel.VertexCentricIteration.VertexUpdateUdf |
From |
To |
|
Change Attribute Type outValue : Tuple2<VertexKey,Message> to outValue : Tuple2<K,Message> in class org.apache.flink.graph.spargel.MessagingFunction |
From |
To |
|
Change Attribute Type resultType : TypeInformation<Tuple2<VertexKey,Message>> to resultType : TypeInformation<Tuple2<K,Message>> in class org.apache.flink.graph.spargel.VertexCentricIteration.MessagingUdfWithEdgeValues |
From |
To |
|
Change Attribute Type vertexUpdateFunction : VertexUpdateFunction<VertexKey,VertexValue,Message> to vertexUpdateFunction : VertexUpdateFunction<K,VVWithDegrees,Message> in class org.apache.flink.graph.spargel.VertexCentricIteration.VertexUpdateUdf |
From |
To |
|
Change Attribute Type edge : Edge<VertexKey,EdgeValue> to edge : Edge<K,EV> in class org.apache.flink.graph.spargel.MessagingFunction.EdgesIterator |
From |
To |
|
Change Attribute Type edgesWithValue : DataSet<Edge<VertexKey,EdgeValue>> to edgesWithValue : DataSet<Edge<K,EV>> in class org.apache.flink.graph.spargel.VertexCentricIteration |
From |
To |
|
Change Attribute Type messagingFunction : MessagingFunction<VertexKey,VertexValue,Message,EdgeValue> to messagingFunction : MessagingFunction<K,VV,Message,EV> in class org.apache.flink.graph.spargel.VertexCentricIteration.MessagingUdfWithEdgeValues |
From |
To |
|
Change Attribute Type outWithDegrees : Collector<Vertex<VertexKey,Tuple3<VertexValue,Long,Long>>> to outWithDegrees : Collector<Vertex<K,Tuple3<VV,Long,Long>>> in class org.apache.flink.graph.spargel.VertexUpdateFunction |
From |
To |
|
Change Attribute Type out : Collector<Tuple2<VertexKey,Message>> to out : Collector<Tuple2<K,Message>> in class org.apache.flink.graph.spargel.MessagingFunction |
From |
To |
|
Change Attribute Type outVal : Vertex<VertexKey,VertexValue> to outVal : Vertex<K,VV> in class org.apache.flink.graph.spargel.VertexUpdateFunction |
From |
To |
|
Change Attribute Type out : Collector<Vertex<VertexKey,VertexValue>> to out : Collector<Vertex<K,VV>> in class org.apache.flink.graph.spargel.VertexUpdateFunction |
From |
To |
|
Change Attribute Type outValWithDegrees : Vertex<VertexKey,Tuple3<VertexValue,Long,Long>> to outValWithDegrees : Vertex<K,Tuple3<VV,Long,Long>> in class org.apache.flink.graph.spargel.VertexUpdateFunction |
From |
To |
|
Change Attribute Type input : Iterator<Edge<VertexKey,EdgeValue>> to input : Iterator<Edge<K,EV>> in class org.apache.flink.graph.spargel.MessagingFunction.EdgesIterator |
From |
To |
|
Change Attribute Type edgeIterator : EdgesIterator<VertexKey,EdgeValue> to edgeIterator : EdgesIterator<K,EV> in class org.apache.flink.graph.spargel.MessagingFunction |
From |
To |
|
Change Attribute Type updateFunction : VertexUpdateFunction<VertexKey,VertexValue,Message> to updateFunction : VertexUpdateFunction<K,VV,Message> in class org.apache.flink.graph.spargel.VertexCentricIteration |
From |
To |
|
Change Attribute Type initialVertices : DataSet<Vertex<VertexKey,VertexValue>> to initialVertices : DataSet<Vertex<K,VV>> in class org.apache.flink.graph.spargel.VertexCentricIteration |
From |
To |