Re: MODERATE for dev@flink.incubator.apache.org

[Henry Saputra <he...@gmail.com>]

Hi Martin,

To start participating/ send emails to dev@flink.incubator.apache.org
please send subscribe request first to
dev-subscribe@flink.incubator.apache.org.



Thanks,

- Henry


On Mon, Jul 14, 2014 at 4:23 AM,
<de...@flink.incubator.apache.org>
wrote:
>
> To approve:
>    dev-accept-1405337015.11291.ejgagdfpnegdnbgoeeeh@flink.incubator.apache.org
> To reject:
>    dev-reject-1405337015.11291.ejgagdfpnegdnbgoeeeh@flink.incubator.apache.org
> To give a reason to reject:
> %%% Start comment
> %%% End comment
>
>
>
> ---------- Forwarded message ----------
> From: Martin Neumann <mn...@spotify.com>
> To: dev@flink.incubator.apache.org
> Cc:
> Date: Mon, 14 Jul 2014 13:23:07 +0200
> Subject: broadcast variable in spargel
> Hej,
>
> I'm using the latest trunk version of Flink and the new JavaAPI.
> I'm writing some graph algorithms that need to know the number of nodes in the graph. To get the number of nodes I run a short count job and then get a DataSet<Long> that I need to give as input to the other calculations.
>
> It works for normal operations:
>
> nodeList.map(new VertexInit()).withBroadcastSet(numNodes, "#Nodes");
>
>
> However when I call the Spargelcode I don't get the option to do .withBroadcastSet
>
> initNodeList.runOperation(VertexCentricIteration.withPlainEdges(edgeList, new VertexRankUpdater(10, 0.85), new RankMessenger(), 100));
>
>
> How do I use broadcast variables in Spargel?
>
>
> cheers Martin
>