Skip to content

Instantly share code, notes, and snippets.

@nambrot

nambrot/spark_setup.scala

Created December 2, 2017 23:28
Show Gist options
  • Save nambrot/ccc1b33948c6394821f5b748ba763103 to your computer and use it in GitHub Desktop.
Save nambrot/ccc1b33948c6394821f5b748ba763103 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
spark_setup.scala
val conf = new SparkConf().setMaster("local[2]").setAppName("BiometricAlertStreamProcessor")
val sc = new SparkContext((conf))
val ssc = new StreamingContext(sc, Seconds(1))
val heartRateLines = mutable.Queue[RDD[String]]()
val hearRateInput = ssc.queueStream(heartRateLines)
val bloodPressureLines = mutable.Queue[RDD[String]]()
val bloodPressureInput = ssc.queueStream(bloodPressureLines)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment