flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Henry Saputra <henry.sapu...@gmail.com>
Subject Re: MODERATE for dev@flink.incubator.apache.org
Date Mon, 14 Jul 2014 22:32:04 GMT
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,
<dev-reject-1405337015.11291.ejgagdfpnegdnbgoeeeh@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 <mneumann@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
>

Mime
View raw message