full_serialize.scala

import org.apache.spark.sql._
import spray.json._
import com.couchbase.client.java.query.N1qlQuery
import com.couchbase.spark.connection.CouchbaseConnection
import com.couchbase.spark._

val sparkSession = "..."

import sparkSession.sqlContext.implicits._

case class Settings(color: String, value: String) // Case class for the JSON

object SettingsProtocol extends DefaultJsonProtocol {
  implicit val settingsFormat = jsonFormat2(Settings)
}

import SettingsProtocol._

// Set up a NQ1L Query

val query1 = "SELECT * from `settings`"

// Query Couchbase
val data = sparkSession.sparkContext.couchbaseQuery(N1qlQuery.simple(query1))
    .collect()
    .map(x => x.value.toString)
    .map(x => x.parseJson.convertTo[Settings])

sparkSession.sparkContext.parallelize(data).toDS().show()

///DataSet

CouchbaseConnection().stop() // Stop Couchbase