com.couchbase.spark.sql
A simple Structured Streaming sink which writes the data frame to the bucket.
Note that for now Upsert is always used internally to not run into document already exists exception, especially when writing aggregates.
An Offset for the CouchbaseSource.
Companion object of the CouchbaseSourceOffset.
A simple Structured Streaming sink which writes the data frame to the bucket.
Note that for now Upsert is always used internally to not run into document already exists exception, especially when writing aggregates.