|
Change Parameter Type state : Iterable<Vertex<K,Tuple3<VV,Long,Long>>> to state : Iterable<Vertex<K,Tuple3<VV,LongValue,LongValue>>> in method public coGroup(edges Iterable<Edge<K,EV>>, state Iterable<Vertex<K,Tuple3<VV,LongValue,LongValue>>>, out Collector<Tuple2<K,Message>>) : void in class org.apache.flink.graph.spargel.ScatterGatherIteration.MessagingUdfWithEVsVVWithDegrees |
From |
To |
|
Change Parameter Type value : Tuple2<Long,Long> to value : Tuple2<Long,LongValue> in method public map(value Tuple2<Long,LongValue>) : Long in class org.apache.flink.graph.examples.GraphMetrics.ProjectVertexId |
From |
To |
|
Change Parameter Type vertex : Iterable<Vertex<K,Tuple3<VV,Long,Long>>> to vertex : Iterable<Vertex<K,Tuple3<VV,LongValue,LongValue>>> in method public coGroup(messages Iterable<Tuple2<K,Message>>, vertex Iterable<Vertex<K,Tuple3<VV,LongValue,LongValue>>>, out Collector<Vertex<K,Tuple3<VV,LongValue,LongValue>>>) : void in class org.apache.flink.graph.spargel.ScatterGatherIteration.VertexUpdateUdfVVWithDegrees |
From |
To |
|
Change Parameter Type iteration : DeltaIteration<Vertex<K,Tuple3<VV,Long,Long>>,Vertex<K,Tuple3<VV,Long,Long>>> to iteration : DeltaIteration<Vertex<K,Tuple3<VV,LongValue,LongValue>>,Vertex<K,Tuple3<VV,LongValue,LongValue>>> in 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>> in class org.apache.flink.graph.spargel.ScatterGatherIteration |
From |
To |
|
Change Parameter Type vertexUpdateFunction : VertexUpdateFunction<K,Tuple3<VV,Long,Long>,Message> to vertexUpdateFunction : VertexUpdateFunction<K,Tuple3<VV,LongValue,LongValue>,Message> in method private VertexUpdateUdfVVWithDegrees(vertexUpdateFunction VertexUpdateFunction<K,Tuple3<VV,LongValue,LongValue>,Message>, resultType TypeInformation<Vertex<K,Tuple3<VV,LongValue,LongValue>>>) in class org.apache.flink.graph.spargel.ScatterGatherIteration.VertexUpdateUdfVVWithDegrees |
From |
To |
|
Change Parameter Type out : Collector<Vertex<K,Tuple3<VV,Long,Long>>> to out : Collector<Vertex<K,Tuple3<VV,LongValue,LongValue>>> in method public coGroup(messages Iterable<Tuple2<K,Message>>, vertex Iterable<Vertex<K,Tuple3<VV,LongValue,LongValue>>>, out Collector<Vertex<K,Tuple3<VV,LongValue,LongValue>>>) : void in class org.apache.flink.graph.spargel.ScatterGatherIteration.VertexUpdateUdfVVWithDegrees |
From |
To |
|
Change Parameter Type out : Collector<Tuple2<K,Long>> to out : Collector<Tuple2<K,LongValue>> in method public coGroup(vertex Iterable<Vertex<K,VV>>, outEdges Iterable<Edge<K,EV>>, out Collector<Tuple2<K,LongValue>>) : void in class org.apache.flink.graph.Graph.CountNeighborsCoGroup |
From |
To |
|
Change Parameter Type resultType : TypeInformation<Vertex<K,Tuple3<VV,Long,Long>>> to resultType : TypeInformation<Vertex<K,Tuple3<VV,LongValue,LongValue>>> in method private VertexUpdateUdfVVWithDegrees(vertexUpdateFunction VertexUpdateFunction<K,Tuple3<VV,LongValue,LongValue>,Message>, resultType TypeInformation<Vertex<K,Tuple3<VV,LongValue,LongValue>>>) in class org.apache.flink.graph.spargel.ScatterGatherIteration.VertexUpdateUdfVVWithDegrees |
From |
To |
|
Change Variable Type result : List<Tuple2<Long,Long>> to result : List<Tuple2<Long,LongValue>> in method public testGetDegrees() : void in class org.apache.flink.graph.test.operations.DegreesITCase |
From |
To |
|
Change Variable Type vertexWithDegrees : Vertex<K,Tuple3<VV,Long,Long>> to vertexWithDegrees : Vertex<K,Tuple3<VV,LongValue,LongValue>> in method public coGroup(edges Iterable<Edge<K,EV>>, state Iterable<Vertex<K,Tuple3<VV,LongValue,LongValue>>>, out Collector<Tuple2<K,Message>>) : void in class org.apache.flink.graph.spargel.ScatterGatherIteration.MessagingUdfWithEVsVVWithDegrees |
From |
To |
|
Change Variable Type vertexIter : Iterator<Vertex<K,Tuple3<VV,Long,Long>>> to vertexIter : Iterator<Vertex<K,Tuple3<VV,LongValue,LongValue>>> in method public coGroup(messages Iterable<Tuple2<K,Message>>, vertex Iterable<Vertex<K,Tuple3<VV,LongValue,LongValue>>>, out Collector<Vertex<K,Tuple3<VV,LongValue,LongValue>>>) : void in class org.apache.flink.graph.spargel.ScatterGatherIteration.VertexUpdateUdfVVWithDegrees |
From |
To |
|
Change Variable Type vertexWithDegrees : Vertex<K,Tuple3<VV,Long,Long>> to vertexWithDegrees : Vertex<K,Tuple3<VV,LongValue,LongValue>> in method public coGroup(messages Iterable<Tuple2<K,Message>>, vertex Iterable<Vertex<K,Tuple3<VV,LongValue,LongValue>>>, out Collector<Vertex<K,Tuple3<VV,LongValue,LongValue>>>) : void in class org.apache.flink.graph.spargel.ScatterGatherIteration.VertexUpdateUdfVVWithDegrees |
From |
To |
|
Change Variable Type data : DataSet<Tuple2<Long,Long>> to data : DataSet<Tuple2<Long,LongValue>> in method public testGetDegrees() : void in class org.apache.flink.graph.test.operations.DegreesITCase |
From |
To |
|
Change Variable Type data : DataSet<Tuple2<Long,Long>> to data : DataSet<Tuple2<Long,LongValue>> in method public testOutDegreesWithNoOutEdges() : void in class org.apache.flink.graph.test.operations.DegreesITCase |
From |
To |
|
Change Variable Type verticesWithDegrees : DataSet<Vertex<K,Tuple3<VV,Long,Long>>> to verticesWithDegrees : DataSet<Vertex<K,Tuple3<VV,LongValue,LongValue>>> 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 |
|
Change Variable Type result : List<Tuple2<Long,Long>> to result : List<Tuple2<Long,LongValue>> in method public testOutDegreesWithNoOutEdges() : void in class org.apache.flink.graph.test.operations.DegreesITCase |
From |
To |
|
Change Variable Type result : List<Tuple2<Long,Long>> to result : List<Tuple2<Long,LongValue>> in method public testOutDegrees() : void in class org.apache.flink.graph.test.operations.DegreesITCase |
From |
To |
|
Change Variable Type degrees : DataSet<Tuple3<K,Long,Long>> to degrees : DataSet<Tuple3<K,LongValue,LongValue>> 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 |
|
Change Variable Type updates : CoGroupOperator<?,?,Vertex<K,Tuple3<VV,Long,Long>>> to updates : CoGroupOperator<?,?,Vertex<K,Tuple3<VV,LongValue,LongValue>>> 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 |
|
Change Variable Type data : DataSet<Tuple2<Long,Long>> to data : DataSet<Tuple2<Long,LongValue>> in method public testGetDegreesWithDisconnectedData() : void in class org.apache.flink.graph.test.operations.DegreesITCase |
From |
To |
|
Change Variable Type result : List<Tuple2<Long,Long>> to result : List<Tuple2<Long,LongValue>> in method public testInDegreesWithNoInEdge() : void in class org.apache.flink.graph.test.operations.DegreesITCase |
From |
To |
|
Change Variable Type messenger : MessagingUdfWithEdgeValues<K,Tuple3<VV,Long,Long>,VV,Message,EV> to messenger : MessagingUdfWithEdgeValues<K,Tuple3<VV,LongValue,LongValue>,VV,Message,EV> in 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>> in class org.apache.flink.graph.spargel.ScatterGatherIteration |
From |
To |
|
Change Variable Type iteration : DeltaIteration<Vertex<K,Tuple3<VV,Long,Long>>,Vertex<K,Tuple3<VV,Long,Long>>> to iteration : DeltaIteration<Vertex<K,Tuple3<VV,LongValue,LongValue>>,Vertex<K,Tuple3<VV,LongValue,LongValue>>> 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 |
|
Change Variable Type vertexTypes : TypeInformation<Vertex<K,Tuple3<VV,Long,Long>>> to vertexTypes : TypeInformation<Vertex<K,Tuple3<VV,LongValue,LongValue>>> 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 |
|
Change Variable Type data : DataSet<Tuple2<Long,Long>> to data : DataSet<Tuple2<Long,LongValue>> in method public testOutDegrees() : void in class org.apache.flink.graph.test.operations.DegreesITCase |
From |
To |
|
Change Variable Type vertexOutDegrees : DataSet<Tuple2<K,Long>> to vertexOutDegrees : DataSet<Tuple2<K,LongValue>> in method public run(network Graph<K,Double,Double>) : DataSet<Vertex<K,Double>> in class org.apache.flink.graph.library.GSAPageRank |
From |
To |
|
Change Variable Type outDegrees : DataSet<Tuple2<K,Long>> to outDegrees : DataSet<Tuple2<K,LongValue>> 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 |
|
Change Variable Type data : DataSet<Tuple2<Long,Long>> to data : DataSet<Tuple2<Long,LongValue>> in method public testInDegrees() : void in class org.apache.flink.graph.test.operations.DegreesITCase |
From |
To |
|
Change Variable Type stateIter : Iterator<Vertex<K,Tuple3<VV,Long,Long>>> to stateIter : Iterator<Vertex<K,Tuple3<VV,LongValue,LongValue>>> in method public coGroup(edges Iterable<Edge<K,EV>>, state Iterable<Vertex<K,Tuple3<VV,LongValue,LongValue>>>, out Collector<Tuple2<K,Message>>) : void in class org.apache.flink.graph.spargel.ScatterGatherIteration.MessagingUdfWithEVsVVWithDegrees |
From |
To |
|
Change Variable Type result : List<Tuple2<Long,Long>> to result : List<Tuple2<Long,LongValue>> in method public testGetDegreesWithDisconnectedData() : void in class org.apache.flink.graph.test.operations.DegreesITCase |
From |
To |
|
Change Variable Type inDegrees : DataSet<Tuple2<K,Long>> to inDegrees : DataSet<Tuple2<K,LongValue>> 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 |
|
Change Variable Type data : DataSet<Tuple2<Long,Long>> to data : DataSet<Tuple2<Long,LongValue>> in method public testInDegreesWithNoInEdge() : void in class org.apache.flink.graph.test.operations.DegreesITCase |
From |
To |
|
Change Variable Type updateUdf : VertexUpdateUdf<K,Tuple3<VV,Long,Long>,Message> to updateUdf : VertexUpdateUdf<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 |
|
Change Variable Type verticesWithDegrees : DataSet<Tuple2<Long,Long>> to verticesWithDegrees : DataSet<Tuple2<Long,LongValue>> in method public main(args String[]) : void in class org.apache.flink.graph.examples.GraphMetrics |
From |
To |
|
Change Variable Type vertexOutDegrees : DataSet<Tuple2<K,Long>> to vertexOutDegrees : DataSet<Tuple2<K,LongValue>> in method public run(network Graph<K,Double,Double>) : DataSet<Vertex<K,Double>> in class org.apache.flink.graph.library.PageRank |
From |
To |
|
Change Variable Type result : List<Tuple2<Long,Long>> to result : List<Tuple2<Long,LongValue>> in method public testInDegrees() : void in class org.apache.flink.graph.test.operations.DegreesITCase |
From |
To |