mkdir spark-streaming-example
cd spark-streaming-example/
mkdir -p src/main/scala
cd src/main/scala
vim TestStreaming.scala
add following line of code to TestStreaming.scala
import org.apache.spark.streaming.StreamingContext
import org.apache.spark.streaming.StreamingContext._
import org.apache.spark.streaming.dstream.DStream
import org.apache.spark.streaming.Duration
import org.apache.spark.streaming.Seconds
import org.apache.spark.SparkConf
object TestStreaming{
def main(args:Array[String]){
val conf = new SparkConf().setAppName("Streaming Test")
val ssc = new StreamingContext(conf,Seconds(30))
val lines = ssc.socketTextStream("hostname",6002)
val errorLines = lines.filter(_.contains("error"))
lines.print
errorLines.print()
//errorLines.saveAsTextFiles("errorline.txt")
println("starting streaming context")
ssc.start()
println("awaiting termination")
ssc.awaitTermination()
println("App done")
}
}
cd -
vim build.sbt
name := "Spark Streaming Example"
version := "1.0"
scalaVersion := "2.10.4"
libraryDependencies ++= Seq("org.apache.spark" %% "spark-core" % "1.4.1","org.apache.spark" %% "spark-streaming" % "1.4.1")
*now run sbt package from project home and it will build a jar inside target/scala-2.10/spark-streaming-example_2.10-1.0.jar
* run this jar using spark-submit
#bin/spark-submit --class TestStreaming target/scala-2.10/spark-streaming-example_2.10-1.0.jar
to test this program open a different terminal and run nc -lk `hostname` 6002 hit enter and type anything on console while will display on the spark console.
Friday, October 23, 2015
Spark Streaming Sample program using scala
Subscribe to:
Post Comments (Atom)
No comments:
Post a Comment