Skip to content

Instantly share code, notes, and snippets.

View valiantljk's full-sized avatar

jialin valiantljk

  • Amazon
  • California
View GitHub Profile
import scala.collection.immutable.List
import spark.SparkContext._
import spark.streaming._
import spark.streaming.StreamingContext._
import spark.streaming.dstream._
object DataStream extends App {
val reportHeader = """----------------------------------------------