Hi,
something like .withBroadcastSet() is not yet available in the DataStream
API. I'm working on it, however. Using a (global) static variable will not
work for this case since the computation is distributed.
The iteration does not work because the head of the iteration (the "loop"
variable) is n
Hello all,
How could I broadcast the variable in Datastream or perform similar
operation so that I could read the value as in DataSet:
IterativeDataSet *loop* = centroids.iterate(numIterations);
DataSet *newCentroids* = points.map(new SelectNearestCenter()).
*withBroadcastSet*(*loop*, "*centroids*
