Hi Michele! This may help explain things: https://cwiki.apache.org/confluence/display/FLINK/Variables+Closures+vs.+Broadcast+Variables
Greetings, Stephan On Wed, Jun 24, 2015 at 6:23 PM, Michele Bertoni < michele1.bert...@mail.polimi.it> wrote: > Hi everybody, > this question may sounds stupid, but i would like to have it clear > > what happens if inside a dataset transformation (e.g. a map) I use > something that is declared somewhere else, like a variable or a dataset, > and not passed as broadcast dataset nor parameter in the constructor of a > rich function? > > for example > > val a = 2 > dataset.filter((v) => v._1 == a) > > or > > dataset1.flatmap((v) => /* something that uses dataset2 */) > > > thanks
