I have CB spark connector 2.2.0 and I tried following insert query using spark connector
val query = "insert into " + userBucketName + " values ('" + values._1 + "',{'data':" +
values._2.map(_._2).toSeq + "});"
println("QQ:"+query)
sc.sparkContext
.couchbaseQuery(N1qlQuery.simple(query), bucketName = userBucketName)
.collect()
but this query not insert into CB and values._2.map(_._2)
size more than millions