Krzysztof Ropiak krro
krro
/ prices.scala
Created
September 13, 2015 07:53
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| val prices = quotesFileLines.map { _.split(",").toList(5).toDouble } |
krro
/ readingFile.scala
Created
September 13, 2015 07:53
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| val quotesFileLines = Source.fromFile("...your...path...").getLines.toList |
krro
/ context.scala
Created
September 13, 2015 07:52
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| val sparkConfig = new SparkConf().setAppName("quotes").setMaster("local") | |
| val sparkContext = new SparkContext(sparkConfig) |
krro
/ imports.scala
Created
September 13, 2015 07:51
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| import org.apache.spark.mllib.regression.{ RidgeRegressionWithSGD, LabeledPoint } | |
| import org.apache.spark.{ SparkConf, SparkContext } | |
| import org.apache.spark.mllib.linalg.Vectors | |
| import scala.io.Source |
krro
/ Main.scala
Created
September 13, 2015 07:49
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| import org.apache.spark.mllib.regression.{ RidgeRegressionWithSGD, LabeledPoint } | |
| import org.apache.spark.{ SparkConf, SparkContext } | |
| import org.apache.spark.mllib.linalg.Vectors | |
| import scala.io.Source | |
| object Main extends App { | |
| val sparkConfig = new SparkConf().setAppName("quotes").setMaster("local") | |
| val sparkContext = new SparkContext(sparkConfig) | |
| val quotesFileLines = Source.fromFile("...your...path...").getLines.toList |
krro
/ gist:4df57fffb2a53fac7772
Created
September 13, 2015 07:49
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| import org.apache.spark.mllib.regression.{ RidgeRegressionWithSGD, LabeledPoint } | |
| import org.apache.spark.{ SparkConf, SparkContext } | |
| import org.apache.spark.mllib.linalg.Vectors | |
| import scala.io.Source | |
| object Main extends App { | |
| val sparkConfig = new SparkConf().setAppName("quotes").setMaster("local") | |
| val sparkContext = new SparkContext(sparkConfig) | |
| val quotesFileLines = Source.fromFile("...your...path...").getLines.toList |
NewerOlder