Advertisement
Guest User

Untitled

a guest
Apr 17th, 2014
61
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
Scala 0.46 KB | None | 0 0
  1. val trainingDataTable = sql("""
  2.    SELECT e.action, u.age, u.latitude, u.longitude
  3.    FROM Users u
  4.    JOIN Events e
  5.    ON u.userId = e.userId""")
  6.  
  7. // Since `sql` returns an RDD, the results can be easily used in MLlib
  8. val trainingData = trainingDataTable.map { case Row(_, age, latitude, longitude) =>
  9.   val features = Array[Double](age, latitude, longitude)
  10.   LabeledPoint(age, features)
  11. }
  12. val model = new LogisticRegressionWithSGD().run(trainingData)
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement