May 2017
Intermediate to advanced
294 pages
7h 33m
English
$ spark-shell
scala> import org.apache.spark.ml.linalg.Vectorsscala> import org.apache.spark.ml.regression.LinearRegression
scala> val points = spark.createDataFrame(Seq( (1620000,Vectors.dense(2100)), (1690000,Vectors.dense(2300)), (1400000,Vectors.dense(2046)), (2000000,Vectors.dense(4314)), (1060000,Vectors.dense(1244)), (3830000,Vectors.dense(4608)), (1230000,Vectors.dense(2173)), (2400000,Vectors.dense(2750)), (3380000,Vectors.dense(4010)), (1480000,Vectors.dense(1959)) )).toDF("label","features")
scala> val lr = new LinearRegression()
Read now
Unlock full access