You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by va...@apache.org on 2015/05/05 19:40:02 UTC

[2/4] flink git commit: [gelly] [docs] Change the return type of groupReduceOnNeighbors example

[gelly] [docs] Change the return type of groupReduceOnNeighbors example

This closes #650


Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/51aa6661
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/51aa6661
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/51aa6661

Branch: refs/heads/master
Commit: 51aa6661a156a7f7b4be7aaa1913963866a5e9a6
Parents: 7d2e5aa
Author: joey001 <zh...@gmail.com>
Authored: Mon May 4 22:12:54 2015 +0200
Committer: vasia <va...@apache.org>
Committed: Tue May 5 17:11:28 2015 +0200

----------------------------------------------------------------------
 docs/libs/gelly_guide.md | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/51aa6661/docs/libs/gelly_guide.md
----------------------------------------------------------------------
diff --git a/docs/libs/gelly_guide.md b/docs/libs/gelly_guide.md
index 91f0978..6ea7dc7 100644
--- a/docs/libs/gelly_guide.md
+++ b/docs/libs/gelly_guide.md
@@ -325,7 +325,7 @@ For example, the following code will output all the vertex pairs which are conne
 {% highlight java %}
 Graph<Long, Long, Double> graph = ...
 
-DataSet<Tuple2<Long, Long>> vertexPairs = graph.groupReduceOnNeighbors(new SelectLargeWeightNeighbors(), EdgeDirection.OUT);
+DataSet<Tuple2<Vertex<Long, Long>, Vertex<Long, Long>>> vertexPairs = graph.groupReduceOnNeighbors(new SelectLargeWeightNeighbors(), EdgeDirection.OUT);
 
 // user-defined function to select the neighbors which have edges with weight > 0.5
 static final class SelectLargeWeightNeighbors implements NeighborsFunctionWithVertexValue<Long, Long, Double,