|
Change Parameter Type vertices : DataSet<Vertex<K,VV>> to vertices : DataSet<Tuple2<K,VV>> in method public Graph(vertices DataSet<Tuple2<K,VV>>, edges DataSet<Tuple3<K,K,EV>>) in class flink.graphs.Graph |
From |
To |
|
Change Parameter Type cog : CoGroupFunction<Vertex<K,VV>,Edge<K,EV>,Tuple2<K,MsgT>> to cog : CoGroupFunction<Tuple2<K,VV>,Tuple3<K,K,EV>,Tuple2<K,MsgT>> in method public pga(cog CoGroupFunction<Tuple2<K,VV>,Tuple3<K,K,EV>,Tuple2<K,MsgT>>, gred GroupReduceFunction<Tuple2<K,MsgT>,Tuple2<K,MsgT>>, fjoin FlatJoinFunction<Tuple2<K,MsgT>,Tuple2<K,VV>,Tuple2<K,VV>>, maxIterations int) : Graph<K,VV,EV> in class flink.graphs.Graph |
From |
To |
|
Change Parameter Type fjoin : FlatJoinFunction<Tuple2<K,MsgT>,Vertex<K,VV>,Vertex<K,VV>> to fjoin : FlatJoinFunction<Tuple2<K,MsgT>,Tuple2<K,VV>,Tuple2<K,VV>> in method public pga(cog CoGroupFunction<Tuple2<K,VV>,Tuple3<K,K,EV>,Tuple2<K,MsgT>>, gred GroupReduceFunction<Tuple2<K,MsgT>,Tuple2<K,MsgT>>, fjoin FlatJoinFunction<Tuple2<K,MsgT>,Tuple2<K,VV>,Tuple2<K,VV>>, maxIterations int) : Graph<K,VV,EV> in class flink.graphs.Graph |
From |
To |
|
Change Parameter Type edges : DataSet<Edge<K,EV>> to edges : DataSet<Tuple3<K,K,EV>> in method public Graph(vertices DataSet<Tuple2<K,VV>>, edges DataSet<Tuple3<K,K,EV>>) in class flink.graphs.Graph |
From |
To |
|
Change Variable Type doubled : DataSet<Vertex<Integer,Integer>> to doubled : DataSet<Tuple2<Integer,Integer>> in method public testMapVertices() : void in class flink.graphs.GraphTest |
From |
To |
|
Change Variable Type doubledData : List<Vertex<Integer,Integer>> to doubledData : List<Tuple2<Integer,Integer>> in method public testMapVertices() : void in class flink.graphs.GraphTest |
From |
To |
|
Change Variable Type filteredVertices : DataSet<Vertex<K,VV>> to filteredVertices : DataSet<Tuple2<K,VV>> in method public subgraph(Tuple2Filter FilterFunction<VV>, edgeFilter FilterFunction<EV>) : Graph<K,VV,EV> in class flink.graphs.Graph |
From |
To |
|
Change Variable Type filteredEdges : DataSet<Edge<K,EV>> to filteredEdges : DataSet<Tuple3<K,K,EV>> in method public subgraph(Tuple2Filter FilterFunction<VV>, edgeFilter FilterFunction<EV>) : Graph<K,VV,EV> in class flink.graphs.Graph |
From |
To |
|
Change Variable Type a : DataSet<Vertex<K,VV>> to a : DataSet<Tuple2<K,VV>> in method public pga(cog CoGroupFunction<Tuple2<K,VV>,Tuple3<K,K,EV>,Tuple2<K,MsgT>>, gred GroupReduceFunction<Tuple2<K,MsgT>,Tuple2<K,MsgT>>, fjoin FlatJoinFunction<Tuple2<K,MsgT>,Tuple2<K,VV>,Tuple2<K,VV>>, maxIterations int) : Graph<K,VV,EV> in class flink.graphs.Graph |
From |
To |
|
Change Variable Type result : DataSet<Vertex<K,VV>> to result : DataSet<Tuple2<K,VV>> in method public pga(cog CoGroupFunction<Tuple2<K,VV>,Tuple3<K,K,EV>,Tuple2<K,MsgT>>, gred GroupReduceFunction<Tuple2<K,MsgT>,Tuple2<K,MsgT>>, fjoin FlatJoinFunction<Tuple2<K,MsgT>,Tuple2<K,VV>,Tuple2<K,VV>>, maxIterations int) : Graph<K,VV,EV> in class flink.graphs.Graph |
From |
To |
|
Change Variable Type iteration : DeltaIteration<Vertex<K,VV>,Vertex<K,VV>> to iteration : DeltaIteration<Tuple2<K,VV>,Tuple2<K,VV>> in method public pga(cog CoGroupFunction<Tuple2<K,VV>,Tuple3<K,K,EV>,Tuple2<K,MsgT>>, gred GroupReduceFunction<Tuple2<K,MsgT>,Tuple2<K,MsgT>>, fjoin FlatJoinFunction<Tuple2<K,MsgT>,Tuple2<K,VV>,Tuple2<K,VV>>, maxIterations int) : Graph<K,VV,EV> in class flink.graphs.Graph |
From |
To |
|
Change Variable Type kevEdge : Edge<K,EV> to kevEdge : Tuple3<K,K,EV> in method public subgraph(Tuple2Filter FilterFunction<VV>, edgeFilter FilterFunction<EV>) : Graph<K,VV,EV> in class flink.graphs.Graph |
From |
To |
|
Change Variable Type doubledDataset : DataSet<Vertex<Integer,Integer>> to doubledDataset : DataSet<Tuple2<Integer,Integer>> in method public testMapVertices() : void in class flink.graphs.GraphTest |
From |
To |
|
Change Variable Type originalDataDoubled : List<Vertex<Integer,Integer>> to originalDataDoubled : List<Tuple2<Integer,Integer>> in method public testMapVertices() : void in class flink.graphs.GraphTest |
From |
To |