Return-Path: 
 <dev-return-1353-apmail-flink-dev-archive=flink.apache.org@flink.incubator.apache.org>
X-Original-To: apmail-flink-dev-archive@www.apache.org
Delivered-To: apmail-flink-dev-archive@www.apache.org
Received: from mail.apache.org (hermes.apache.org [140.211.11.3])
	by minotaur.apache.org (Postfix) with SMTP id E1CB611F7C
	for <apmail-flink-dev-archive@www.apache.org>;
 Mon, 14 Jul 2014 11:27:58 +0000 (UTC)
Received: (qmail 15678 invoked by uid 500); 14 Jul 2014 11:27:58 -0000
Delivered-To: apmail-flink-dev-archive@flink.apache.org
Received: (qmail 15626 invoked by uid 500); 14 Jul 2014 11:27:58 -0000
Mailing-List: contact dev-help@flink.incubator.apache.org; run by ezmlm
Precedence: bulk
List-Help: <mailto:dev-help@flink.incubator.apache.org>
List-Unsubscribe: <mailto:dev-unsubscribe@flink.incubator.apache.org>
List-Post: <mailto:dev@flink.incubator.apache.org>
List-Id: <dev.flink.incubator.apache.org>
Reply-To: dev@flink.incubator.apache.org
Delivered-To: mailing list dev@flink.incubator.apache.org
Delivered-To: moderator for dev@flink.incubator.apache.org
Received: (qmail 11281 invoked by uid 99); 14 Jul 2014 11:23:35 -0000
X-ASF-Spam-Status: No, hits=1.5 required=5.0
	tests=HTML_MESSAGE,RCVD_IN_DNSWL_LOW,SPF_PASS
X-Spam-Check-By: apache.org
Received-SPF: pass (nike.apache.org: domain of mneumann@spotify.com designates
 209.85.220.175 as permitted sender)
X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed;
        d=1e100.net; s=20130820;
        h=x-gm-message-state:mime-version:date:message-id:subject:from:to
         :content-type;
        bh=buLAGrxF5witbzUNgQa1BpWO4B+V9qg29JCVKJ82/bc=;
        b=NJeYY1WTdfNgP9Wyk/hMBKL/0t8Wl3Oo7mmCw3CTOOf4u4xGWOK6wa4NIQb/xIZjcz
         pW+8vG5VrZOxwf/m+zLntyT7cpfbcOpIFfQ+HdX1p+M4EqM2Wnpb1jjlDptorK8MUAvb
         R1ailF50XitRLXxAEm+7FkPCfA+1fIHPvRlfy2NuU+4Y9vLgcz/38uSwMcoxtqrEuvug
         DFiGJqbgB2nKRFgcqeh0wWVn9dDlb/1k6SwrMkEQ2ZZo8EgjNamJhO439oeb89nSwQN0
         0EEvkKUKNkyGXRKf+KMiOlemjwaTtV2mstgSUccCpWy7MfIhGj7W7XSbVIJhViMMM1dz
         8+JA==
X-Gm-Message-State: 
 ALoCoQmUn8aEXzJVwL9Ao6egiAb2dgY6SsqCtsf8fgHRfbInZcVfKXjEIyEfemF+MQi7rgj3WXuz
MIME-Version: 1.0
X-Received: by 10.52.106.162 with SMTP id gv2mr55761vdb.47.1405336987511; Mon,
 14 Jul 2014 04:23:07 -0700 (PDT)
Date: Mon, 14 Jul 2014 13:23:07 +0200
Message-ID: 
 <CAHuUK3XByMwy-YRpx1L5=PO0J4qH7cDGy1zU1jvreEsr-Kv51g@mail.gmail.com>
Subject: broadcast variable in spargel
From: Martin Neumann <mneumann@spotify.com>
To: dev@flink.incubator.apache.org
Content-Type: multipart/alternative; boundary=bcaec548a9bdee478304fe2583a0
X-Virus-Checked: Checked by ClamAV on apache.org

--bcaec548a9bdee478304fe2583a0
Content-Type: text/plain; charset=UTF-8

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

--bcaec548a9bdee478304fe2583a0--