Spark＆Scalaを使用してCouchBaseにデータを書き込む方法は？

Question

私はCouchBase.Iで初心者には、以下のローカルmode.MyのサンプルコードでのCouchbaseのにデータを書き込むことが

val cfg = new SparkConf() 
.setAppName("couchbaseQuickstart") 
.setMaster("local[*]") 
.set("com.couchbase.bucket.MyBucket","pwd") 

    val sc = new SparkContext(cfg) 
    val doc1 = JsonDocument.create("doc1", JsonObject.create().put("some","content")) 
    val doc2 = JsonArrayDocument.create("doc2", JsonArray.from("more", "content", "in", "here")) 
    val data = sc.parallelize(Seq(doc1, doc2)) 

をしようとしていますが、私は（）data.saveToCouchbaseにアクセスすることはできません。

私はスパーク1.6.1 &スカラ座2.11.8に

を使用しています

私はスパーク&スカラ座を使用してのCouchbaseにデータを書き込むことができますどのように

built.sbtに

libraryDependencies += "org.apache.spark" % "spark-core_2.11" % "1.6.1" 
libraryDependencies += "com.couchbase.client" % "spark-connector_2.11" % "1.2.1" 

を次の依存関係を与えましたか？

Answer 1

あなただけのRDDSとデータフレームにCouchbaseの機能を使用することができますよimport文が欠落しているように見える：

import com.couchbase.spark._ 

val cfg = new SparkConf() 
.setAppName("couchbaseQuickstart") 
.setMaster("local[*]") 
.set("com.couchbase.bucket.MyBucket","pwd") 

val sc = new SparkContext(cfg) 
val doc1 = JsonDocument.create("doc1", 

JsonObject.create().put("some","content")) 
val doc2 = JsonArrayDocument.create("doc2", JsonArray.from("more", "content", "in", "here")) 

val data = sc.parallelize(Seq(doc1, doc2)) 

data.saveToCouchbase()