Hi Martin, To start participating/ send emails to dev@flink.incubator.apache.org please send subscribe request first to dev-subscr...@flink.incubator.apache.org.
Thanks, - Henry On Mon, Jul 14, 2014 at 4:23 AM, <dev-reject-1405337015.11291.ejgagdfpnegdnbgoe...@flink.incubator.apache.org> wrote: > > To approve: > dev-accept-1405337015.11291.ejgagdfpnegdnbgoe...@flink.incubator.apache.org > To reject: > dev-reject-1405337015.11291.ejgagdfpnegdnbgoe...@flink.incubator.apache.org > To give a reason to reject: > %%% Start comment > %%% End comment > > > > ---------- Forwarded message ---------- > From: Martin Neumann <mneum...@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 >
