JIRA: [NEMO-15: Run Spark ALS in distributed 
mode](https://issues.apache.org/jira/projects/NEMO/issues/NEMO-15)

**Major changes:**
- Removes 'sideinput' from IRDAG, and instead introduces 
BroadcastVariableProperty
- InMasterBroadcastVariables/BroadcastManagerWorker: Components that deal with 
broadcast variables
- New RPC messages for exchanging broadcast variables between client->driver, 
and driver<->executor 

**Minor changes to note:**
- Explicit scala lambdas (update_ms, update_us) to get around serialization 
errors

**Tests for the changes:**
- SparkScala#testALS

**Other comments:**
- This PR also closes: [NEMO-14] Re-investigate Broadcast and SideInputs

Closes #GITHUB_PR_NUMBER


[ Full content available at: https://github.com/apache/incubator-nemo/pull/113 ]
This message was relayed via gitbox.apache.org for [email protected]

Reply via email to