That is great ! It worked.
I tried to the following code in spark-shell:
import org.apache.spark._
import com.couchbase.spark._
import com.couchbase.spark.sql._
import com.couchbase.client.java.document.JsonDocument
sc.stop
val conf = new SparkConf()
.setMaster("local[*]")
.setAppName("myapp")
.set("com.couchbase.nodes", "localhost")
.set("com.couchbase.bucket.travel-sample", "")
.set("com.couchbase.bucket.beer-sample", "")
val sc = new SparkContext(conf)
val sqlContext = new org.apache.spark.sql.SQLContext(sc)
val airlines = sqlContext.read.couchbase(schemaFilter = org.apache.spark.sql.sources.EqualTo("type", "airline"))
val breweries = sqlContext.read.couchbase(schemaFilter = org.apache.spark.sql.sources.EqualTo("type", "brewery"))
How do I specify the bucket name for travel-sample ?
Cheers