[
https://issues.apache.org/jira/browse/FLINK-5243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16977929#comment-16977929
]
Dinesh Balachandran commented on FLINK-5243:
--------------------------------------------
Yes, that's it. Essentially the below:
{code:java}
BipartiteGraph<Long, Long, String, String, Double> bigraph =
BipartiteGraph.fromDataSet(top, bottom, edges, env);
Graph<Long, Double, Double> graph =
bigraph.projectionTopSimple().mapVertices(new
InitVertices(srcVertexId)).mapEdges(new InitEdges());
DataSet<Vertex<Long, Double>> result = new
GSASingleSourceShortestPaths(srcVertexId, maxIterations).run(graph);{code}
The projection API is key to achieve the outcome.
> Implement an example for BipartiteGraph
> ---------------------------------------
>
> Key: FLINK-5243
> URL: https://issues.apache.org/jira/browse/FLINK-5243
> Project: Flink
> Issue Type: Sub-task
> Components: Library / Graph Processing (Gelly)
> Reporter: Ivan Mushketyk
> Priority: Major
> Labels: beginner
>
> Should implement example for BipartiteGraph in gelly-examples project
> similarly to examples for Graph class.
> Depends on this: https://issues.apache.org/jira/browse/FLINK-2254
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
