flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Vasiliki Kalavri <vasilikikala...@gmail.com>
Subject Re: Multiple sources shortest path
Date Sun, 15 Feb 2015 11:37:46 GMT

you can certainly use a for-loop like this to run SSSP several times. Just
make sure you return or store the result of the computation for each
source, by adding a data sink e.g.:

for (id : Ids) {
          graph.run(new SingleSourceShortestPaths<Long>(id, maxIterations))

However, if you have a large amount of source nodes, executing one SSSP for
each of them is probably not the most efficient way to go.
Instead, you could maybe write a custom multiple shortest paths program,
where each node calculates distances for multiple sources in each
iteration. In this case, the vertex value could be a vector of size equal
to the number of input sources.


On 14 February 2015 at 12:26, HungChang <unicorn.banachi@gmail.com> wrote:

> Hi,
> In graph api there's an single source shortest path library.
> DataSet<Vertex&lt;Long,Double>> singleSourceShortestPaths =
>                 graph.run(new SingleSourceShortestPaths<Long>(srcVertexId,
> maxIterations)).getVertices();
> For Multiple Source, would it be possible to run it for all nodes using
> for-loop?
> for example,
> for(Node node: nodes){
>  DataSet<Vertex&lt;Long,Double>> singleSourceShortestPaths =
>                 graph.run(new SingleSourceShortestPaths<Long>(node,
> maxIterations)).getVertices();
> }
> --
> View this message in context:
> http://apache-flink-incubator-user-mailing-list-archive.2336050.n4.nabble.com/Multiple-sources-shortest-path-tp729.html
> Sent from the Apache Flink (Incubator) User Mailing List archive. mailing
> list archive at Nabble.com.

View raw message