Details
-
Improvement
-
Resolution: Fixed
-
Major
-
None
-
None
-
None
-
1
-
SDK46: Limit Err, CB++, Spark
Description
import com.couchbase.spark._ |
import com.couchbase.client.scala.json.JsonObject |
import com.couchbase.client.scala.analytics.AnalyticsOptions |
val query = "SELECT ht.city,ht.state,COUNT(*) AS num_hotels FROM hotel ht GROUP BY ht.city,ht.state HAVING COUNT(*) > 30" |
val options = AnalyticsOptions(Scope = Some("inventory")) |
val result = sc.couchbaseAnalyticsQuery[JsonObject](query, options)
|
|
|
result.collect().foreach(println)
|
Environment : Scala 2.12 and Spark 3.1.1
The error message is
command-1883199299897832:6: error: not found: value Scope val options = AnalyticsOptions(Scope = Some("inventory"))
Attachments
For Gerrit Dashboard: SPARKC-146 | ||||||
---|---|---|---|---|---|---|
# | Subject | Branch | Project | Status | CR | V |
165329,2 | SPARKC-146: Add support for scope-level query and analytics RDD | master | couchbase-spark-connector | Status: MERGED | +2 | +1 |