May 2017
Intermediate to advanced
294 pages
7h 33m
English
$ spark-shell --packages org.apache.spark:spark-sql-kafka-0-10_2.11:2.1.1
scala> val data = spark.readStream.format("kafka").option("kafka.bootstrap.servers","localhost:9092").option("subscribe","oscars").load()
scala> data.isStreaming
scala> data.printSchema
scala> val data = spark.readStream.format("kafka").option("kafka.bootstrap.servers","localhost:9092").option("subscribe","oscars").load()
scala> ...
Read now
Unlock full access