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,