File tree Expand file tree Collapse file tree 2 files changed +3
-3
lines changed
src/main/scala/com/high-performance-spark-examples/streaming Expand file tree Collapse file tree 2 files changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -42,7 +42,7 @@ libraryDependencies ++= Seq(
4242 " junit" % " junit" % " 4.11" ,
4343 " com.holdenkarau" %% " spark-testing-base" % " 2.1.0_0.6.0" ,
4444 " com.novocode" % " junit-interface" % " 0.11" % " test->default" ,
45- // tag::sacalLogging []
45+ // tag::scalaLogging []
4646 " com.typesafe.scala-logging" %% " scala-logging" % " 3.5.0" ,
4747 // end::scalaLogging[]
4848 " org.codehaus.jackson" % " jackson-core-asl" % " 1.8.8" ,
Original file line number Diff line number Diff line change @@ -30,13 +30,13 @@ object DStreamExamples {
3030 val batchInterval = Seconds (1 )
3131 val ssc = new StreamingContext (sc, batchInterval)
3232 ssc.checkpoint(checkpointDir)
33- // Then create whatever stream are required
33+ // Then create whatever stream is required
3434 // And whatever mappings need to go on those streams
3535 ssc
3636 }
3737 val ssc = StreamingContext .getOrCreate(checkpointDir,
3838 createStreamingContext _)
39- // Do whatever work needs to be regardless of state
39+ // Do whatever work needs to be done regardless of state
4040 // Start context and run
4141 ssc.start()
4242 // end::sscRecover[]
You can’t perform that action at this time.
0 commit comments