Yes, Soumya that file contents are newline separated.
You can run that program in 4 Steps (Hoping that you already have your
spark/hadoop up and running)
1. Copy the code and paste as SimpleApp.scala
2. Create a sbt build file with all dependencies, which is pasted below
3. do a *sbt package*
4. then *sbt run*
*simple.sbt*
name := "Simple Project"
version := "1.0"
scalaVersion := "2.9.3"
libraryDependencies += "org.apache.spark" %% "spark-streaming" %
"0.8.0-incubating"
resolvers ++= Seq("Akka Repository" at "http://repo.akka.io/releases/","Spray
Repository" at "http://repo.spray.cc/";)
-
AkhilDas
CodeBreach.in
- in.linkedin.com/in/akhildas/
