Hi Lydia,
Spark and Flink are not identical. Thus, you’ll concepts in both system
which won’t have a corresponding counter part in the other system. For
example, rows.context.broadcast(v) broadcasts the value v so that you can
use it on all Executors. Flink follows a slightly different concept whe
Hi all,
as mentioned before I am trying to import the RowMatrix from Spark to Flink…
In the code I already ran into a dead end… In the function
multiplyGramianMatrixBy() (see end of mail) there is the line:
rows.context.broadcast(v) (rows is a DataSet[Vector]
What exactly is this line doing? Do
