@@ -229,14 +229,14 @@ class ALS private (
229229 // perform ALS update
230230 logInfo(" Re-computing I given U (Iteration %d/%d)" .format(iter, iterations))
231231 // Persist users because it will be called twice.
232- users.setName(" users-%d " .format( iter) ).persist()
232+ users.setName(s " users- $ iter" ).persist()
233233 val YtY = Some (sc.broadcast(computeYtY(users)))
234234 val previousProducts = products
235235 products = updateFeatures(users, userOutLinks, productInLinks, partitioner, rank, lambda,
236236 alpha, YtY )
237237 previousProducts.unpersist()
238238 logInfo(" Re-computing U given I (Iteration %d/%d)" .format(iter, iterations))
239- products.setName(" products-%d " .format( iter) ).persist()
239+ products.setName(s " products- $ iter" ).persist()
240240 val XtX = Some (sc.broadcast(computeYtY(products)))
241241 val previousUsers = users
242242 users = updateFeatures(products, productOutLinks, userInLinks, partitioner, rank, lambda,
@@ -249,11 +249,11 @@ class ALS private (
249249 logInfo(" Re-computing I given U (Iteration %d/%d)" .format(iter, iterations))
250250 products = updateFeatures(users, userOutLinks, productInLinks, partitioner, rank, lambda,
251251 alpha, YtY = None )
252- products.setName(" products-%d " .format( iter) )
252+ products.setName(s " products- $ iter" )
253253 logInfo(" Re-computing U given I (Iteration %d/%d)" .format(iter, iterations))
254254 users = updateFeatures(products, productOutLinks, userInLinks, partitioner, rank, lambda,
255255 alpha, YtY = None )
256- users.setName(" users-%d " .format( iter) )
256+ users.setName(s " users- $ iter" )
257257 }
258258 }
259259
0 commit comments