Hi Martin,
To start participating/ send emails to
[hidden email]
please send subscribe request first to
[hidden email].
Thanks,
- Henry
On Mon, Jul 14, 2014 at 4:23 AM,
<
[hidden email]>
wrote:
>
> To approve:
>
[hidden email]
> To reject:
>
[hidden email]
> To give a reason to reject:
> %%% Start comment
> %%% End comment
>
>
>
> ---------- Forwarded message ----------
> From: Martin Neumann <
[hidden email]>
> To:
[hidden email]
> 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
>
Locked
