sparkstream.scala

// Create the Spark Config and instruct to use the travel-sample bucket
// with no password.
val conf = new SparkConf()
  .setMaster("local[*]")
  .setAppName("StreamingExample")
  .set("com.couchbase.bucket.travel-sample", "")

// Initialize StreamingContext with a Batch interval of 5 seconds
val ssc = new StreamingContext(conf, Seconds(5))

// Consume the DCP Stream from the beginning and never stop.
// This counts the messages per interval and prints their count.
ssc
  .couchbaseStream(from = FromBeginning, to = ToInfinity)
  .count()
  .print()

// Start the Stream and await termination
ssc.start()
ssc.awaitTermination()