From d952d44c2da9d064a15ef93139c74bac98c2a1a2 Mon Sep 17 00:00:00 2001 From: Rajdeep Dua Date: Wed, 28 Dec 2016 14:42:06 +0530 Subject: [PATCH] [PIO-48] scala-local-helloword Sample Not working --- .../scala-local-helloworld/HelloWorld.scala | 20 ++++++++++++++----- .../scala-local-helloworld/build.sbt | 6 ++++-- 2 files changed, 19 insertions(+), 7 deletions(-) diff --git a/examples/experimental/scala-local-helloworld/HelloWorld.scala b/examples/experimental/scala-local-helloworld/HelloWorld.scala index bc565ce5d2..6ec4f0af56 100644 --- a/examples/experimental/scala-local-helloworld/HelloWorld.scala +++ b/examples/experimental/scala-local-helloworld/HelloWorld.scala @@ -42,11 +42,17 @@ class MyPredictedResult( val temperature: Double ) extends Serializable -// controller components -class MyDataSource extends LDataSource[EmptyDataSourceParams, EmptyDataParams, - MyTrainingData, MyQuery, EmptyActualResult] { +case class MyDataSourceParams(val multiplier: Int + ) extends Params + +class MyDataSource extends LDataSource[ + MyTrainingData, + EmptyEvaluationInfo, + MyQuery, + EmptyActualResult] { /* override this to return Training Data only */ + override def readTraining(): MyTrainingData = { val lines = Source.fromFile("../data/helloworld/data.csv").getLines() @@ -59,8 +65,12 @@ class MyDataSource extends LDataSource[EmptyDataSourceParams, EmptyDataParams, } } -class MyAlgorithm extends LAlgorithm[EmptyAlgorithmParams, MyTrainingData, - MyModel, MyQuery, MyPredictedResult] { +class MyAlgorithm extends LAlgorithm[ + MyTrainingData, + MyModel, + MyQuery, + MyPredictedResult] { + override def train(pd: MyTrainingData): MyModel = { diff --git a/examples/experimental/scala-local-helloworld/build.sbt b/examples/experimental/scala-local-helloworld/build.sbt index df7ba52ef1..94d147e275 100644 --- a/examples/experimental/scala-local-helloworld/build.sbt +++ b/examples/experimental/scala-local-helloworld/build.sbt @@ -24,6 +24,8 @@ name := "example-scala-local-helloworld" organization := "org.sample" libraryDependencies ++= Seq( - "org.apache.predictionio" %% "core" % "0.9.1" % "provided", - "org.apache.predictionio" %% "data" % "0.9.1" % "provided", + "org.slf4j" % "slf4j-api" % "1.6.1", + "org.apache.predictionio" % "apache-predictionio-data_2.10" % "0.10.0-incubating", + "org.apache.predictionio" %% "apache-predictionio-core" % "0.10.0-incubating", "org.apache.spark" %% "spark-core" % "1.2.0" % "provided") +