Skip to content

Instantly share code, notes, and snippets.

@josep2

josep2/spark_streaming_couchbase.scala

Created January 1, 2017 21:55
Show Gist options
  • Save josep2/5c071b3528f73341a959fd6b8c84ca19 to your computer and use it in GitHub Desktop.
Save josep2/5c071b3528f73341a959fd6b8c84ca19 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
spark_streaming_couchbase.scala
// Set up A Streaming Context
val ssc = new StreamingContext(conf, Seconds(2))
ssc
.couchbaseStream(from = FromBeginning, to = ToInfinity)
.someMethod()
ssc.start()
ssc.awaitTermination()
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment