flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Andra Lungu (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-2714) Port the Flink DataSet Triangle Count example to the Gelly library
Date Mon, 05 Oct 2015 07:36:26 GMT

    [ https://issues.apache.org/jira/browse/FLINK-2714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14943010#comment-14943010

Andra Lungu commented on FLINK-2714:

Only someone with admin rights can assign you. [~uce] can you please help us out with that?

GSATriangleCount is the Gather-Sum-Apply-Scatter version of this algorithm. The vertex-centric
variant is covered by FLINK-2634.
Nevertheless, you can still port the Flink DataSet example. Simply look at the example we
have in Gelly and adapt that implementation to fit the API. One example of a modification
would be to add a call to "reduce". The example in the DataSet API ennumerates triangles and
the one we have in Gelly counts them. Also add relevant comments and JavaDoc and don't forget
to update the test.

Let us know if you have further questions.  

> Port the Flink DataSet Triangle Count example to the Gelly library
> ------------------------------------------------------------------
>                 Key: FLINK-2714
>                 URL: https://issues.apache.org/jira/browse/FLINK-2714
>             Project: Flink
>          Issue Type: Task
>          Components: Gelly
>    Affects Versions: 0.10
>         Environment: 
>            Reporter: Andra Lungu
>            Priority: Trivial
>              Labels: newbie, starter
> Currently, the Gelly library contains two methods for counting the number of triangles
in a graph: a vertex-centric version and a gather-apply-scatter version. 
> This issue proposes the addition of a third library method based on this Flink example:
> https://github.com/apache/flink/blob/master/flink-examples/flink-java-examples/src/main/java/org/apache/flink/examples/java/graph/EnumTrianglesOpt.java
> The only modification needed is an extra reduce step that takes the enumerated triangles
produced and yields a number. 

This message was sent by Atlassian JIRA

View raw message